| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
| H A D | rpl_mts_submode.cc | 107 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
463 THD* thd= rli->info_thd; in wait_for_last_committed_trx()
481 if ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
496 while ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
510 DBUG_RETURN(rli->info_thd->killed || is_error); in wait_for_last_committed_trx()
538 if (sql_slave_killed(rli->info_thd, rli)) in schedule_next_event()
755 if (!(table= c_rli->info_thd->temporary_tables)) in attach_temp_tables()
760 c_rli->info_thd->temporary_tables= 0; in attach_temp_tables()
788 c_rli->info_thd->temporary_tables= cur_table; in attach_temp_tables()
841 THD* thd= rli->info_thd; in get_least_occupied_worker()
[all …]
|
| H A D | rpl_rli_pdb.cc | 264 info_thd= NULL; in ~Slave_worker()
533 info_thd= worker_thd; in copy_values_for_PFS()
590 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in reset_recovery_info()
596 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in reset_recovery_info()
609 info_thd->backup_binlog_lock.release_protection(info_thd); in reset_recovery_info()
634 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in commit_positions()
640 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in commit_positions()
724 info_thd->backup_binlog_lock.release_protection(info_thd); in commit_positions()
1686 THD *thd= info_thd; in do_report()
1838 THD *thd= info_thd; in slave_worker_exec_event()
[all …]
|
| H A D | rpl_rli.h | 153 assert(info_thd); in belongs_to_client()
154 return !info_thd->slave_thread; in belongs_to_client()
963 bool ret= is_in_stmt() || (info_thd->variables.option_bits & OPTION_BEGIN); in is_in_trx_or_stmt()
994 bool ret= is_in_trx_or_stmt() || info_thd->owned_gtid.sidno != 0; in is_in_group()
1020 assert(!info_thd || in set_group_master_log_name()
1021 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_name()
1028 assert(!info_thd || in set_group_master_log_pos()
1029 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_pos()
1102 THD_STAGE_INFO(info_thd, stage_sql_thd_waiting_until_delay); in start_sql_delay()
|
| H A D | rpl_rli.cc | 1158 assert(!info_thd->backup_binlog_lock.is_acquired()); in inc_group_relay_log_pos()
1161 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in inc_group_relay_log_pos()
1239 info_thd->backup_binlog_lock.release_protection(info_thd); in inc_group_relay_log_pos()
1839 assert(!is_mts_worker(info_thd)); in stmt_done()
1881 assert(!is_mts_worker(info_thd)); in stmt_done()
1905 assert(info_thd == thd); in cleanup_context()
1929 info_thd->reset_query(); in cleanup_context()
1930 info_thd->reset_query_for_display(); in cleanup_context()
2845 assert(!info_thd || !is_mts_worker(info_thd) || !fe); in set_rli_description_event()
2851 if (info_thd) in set_rli_description_event()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
| H A D | rpl_mts_submode.cc | 107 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
463 THD* thd= rli->info_thd; in wait_for_last_committed_trx()
481 if ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
496 while ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
510 DBUG_RETURN(rli->info_thd->killed || is_error); in wait_for_last_committed_trx()
538 if (sql_slave_killed(rli->info_thd, rli)) in schedule_next_event()
755 if (!(table= c_rli->info_thd->temporary_tables)) in attach_temp_tables()
760 c_rli->info_thd->temporary_tables= 0; in attach_temp_tables()
788 c_rli->info_thd->temporary_tables= cur_table; in attach_temp_tables()
841 THD* thd= rli->info_thd; in get_least_occupied_worker()
[all …]
|
| H A D | rpl_rli_pdb.cc | 264 info_thd= NULL; in ~Slave_worker()
533 info_thd= worker_thd; in copy_values_for_PFS()
590 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in reset_recovery_info()
596 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in reset_recovery_info()
609 info_thd->backup_binlog_lock.release_protection(info_thd); in reset_recovery_info()
634 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in commit_positions()
640 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in commit_positions()
724 info_thd->backup_binlog_lock.release_protection(info_thd); in commit_positions()
1686 THD *thd= info_thd; in do_report()
1838 THD *thd= info_thd; in slave_worker_exec_event()
[all …]
|
| H A D | rpl_rli.h | 153 assert(info_thd); in belongs_to_client()
154 return !info_thd->slave_thread; in belongs_to_client()
963 bool ret= is_in_stmt() || (info_thd->variables.option_bits & OPTION_BEGIN); in is_in_trx_or_stmt()
994 bool ret= is_in_trx_or_stmt() || info_thd->owned_gtid.sidno != 0; in is_in_group()
1020 assert(!info_thd || in set_group_master_log_name()
1021 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_name()
1028 assert(!info_thd || in set_group_master_log_pos()
1029 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_pos()
1102 THD_STAGE_INFO(info_thd, stage_sql_thd_waiting_until_delay); in start_sql_delay()
|
| H A D | rpl_rli.cc | 1158 assert(!info_thd->backup_binlog_lock.is_acquired()); in inc_group_relay_log_pos()
1161 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in inc_group_relay_log_pos()
1239 info_thd->backup_binlog_lock.release_protection(info_thd); in inc_group_relay_log_pos()
1839 assert(!is_mts_worker(info_thd)); in stmt_done()
1881 assert(!is_mts_worker(info_thd)); in stmt_done()
1905 assert(info_thd == thd); in cleanup_context()
1929 info_thd->reset_query(); in cleanup_context()
1930 info_thd->reset_query_for_display(); in cleanup_context()
2845 assert(!info_thd || !is_mts_worker(info_thd) || !fe); in set_rli_description_event()
2851 if (info_thd) in set_rli_description_event()
[all …]
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
| H A D | rpl_mts_submode.cc | 107 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
463 THD* thd= rli->info_thd; in wait_for_last_committed_trx()
481 if ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
496 while ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
510 DBUG_RETURN(rli->info_thd->killed || is_error); in wait_for_last_committed_trx()
538 if (sql_slave_killed(rli->info_thd, rli)) in schedule_next_event()
755 if (!(table= c_rli->info_thd->temporary_tables)) in attach_temp_tables()
760 c_rli->info_thd->temporary_tables= 0; in attach_temp_tables()
788 c_rli->info_thd->temporary_tables= cur_table; in attach_temp_tables()
841 THD* thd= rli->info_thd; in get_least_occupied_worker()
[all …]
|
| /dports/databases/mysql57-client/mysql-5.7.36/sql/ |
| H A D | rpl_mts_submode.cc | 107 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
463 THD* thd= rli->info_thd; in wait_for_last_committed_trx()
481 if ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
496 while ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
510 DBUG_RETURN(rli->info_thd->killed || is_error); in wait_for_last_committed_trx()
538 if (sql_slave_killed(rli->info_thd, rli)) in schedule_next_event()
755 if (!(table= c_rli->info_thd->temporary_tables)) in attach_temp_tables()
760 c_rli->info_thd->temporary_tables= 0; in attach_temp_tables()
788 c_rli->info_thd->temporary_tables= cur_table; in attach_temp_tables()
841 THD* thd= rli->info_thd; in get_least_occupied_worker()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
| H A D | rpl_mts_submode.cc | 107 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
463 THD* thd= rli->info_thd; in wait_for_last_committed_trx()
481 if ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
496 while ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
510 DBUG_RETURN(rli->info_thd->killed || is_error); in wait_for_last_committed_trx()
538 if (sql_slave_killed(rli->info_thd, rli)) in schedule_next_event()
755 if (!(table= c_rli->info_thd->temporary_tables)) in attach_temp_tables()
760 c_rli->info_thd->temporary_tables= 0; in attach_temp_tables()
788 c_rli->info_thd->temporary_tables= cur_table; in attach_temp_tables()
841 THD* thd= rli->info_thd; in get_least_occupied_worker()
[all …]
|
| H A D | rpl_rli_pdb.cc | 264 info_thd= NULL; in ~Slave_worker()
533 info_thd= worker_thd; in copy_values_for_PFS()
590 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in reset_recovery_info()
596 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in reset_recovery_info()
609 info_thd->backup_binlog_lock.release_protection(info_thd); in reset_recovery_info()
634 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in commit_positions()
640 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in commit_positions()
724 info_thd->backup_binlog_lock.release_protection(info_thd); in commit_positions()
1686 THD *thd= info_thd; in do_report()
1838 THD *thd= info_thd; in slave_worker_exec_event()
[all …]
|
| H A D | rpl_rli.h | 153 assert(info_thd); in belongs_to_client()
154 return !info_thd->slave_thread; in belongs_to_client()
963 bool ret= is_in_stmt() || (info_thd->variables.option_bits & OPTION_BEGIN); in is_in_trx_or_stmt()
994 bool ret= is_in_trx_or_stmt() || info_thd->owned_gtid.sidno != 0; in is_in_group()
1020 assert(!info_thd || in set_group_master_log_name()
1021 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_name()
1028 assert(!info_thd || in set_group_master_log_pos()
1029 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_pos()
1102 THD_STAGE_INFO(info_thd, stage_sql_thd_waiting_until_delay); in start_sql_delay()
|
| H A D | rpl_rli.cc | 1158 assert(!info_thd->backup_binlog_lock.is_acquired()); in inc_group_relay_log_pos()
1161 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in inc_group_relay_log_pos()
1239 info_thd->backup_binlog_lock.release_protection(info_thd); in inc_group_relay_log_pos()
1839 assert(!is_mts_worker(info_thd)); in stmt_done()
1881 assert(!is_mts_worker(info_thd)); in stmt_done()
1905 assert(info_thd == thd); in cleanup_context()
1929 info_thd->reset_query(); in cleanup_context()
1930 info_thd->reset_query_for_display(); in cleanup_context()
2845 assert(!info_thd || !is_mts_worker(info_thd) || !fe); in set_rli_description_event()
2851 if (info_thd) in set_rli_description_event()
[all …]
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
| H A D | rpl_mts_submode.cc | 107 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
463 THD* thd= rli->info_thd; in wait_for_last_committed_trx()
481 if ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
496 while ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
510 DBUG_RETURN(rli->info_thd->killed || is_error); in wait_for_last_committed_trx()
538 if (sql_slave_killed(rli->info_thd, rli)) in schedule_next_event()
755 if (!(table= c_rli->info_thd->temporary_tables)) in attach_temp_tables()
760 c_rli->info_thd->temporary_tables= 0; in attach_temp_tables()
788 c_rli->info_thd->temporary_tables= cur_table; in attach_temp_tables()
841 THD* thd= rli->info_thd; in get_least_occupied_worker()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
| H A D | rpl_rli.h | 136 DBUG_ASSERT(info_thd); in belongs_to_client()
137 return !info_thd->slave_thread; in belongs_to_client()
749 return (info_thd->variables.option_bits & OPTION_BEGIN) || in is_in_group()
752 info_thd->owned_gtid.sidno; in is_in_group()
776 DBUG_ASSERT(!info_thd || in set_group_master_log_name()
777 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_name()
784 DBUG_ASSERT(!info_thd || in set_group_master_log_pos()
785 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_pos()
850 THD_STAGE_INFO(info_thd, stage_sql_thd_waiting_until_delay); in start_sql_delay()
|
| H A D | rpl_rli_pdb.cc | 242 info_thd= NULL; in ~Slave_worker()
520 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in reset_recovery_info()
526 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in reset_recovery_info()
539 info_thd->backup_binlog_lock.release_protection(info_thd); in reset_recovery_info()
564 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in commit_positions()
570 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in commit_positions()
654 info_thd->backup_binlog_lock.release_protection(info_thd); in commit_positions()
932 THD *thd= rli->info_thd; in map_db_to_worker()
1721 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
1890 THD *thd= rli->info_thd; in append_item_to_jobs()
[all …]
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
| H A D | rpl_rli.h | 136 DBUG_ASSERT(info_thd); in belongs_to_client()
137 return !info_thd->slave_thread; in belongs_to_client()
749 return (info_thd->variables.option_bits & OPTION_BEGIN) || in is_in_group()
752 info_thd->owned_gtid.sidno; in is_in_group()
776 DBUG_ASSERT(!info_thd || in set_group_master_log_name()
777 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_name()
784 DBUG_ASSERT(!info_thd || in set_group_master_log_pos()
785 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_pos()
850 THD_STAGE_INFO(info_thd, stage_sql_thd_waiting_until_delay); in start_sql_delay()
|
| H A D | rpl_rli_pdb.cc | 242 info_thd= NULL; in ~Slave_worker()
520 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in reset_recovery_info()
526 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in reset_recovery_info()
539 info_thd->backup_binlog_lock.release_protection(info_thd); in reset_recovery_info()
564 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in commit_positions()
570 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in commit_positions()
654 info_thd->backup_binlog_lock.release_protection(info_thd); in commit_positions()
932 THD *thd= rli->info_thd; in map_db_to_worker()
1721 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
1890 THD *thd= rli->info_thd; in append_item_to_jobs()
[all …]
|
| H A D | rpl_rli.cc | 1010 DBUG_ASSERT(!info_thd->backup_binlog_lock.is_acquired()); in inc_group_relay_log_pos()
1013 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in inc_group_relay_log_pos()
1085 info_thd->backup_binlog_lock.release_protection(info_thd); in inc_group_relay_log_pos()
1530 DBUG_ASSERT(!is_mts_worker(info_thd)); in stmt_done()
1572 DBUG_ASSERT(!is_mts_worker(info_thd)); in stmt_done()
1596 DBUG_ASSERT(info_thd == thd); in cleanup_context()
1616 info_thd->reset_query_for_display(); in cleanup_context()
1619 info_thd->set_query(NULL, 0); in cleanup_context()
2344 DBUG_ASSERT(!info_thd || !is_mts_worker(info_thd) || !fe); in set_rli_description_event()
2349 if (info_thd && is_parallel_exec()) in set_rli_description_event()
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
| H A D | rpl_rli.h | 136 DBUG_ASSERT(info_thd); in belongs_to_client()
137 return !info_thd->slave_thread; in belongs_to_client()
749 return (info_thd->variables.option_bits & OPTION_BEGIN) || in is_in_group()
752 info_thd->owned_gtid.sidno; in is_in_group()
776 DBUG_ASSERT(!info_thd || in set_group_master_log_name()
777 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_name()
784 DBUG_ASSERT(!info_thd || in set_group_master_log_pos()
785 info_thd->backup_binlog_lock.is_protection_acquired()); in set_group_master_log_pos()
850 THD_STAGE_INFO(info_thd, stage_sql_thd_waiting_until_delay); in start_sql_delay()
|
| H A D | rpl_rli_pdb.cc | 242 info_thd= NULL; in ~Slave_worker()
520 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in reset_recovery_info()
526 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in reset_recovery_info()
539 info_thd->backup_binlog_lock.release_protection(info_thd); in reset_recovery_info()
564 if (info_thd && !info_thd->backup_binlog_lock.is_acquired()) in commit_positions()
570 if (info_thd->backup_binlog_lock.acquire_protection(info_thd, MDL_EXPLICIT, in commit_positions()
654 info_thd->backup_binlog_lock.release_protection(info_thd); in commit_positions()
932 THD *thd= rli->info_thd; in map_db_to_worker()
1721 THD *thd= rli->info_thd; in wait_for_workers_to_finish()
1890 THD *thd= rli->info_thd; in append_item_to_jobs()
[all …]
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/ |
| H A D | rpl_mts_submode.cc | 119 THD *thd = rli->info_thd; in wait_for_workers_to_finish()
564 THD *thd = rli->info_thd; in wait_for_last_committed_trx()
581 if ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
593 } while ((!rli->info_thd->killed && !is_error) && in wait_for_last_committed_trx()
605 return rli->info_thd->killed || is_error; in wait_for_last_committed_trx()
629 if (sql_slave_killed(rli->info_thd, rli)) return 0; in schedule_next_event()
829 if (!(table = c_rli->info_thd->temporary_tables)) { in attach_temp_tables()
833 c_rli->info_thd->temporary_tables = nullptr; in attach_temp_tables()
858 c_rli->info_thd->temporary_tables = cur_table; in attach_temp_tables()
902 THD *thd = rli->info_thd; in get_least_occupied_worker()
[all …]
|
| H A D | rpl_rli.cc | 1229 DBUG_ASSERT(!is_mts_worker(info_thd)); in stmt_done()
1274 DBUG_ASSERT(info_thd == thd); in cleanup_context()
1297 info_thd->reset_query(); in cleanup_context()
1298 info_thd->reset_query_for_display(); in cleanup_context()
2289 DBUG_ASSERT(!info_thd || !is_mts_worker(info_thd) || !fe); in set_rli_description_event()
2294 if (info_thd) { in set_rli_description_event()
2300 info_thd->in_active_multi_stmt_transaction(); in set_rli_description_event()
2488 THD *thd = info_thd; in adapt_to_master_version_updown()
2759 THD *thd = info_thd; in post_commit()
2987 } else if (this->info_thd != nullptr && in print_applier_security_context_user_host()
[all …]
|
| H A D | rpl_applier_reader.cc | 171 if (sql_slave_killed(m_rli->info_thd, m_rli)) return nullptr; in read_next_event()
211 m_rli->info_thd, m_rli->relay_log.get_binlog_end_pos_lock(), in read_next_event()
223 if (sql_slave_killed(m_rli->info_thd, m_rli)) return nullptr; in read_next_event()
407 is_instance_backup_locked(m_rli->info_thd); in purge_applied_logs()
520 (m_rli->info_thd != nullptr && in debug_print_next_event_positions()
521 m_rli->info_thd->variables.binlog_trx_compression))); in debug_print_next_event_positions()
|