Home
last modified time | relevance | path

Searched refs:Stage_manager (Results 1 – 22 of 22) sorted by relevance

/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/
H A Dbinlog.h38 class Stage_manager {
41 friend class Stage_manager; variable
99 Stage_manager() in Stage_manager() function
103 ~Stage_manager() in ~Stage_manager()
382 Stage_manager stage_manager;
516 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc1493 Stage_manager::Mutex_queue::append(THD *first) in append()
1525 Stage_manager::Mutex_queue::pop_front() in pop_front()
1593 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
1613 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
7009 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7173 Stage_manager::StageID stage, THD *queue, in change_stage()
7180 DBUG_ASSERT(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
7535 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7603 if (change_stage(thd, Stage_manager::SYNC_STAGE, wait_queue, in ordered_commit()
7610 final_queue= stage_manager.fetch_queue_for(Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/mysql56-client/mysql-5.6.51/sql/
H A Dbinlog.h38 class Stage_manager {
41 friend class Stage_manager; variable
99 Stage_manager() in Stage_manager() function
103 ~Stage_manager() in ~Stage_manager()
382 Stage_manager stage_manager;
516 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc1442 Stage_manager::Mutex_queue::append(THD *first) in append()
1474 Stage_manager::Mutex_queue::pop_front() in pop_front()
1542 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
1562 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
6907 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7071 Stage_manager::StageID stage, THD *queue, in change_stage()
7078 DBUG_ASSERT(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
7411 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7479 if (change_stage(thd, Stage_manager::SYNC_STAGE, wait_queue, in ordered_commit()
7486 final_queue= stage_manager.fetch_queue_for(Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Dbinlog.h38 class Stage_manager {
41 friend class Stage_manager; variable
99 Stage_manager() in Stage_manager() function
103 ~Stage_manager() in ~Stage_manager()
382 Stage_manager stage_manager;
518 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc1563 Stage_manager::Mutex_queue::append(THD *first) in append()
1595 Stage_manager::Mutex_queue::pop_front() in pop_front()
1664 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
1684 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
7192 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7356 Stage_manager::StageID stage, THD *queue, in change_stage()
7363 DBUG_ASSERT(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
7711 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7781 if (change_stage(thd, Stage_manager::SYNC_STAGE, wait_queue, in ordered_commit()
7788 final_queue= stage_manager.fetch_queue_for(Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Dbinlog.h38 class Stage_manager {
41 friend class Stage_manager; variable
99 Stage_manager() in Stage_manager() function
103 ~Stage_manager() in ~Stage_manager()
382 Stage_manager stage_manager;
518 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc1563 Stage_manager::Mutex_queue::append(THD *first) in append()
1595 Stage_manager::Mutex_queue::pop_front() in pop_front()
1664 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
1684 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
7192 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7356 Stage_manager::StageID stage, THD *queue, in change_stage()
7363 DBUG_ASSERT(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
7711 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7781 if (change_stage(thd, Stage_manager::SYNC_STAGE, wait_queue, in ordered_commit()
7788 final_queue= stage_manager.fetch_queue_for(Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/
H A Dbinlog.h38 class Stage_manager {
41 friend class Stage_manager; variable
99 Stage_manager() in Stage_manager() function
103 ~Stage_manager() in ~Stage_manager()
382 Stage_manager stage_manager;
518 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc1563 Stage_manager::Mutex_queue::append(THD *first) in append()
1595 Stage_manager::Mutex_queue::pop_front() in pop_front()
1664 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
1684 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
7192 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7356 Stage_manager::StageID stage, THD *queue, in change_stage()
7363 DBUG_ASSERT(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
7711 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7781 if (change_stage(thd, Stage_manager::SYNC_STAGE, wait_queue, in ordered_commit()
7788 final_queue= stage_manager.fetch_queue_for(Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Dbinlog.h55 class Stage_manager {
58 friend class Stage_manager; variable
133 Stage_manager() in Stage_manager() function
137 ~Stage_manager() in ~Stage_manager()
457 Stage_manager stage_manager;
663 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc2053 Stage_manager::Mutex_queue::append(THD *first) in append()
2092 Stage_manager::Mutex_queue::pop_front() in pop_front()
2162 case Stage_manager::FLUSH_STAGE: in enroll_for()
2165 case Stage_manager::SYNC_STAGE: in enroll_for()
2168 case Stage_manager::COMMIT_STAGE: in enroll_for()
2206 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
2252 void Stage_manager::signal_done(THD *queue) in signal_done()
2262 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
9168 DBUG_ASSERT(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
9681 Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dbinlog.h57 class Stage_manager {
60 friend class Stage_manager; variable
135 Stage_manager() in Stage_manager() function
139 ~Stage_manager() in ~Stage_manager()
465 Stage_manager stage_manager;
672 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc2219 Stage_manager::Mutex_queue::append(THD *first) in append()
2258 Stage_manager::Mutex_queue::pop_front() in pop_front()
2328 case Stage_manager::FLUSH_STAGE: in enroll_for()
2331 case Stage_manager::SYNC_STAGE: in enroll_for()
2334 case Stage_manager::COMMIT_STAGE: in enroll_for()
2372 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
2418 void Stage_manager::signal_done(THD *queue) in signal_done()
2428 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
9820 assert(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
10364 Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Dbinlog.h55 class Stage_manager {
58 friend class Stage_manager; variable
133 Stage_manager() in Stage_manager() function
137 ~Stage_manager() in ~Stage_manager()
457 Stage_manager stage_manager;
663 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc2109 Stage_manager::Mutex_queue::append(THD *first) in append()
2148 Stage_manager::Mutex_queue::pop_front() in pop_front()
2218 case Stage_manager::FLUSH_STAGE: in enroll_for()
2221 case Stage_manager::SYNC_STAGE: in enroll_for()
2224 case Stage_manager::COMMIT_STAGE: in enroll_for()
2262 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
2308 void Stage_manager::signal_done(THD *queue) in signal_done()
2318 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
9288 assert(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
9824 Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Dbinlog.h57 class Stage_manager {
60 friend class Stage_manager; variable
135 Stage_manager() in Stage_manager() function
139 ~Stage_manager() in ~Stage_manager()
465 Stage_manager stage_manager;
672 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc2219 Stage_manager::Mutex_queue::append(THD *first) in append()
2258 Stage_manager::Mutex_queue::pop_front() in pop_front()
2328 case Stage_manager::FLUSH_STAGE: in enroll_for()
2331 case Stage_manager::SYNC_STAGE: in enroll_for()
2334 case Stage_manager::COMMIT_STAGE: in enroll_for()
2372 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
2418 void Stage_manager::signal_done(THD *queue) in signal_done()
2428 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
9820 assert(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
10364 Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Dbinlog.h57 class Stage_manager {
60 friend class Stage_manager; variable
135 Stage_manager() in Stage_manager() function
139 ~Stage_manager() in ~Stage_manager()
465 Stage_manager stage_manager;
672 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc2219 Stage_manager::Mutex_queue::append(THD *first) in append()
2258 Stage_manager::Mutex_queue::pop_front() in pop_front()
2328 case Stage_manager::FLUSH_STAGE: in enroll_for()
2331 case Stage_manager::SYNC_STAGE: in enroll_for()
2334 case Stage_manager::COMMIT_STAGE: in enroll_for()
2372 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
2418 void Stage_manager::signal_done(THD *queue) in signal_done()
2428 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
9820 assert(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
10364 Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Dbinlog.h55 class Stage_manager {
58 friend class Stage_manager; variable
133 Stage_manager() in Stage_manager() function
137 ~Stage_manager() in ~Stage_manager()
457 Stage_manager stage_manager;
662 bool change_stage(THD *thd, Stage_manager::StageID stage,
H A Dbinlog.cc2054 Stage_manager::Mutex_queue::append(THD *first) in append()
2093 Stage_manager::Mutex_queue::pop_front() in pop_front()
2163 case Stage_manager::FLUSH_STAGE: in enroll_for()
2166 case Stage_manager::SYNC_STAGE: in enroll_for()
2169 case Stage_manager::COMMIT_STAGE: in enroll_for()
2207 THD *Stage_manager::Mutex_queue::fetch_and_empty() in fetch_and_empty()
2253 void Stage_manager::signal_done(THD *queue) in signal_done()
2263 void Stage_manager::clear_preempt_status(THD *head) in clear_preempt_status()
9168 assert(0 <= stage && stage < Stage_manager::STAGE_COUNTER); in change_stage()
9683 Stage_manager::SYNC_STAGE); in ordered_commit()
[all …]