| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/ |
| H A D | binlog.h | 111 FLUSH_STAGE, enumerator
133 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 6992 std::pair<bool,THD*> current= stage_manager.pop_front(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7009 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7535 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7548 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/mysql56-client/mysql-5.6.51/sql/ |
| H A D | binlog.h | 111 FLUSH_STAGE, enumerator
133 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 6890 std::pair<bool,THD*> current= stage_manager.pop_front(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
6907 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7411 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7424 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
| H A D | binlog.h | 111 FLUSH_STAGE, enumerator
133 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 7175 std::pair<bool,THD*> current= stage_manager.pop_front(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7192 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7711 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7724 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
| H A D | binlog.h | 111 FLUSH_STAGE, enumerator
133 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 7175 std::pair<bool,THD*> current= stage_manager.pop_front(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7192 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7711 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7724 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
| H A D | binlog.h | 111 FLUSH_STAGE, enumerator
133 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 7175 std::pair<bool,THD*> current= stage_manager.pop_front(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7192 THD *queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
7711 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
7724 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
| H A D | binlog.h | 145 FLUSH_STAGE, enumerator
167 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 2130 if (stage == FLUSH_STAGE && has_commit_order_manager(thd)) in enroll_for()
2162 case Stage_manager::FLUSH_STAGE: in enroll_for()
8963 THD *first_seen= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
9589 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
9594 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
9607 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | binlog.h | 147 FLUSH_STAGE, enumerator
169 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 2296 if (stage == FLUSH_STAGE && has_commit_order_manager(thd)) in enroll_for()
2328 case Stage_manager::FLUSH_STAGE: in enroll_for()
9615 THD *first_seen= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
10273 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
10286 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
| H A D | binlog.h | 145 FLUSH_STAGE, enumerator
167 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 2186 if (stage == FLUSH_STAGE && has_commit_order_manager(thd)) in enroll_for()
2218 case Stage_manager::FLUSH_STAGE: in enroll_for()
9083 THD *first_seen= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
9730 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
9735 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
9748 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | binlog.h | 147 FLUSH_STAGE, enumerator
169 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 2296 if (stage == FLUSH_STAGE && has_commit_order_manager(thd)) in enroll_for()
2328 case Stage_manager::FLUSH_STAGE: in enroll_for()
9615 THD *first_seen= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
10273 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
10286 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | binlog.h | 147 FLUSH_STAGE, enumerator
169 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 2296 if (stage == FLUSH_STAGE && has_commit_order_manager(thd)) in enroll_for()
2328 case Stage_manager::FLUSH_STAGE: in enroll_for()
9615 THD *first_seen= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
10273 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
10286 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|
| /dports/databases/mysql57-client/mysql-5.7.36/sql/ |
| H A D | binlog.h | 145 FLUSH_STAGE, enumerator
167 m_queue[FLUSH_STAGE].init( in init()
|
| H A D | binlog.cc | 2131 if (stage == FLUSH_STAGE && has_commit_order_manager(thd)) in enroll_for()
2163 case Stage_manager::FLUSH_STAGE: in enroll_for()
8963 THD *first_seen= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in process_flush_stage_queue()
9589 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
9594 if (change_stage(thd, Stage_manager::FLUSH_STAGE, thd, NULL, &LOCK_log)) in ordered_commit()
9607 final_queue= stage_manager.fetch_queue_for(Stage_manager::FLUSH_STAGE); in ordered_commit()
|