/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/ |
H A D | rpl_commit_stage_manager.h | 165 enum StageID { enum 239 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex, 250 std::pair<bool, THD *> pop_front(StageID stage) { in pop_front() 274 THD *fetch_queue_acquire_lock(StageID stage); 284 THD *fetch_queue_skip_acquire_lock(StageID stage); 299 void wait_count_or_timeout(ulong count, long usec, StageID stage); 308 void signal_done(THD *queue, StageID stage = BINLOG_FLUSH_STAGE); 324 void lock_queue(StageID stage) { m_queue[stage].lock(); } in lock_queue() 331 void unlock_queue(StageID stage) { m_queue[stage].unlock(); } in unlock_queue()
|
H A D | rpl_commit_stage_manager.cc | 145 bool Commit_stage_manager::enroll_for(StageID stage, THD *thd, in enroll_for() 361 StageID stage) { in wait_count_or_timeout() 383 THD *Commit_stage_manager::fetch_queue_acquire_lock(StageID stage) { in fetch_queue_acquire_lock() 388 THD *Commit_stage_manager::fetch_queue_skip_acquire_lock(StageID stage) { in fetch_queue_skip_acquire_lock() 401 void Commit_stage_manager::signal_done(THD *queue, StageID stage) { in signal_done()
|
H A D | binlog.h | 495 bool change_stage(THD *thd, Commit_stage_manager::StageID stage, THD *queue,
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
H A D | binlog.h | 144 enum StageID { enum 214 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 216 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 238 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 256 void wait_count_or_timeout(ulong count, long usec, StageID stage); 663 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 2122 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 2227 void Stage_manager::wait_count_or_timeout(ulong count, long usec, StageID stage) in wait_count_or_timeout() 9161 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
H A D | binlog.h | 146 enum StageID { enum 216 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 218 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 240 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 258 void wait_count_or_timeout(ulong count, long usec, StageID stage); 672 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 2288 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 2393 void Stage_manager::wait_count_or_timeout(ulong count, long usec, StageID stage) in wait_count_or_timeout() 9813 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
H A D | binlog.h | 144 enum StageID { enum 214 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 216 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 238 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 256 void wait_count_or_timeout(ulong count, long usec, StageID stage); 663 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 2178 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 2283 void Stage_manager::wait_count_or_timeout(ulong count, long usec, StageID stage) in wait_count_or_timeout() 9281 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
H A D | binlog.h | 146 enum StageID { enum 216 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 218 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 240 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 258 void wait_count_or_timeout(ulong count, long usec, StageID stage); 672 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 2288 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 2393 void Stage_manager::wait_count_or_timeout(ulong count, long usec, StageID stage) in wait_count_or_timeout() 9813 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
H A D | binlog.h | 146 enum StageID { enum 216 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 218 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 240 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 258 void wait_count_or_timeout(ulong count, long usec, StageID stage); 672 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 2288 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 2393 void Stage_manager::wait_count_or_timeout(ulong count, long usec, StageID stage) in wait_count_or_timeout() 9813 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/mysql57-client/mysql-5.7.36/sql/ |
H A D | binlog.h | 144 enum StageID { enum 214 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 216 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 238 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 256 void wait_count_or_timeout(ulong count, long usec, StageID stage); 662 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 2123 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 2228 void Stage_manager::wait_count_or_timeout(ulong count, long usec, StageID stage) in wait_count_or_timeout() 9161 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/ |
H A D | binlog.h | 110 enum StageID { enum 180 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 182 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 204 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 516 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 1553 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 7173 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/mysql56-client/mysql-5.6.51/sql/ |
H A D | binlog.h | 110 enum StageID { enum 180 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 182 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 204 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 516 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 1502 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 7071 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
H A D | binlog.h | 110 enum StageID { enum 180 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 182 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 204 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 518 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 1623 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 7356 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
H A D | binlog.h | 110 enum StageID { enum 180 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 182 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 204 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 518 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 1623 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 7356 Stage_manager::StageID stage, THD *queue, in change_stage()
|
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
H A D | binlog.h | 110 enum StageID { enum 180 bool enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex); 182 std::pair<bool,THD*> pop_front(StageID stage) in pop_front() 204 THD *fetch_queue_for(StageID stage) { in fetch_queue_for() 518 bool change_stage(THD *thd, Stage_manager::StageID stage,
|
H A D | binlog.cc | 1623 Stage_manager::enroll_for(StageID stage, THD *thd, mysql_mutex_t *stage_mutex) in enroll_for() 7356 Stage_manager::StageID stage, THD *queue, in change_stage()
|