/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/ |
H A D | binlog.h | 38 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 D | binlog.cc | 1493 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 D | binlog.h | 38 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 D | binlog.cc | 1442 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 D | binlog.h | 38 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 D | binlog.cc | 1563 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 D | binlog.h | 38 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 D | binlog.cc | 1563 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 D | binlog.h | 38 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 D | binlog.cc | 1563 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 D | binlog.h | 55 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 D | binlog.cc | 2053 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 D | binlog.h | 57 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 D | binlog.cc | 2219 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 D | binlog.h | 55 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 D | binlog.cc | 2109 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 D | binlog.h | 57 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 D | binlog.cc | 2219 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 D | binlog.h | 57 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 D | binlog.cc | 2219 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 D | binlog.h | 55 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 D | binlog.cc | 2054 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 …]
|