Home
last modified time | relevance | path

Searched refs:StageID (Results 1 – 25 of 26) sorted by relevance

12

/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Drpl_commit_stage_manager.h165 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 Drpl_commit_stage_manager.cc145 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 Dbinlog.h495 bool change_stage(THD *thd, Commit_stage_manager::StageID stage, THD *queue,
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Dbinlog.h144 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 Dbinlog.cc2122 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 Dbinlog.h146 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 Dbinlog.cc2288 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 Dbinlog.h144 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 Dbinlog.cc2178 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 Dbinlog.h146 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 Dbinlog.cc2288 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 Dbinlog.h146 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 Dbinlog.cc2288 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 Dbinlog.h144 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 Dbinlog.cc2123 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 Dbinlog.h110 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 Dbinlog.cc1553 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 Dbinlog.h110 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 Dbinlog.cc1502 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 Dbinlog.h110 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 Dbinlog.cc1623 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 Dbinlog.h110 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 Dbinlog.cc1623 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 Dbinlog.h110 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 Dbinlog.cc1623 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()

12