MySQL 9.1.0
Source Code Documentation
Slave_worker Member List

This is the complete list of members for Slave_worker, including all inherited members.

abort_pos_waitRelay_log_info
abort_slaveRpl_info
adapt_to_master_version(Format_description_log_event *fdle)Relay_log_info
adapt_to_master_version_updown(ulong master_version, ulong current_version)Relay_log_info
add_channel_to_relay_log_name(char *buff, uint buff_size, const char *base_name)Relay_log_infoprivate
add_gtid_set(const Gtid_set *gtid_set)Relay_log_info
add_logged_gtid(rpl_sidno sidno, rpl_gno gno)Relay_log_infoinline
APPLIER_METADATA_LINES_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_TYPERelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_VALUERelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_CHANNELRelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_DELAYRelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_IDRelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_PRIV_CHECKS_HOSTNAMERelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_PRIV_CHECKS_USERNAMERelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_REQUIRE_ROW_FORMATRelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_REQUIRE_TABLE_PRIMARY_KEY_CHECKRelay_log_infoprivatestatic
APPLIER_METADATA_LINES_WITH_WORKERSRelay_log_infoprivatestatic
assign_partition_db(Log_event *ev)Slave_workerprivate
atomic_channel_open_temp_tablesRelay_log_info
atomic_is_stoppingRpl_info
belongs_to_client()Relay_log_infoinline
bitmap_shiftedSlave_worker
c_rliSlave_worker
cached_charsetRelay_log_info
cached_charset_compare(char *charset) constRelay_log_info
cached_charset_invalidate()Relay_log_info
channelRpl_infoprotected
channel_mts_submodeRelay_log_info
check_and_report_end_of_retries(THD *thd)Slave_worker
check_applier_acl_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname)Relay_log_info
check_if_info_was_cleared(const enum_return_check &previous_result) constRelay_log_info
check_info() constRpl_infoinline
check_privilege_checks_user()Relay_log_info
check_privilege_checks_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname)Relay_log_info
checkpoint_groupRelay_log_info
checkpoint_master_log_nameSlave_worker
checkpoint_master_log_posSlave_worker
checkpoint_notifiedSlave_worker
checkpoint_relay_log_nameSlave_worker
checkpoint_relay_log_posSlave_worker
clean_info()Rpl_infoinline
cleanup_after_query()Relay_log_infoinline
cleanup_after_session()Relay_log_infoinline
cleanup_context(THD *, bool)Relay_log_info
clear_error()Slave_reporting_capabilityinline
clear_flag(enum_state_flag flag)Relay_log_infoinline
clear_gtid_monitoring_info()Relay_log_infoinline
clear_info()Relay_log_info
clear_mts_recovery_groups()Relay_log_infoinline
clear_privilege_checks_user()Relay_log_info
clear_processing_trx()Relay_log_infoinline
clear_relay_log_truncated()Relay_log_info
clear_sql_delay()Relay_log_infoinline
clear_tables_to_lock()Relay_log_info
clear_until_option()Relay_log_infoinline
close_temporary_tables()Relay_log_info
commit_order_mngrRelay_log_infoprivate
commit_positions(Log_event *evt, Slave_job_group *ptr_g, bool force)Slave_worker
commit_positions() overrideSlave_workerinlinevirtual
commit_timestamps_statusRelay_log_info
COMMIT_TS_FOUND enum valueRelay_log_info
COMMIT_TS_NOT_FOUND enum valueRelay_log_info
COMMIT_TS_UNKNOWN enum valueRelay_log_info
coordinator_log_after_purgeRelay_log_info
copy_info(Rpl_info_handler *from, Rpl_info_handler *to)Rpl_infoinline
copy_values_for_PFS(ulong worker_id, en_running_state running_status, THD *worker_thd, const Error &last_error, Gtid_monitoring_info *monitoring_info_arg)Slave_worker
copy_worker_metrics(Slave_worker *other)Slave_workerinline
count_relay_log_space()Relay_log_info
curr_group_assigned_partsRelay_log_info
curr_group_daRelay_log_info
curr_group_exec_partsSlave_worker
curr_group_isolatedRelay_log_info
curr_group_seen_beginRelay_log_info
curr_group_seen_gtidRelay_log_info
curr_group_seen_sequence_numberSlave_worker
curr_jobsSlave_worker
current_eventRelay_log_info
current_mts_submodeRelay_log_info
data_condRpl_info
data_lockRpl_info
ddl_not_atomicRelay_log_info
deferred_eventsRelay_log_info
deferred_events_collectingRelay_log_info
deinit_workers()Relay_log_info
detach_engine_ha_data(THD *thd)Relay_log_info
do_report(loglevel level, int err_code, const char *msg, va_list v_args) const overrideSlave_workerprotectedvirtual
do_report(loglevel level, int err_code, const Gtid_specification *gtid_next, const char *msg, va_list v_args) const overrideSlave_workerprotectedvirtual
en_running_state enum nameSlave_worker
end_group_sets_max_dbsSlave_worker
end_info()Slave_workerprivate
enum_priv_checks_status enum nameRelay_log_info
enum_require_row_status enum nameRelay_log_info
enum_require_table_primary_key enum nameRelay_log_info
enum_state_flag enum nameRelay_log_info
err_lockSlave_reporting_capabilitymutable
ERROR_LEAVING enum valueSlave_worker
error_on_rli_init_infoRelay_log_info
event_relay_log_nameRelay_log_infoprotected
event_relay_log_posRelay_log_infoprotected
event_start_posRelay_log_infoprotected
excess_cntSlave_worker
exit_count_lockRelay_log_info
exit_counterRelay_log_info
exit_incrementedSlave_worker
fd_change_notifiedSlave_worker
fill_coord_err_buf(loglevel level, int err_code, const char *buff_coord) constRelay_log_info
finished_processing()Relay_log_infoinline
flush_current_log()Relay_log_info
flush_info(bool force=false)Slave_worker
Relay_log_info::flush_info(const int flush_flags)Relay_log_info
force_flush_postponed_due_to_split_transRelay_log_info
found_commit_order_deadlock()Slave_worker
future_event_relay_log_posRelay_log_infoprotected
gaqRelay_log_info
gaq_indexSlave_workerprivate
get_allow_drop_write_set()Relay_log_infoinline
get_applier_metrics()Relay_log_info
get_c_rli() overrideSlave_workerinlinevirtual
get_channel() constRpl_infoinline
get_channel_field_index()Slave_workerstatic
get_commit_order_manager()Relay_log_infoinline
get_description_info() constRpl_infoinline
get_event_relay_log_name()Relay_log_infoinline
get_event_relay_log_pos()Relay_log_infoinline
get_event_start_pos()Relay_log_infoinline
get_flag(enum_state_flag flag)Relay_log_infoinline
get_for_channel_str(bool upper_case=false) const overrideSlave_workervirtual
get_future_event_relay_log_pos()Relay_log_infoinline
get_group_master_log_name() constRelay_log_infoinline
get_group_master_log_name_info() constRelay_log_infoinline
get_group_master_log_pos() constRelay_log_infoinline
get_group_master_log_pos_info() constRelay_log_infoinline
get_group_relay_log_name()Relay_log_infoinline
get_group_relay_log_pos()Relay_log_infoinline
get_group_source_log_start_end_pos() constRelay_log_info
get_gtid_monitoring_info()Relay_log_infoinline
get_gtid_set() constRelay_log_infoinline
get_ignore_write_set_memory_limit()Relay_log_infoinline
get_internal_id() constRpl_infoinline
get_master_log_name()Slave_worker
get_master_log_pos()Slave_workerinline
get_master_server_version()Slave_workerinline
get_number_info_rli_fields()Relay_log_infostatic
get_number_worker_fields()Slave_workerstatic
get_privilege_checks_hostname() constRelay_log_info
get_privilege_checks_username() constRelay_log_info
get_require_table_primary_key_check() constRelay_log_info
get_rli_description_event() constRelay_log_infoinline
get_row_stmt_start_timestamp()Relay_log_infoinline
get_rpl_info_handler()Rpl_infoinline
get_rpl_log_name() constRelay_log_infoinline
get_sql_delay()Relay_log_infoinline
get_sql_delay_end()Relay_log_infoinline
get_table_data(TABLE *table_arg, table_def **tabledef_var, TABLE **conv_table_var) constRelay_log_infoinline
get_table_pk_field_indexes()Slave_workerstatic
get_thd_tx_priority()Relay_log_infoinline
get_tsid_lock()Relay_log_infoinline
get_tsid_map()Relay_log_infoinline
get_until_log_name()Relay_log_info
get_until_log_pos()Relay_log_info
get_worker(size_t n)Relay_log_infoinline
get_worker_count()Relay_log_infoinline
get_worker_metrics()Slave_worker
group_executedSlave_worker
group_master_log_nameRelay_log_infoprotected
group_master_log_posRelay_log_infoprotected
group_relay_log_nameRelay_log_infoprotected
group_relay_log_posRelay_log_infoprotected
group_shiftedSlave_worker
group_source_log_end_posRelay_log_infoprivate
group_source_log_seen_start_posRelay_log_infoprivate
group_source_log_start_posRelay_log_infoprivate
gtid_monitoring_infoRelay_log_infoprivate
gtid_retrieved_initializedRelay_log_infoprivate
gtid_setRelay_log_infoprivate
handlerRpl_infoprotected
has_temporary_error(THD *thd, uint error_arg=0, bool *silent=nullptr) constSlave_reporting_capability
idSlave_worker
ign_master_log_name_endRelay_log_info
ign_master_log_pos_endRelay_log_info
IN_STMT enum valueRelay_log_info
inc_event_relay_log_pos()Relay_log_infoinline
inc_group_relay_log_pos(ulonglong log_pos, bool need_data_lock, bool force=false)Relay_log_info
increment_worker_metrics_for_event(const Log_event &event)Slave_workerinline
info_thdRpl_info
info_thd_lockRpl_info
init_until_option(THD *thd, const LEX_SOURCE_INFO *master_param)Relay_log_info
init_worker(Relay_log_info *, ulong)Slave_worker
init_workers(ulong)Relay_log_info
initedRpl_info
inited_hash_workersRelay_log_info
initialize_applier_security_context()Relay_log_info
initialize_security_context(THD *thd)Relay_log_info
internal_idRpl_infoprotected
is_applier_source_position_info_invalid() constRelay_log_info
is_engine_ha_data_detached()Relay_log_infoinline
is_error() constSlave_reporting_capabilityinline
is_group_master_log_pos_invalidRelay_log_info
is_group_relay_log_name_invalid(const char **errmsg)Relay_log_info
is_in_group() constRelay_log_infoinline
is_in_stmt() constRelay_log_infoinlineprivate
is_in_trx_or_stmt() constRelay_log_infoinlineprivate
is_long_find_row_note_printed()Relay_log_infoinline
is_mts_in_group()Relay_log_infoinline
is_mts_recovery() constRelay_log_infoinline
is_parallel_exec() constRelay_log_infoinline
is_privilege_checks_user_corrupted() constRelay_log_info
is_privilege_checks_user_null() constRelay_log_info
is_processing_trx()Relay_log_infoinline
is_receiver_waiting_for_rl_spaceRelay_log_info
is_relay_log_recoveryRelay_log_info
is_relay_log_truncated()Relay_log_infoinline
is_row_format_required() constRelay_log_info
is_time_for_mta_checkpoint()Relay_log_info
is_transactional() constRpl_infoinline
is_until_satisfied_after_dispatching_event()Relay_log_infoinline
is_until_satisfied_all_transactions_read_from_relay_log()Relay_log_infoinline
is_until_satisfied_at_start_slave()Relay_log_infoinline
is_until_satisfied_before_dispatching_event(const Log_event *ev)Relay_log_infoinline
jobsSlave_worker
jobs_condSlave_worker
jobs_lockSlave_worker
key_info_data_condRpl_info
key_info_data_lockRpl_info
key_info_run_lockRpl_info
key_info_sleep_condRpl_info
key_info_sleep_lockRpl_info
key_info_start_condRpl_info
key_info_stop_condRpl_info
key_info_thd_lockRpl_info
last_assigned_workerRelay_log_info
last_clockRelay_log_info
last_error() constSlave_reporting_capabilityinline
last_event_start_timeRelay_log_info
last_group_done_indexSlave_worker
last_groups_assigned_indexSlave_worker
last_master_timestampRelay_log_info
log_space_condRelay_log_info
log_space_limitRelay_log_info
log_space_lockRelay_log_info
log_space_totalRelay_log_info
logical_clock_condRelay_log_info
long_find_row_note_printedRelay_log_infoprivate
m_allow_drop_write_setRelay_log_infoprivate
m_assign_gtids_to_anonymous_transactions_infoRelay_log_info
m_commit_order_deadlockSlave_workerprivate
m_coordinator_metricsRelay_log_infoprivate
m_disabled_metric_aggregatorRelay_log_infoprivate
m_disabled_worker_metricsSlave_workerprivate
m_events_applied_in_transactionSlave_worker
m_flag_positions_committedSlave_workerprivate
m_flagsRelay_log_infoprivate
m_ignore_write_set_memory_limitRelay_log_infoprivate
m_is_after_metrics_breakpointSlave_worker
m_is_applier_source_position_info_invalidRelay_log_infoprivate
m_is_engine_ha_data_detachedRelay_log_info
m_is_worker_metric_collection_enabledSlave_workerprivate
m_key_mta_temp_table_LOCKRelay_log_info
m_last_errorSlave_reporting_capabilitymutableprotected
m_privilege_checks_hostnameRelay_log_infoprivate
m_privilege_checks_user_corruptedRelay_log_infoprivate
m_privilege_checks_usernameRelay_log_infoprivate
m_relay_log_truncatedRelay_log_infoprivate
m_require_row_formatRelay_log_infoprivate
m_require_table_primary_key_checkRelay_log_infoprivate
m_table_mapRelay_log_info
m_thread_nameSlave_reporting_capabilityprivate
m_worker_metricsSlave_workerprivate
mapping_db_to_workerRelay_log_info
master_log_change_notifiedSlave_worker
master_log_posSlave_workerprivate
max_updated_indexRelay_log_info
MAXIMUM_APPLIER_METADATA_LINESRelay_log_infoprivatestatic
miRelay_log_info
mta_coordinator_has_waited_statRelay_log_info
mts_coordinator_basic_napRelay_log_info
MTS_END_GROUP enum valueRelay_log_info
mts_end_group_sets_max_dbsRelay_log_info
mts_finalize_recovery()Relay_log_info
mts_gaq_LOCKRelay_log_info
mts_group_statusRelay_log_info
mts_groups_assignedRelay_log_info
MTS_IN_GROUP enum valueRelay_log_info
MTS_KILLED_GROUP enum valueRelay_log_info
MTS_NOT_IN_GROUP enum valueRelay_log_info
mts_pending_jobs_sizeRelay_log_info
mts_pending_jobs_size_maxRelay_log_info
mts_recovery_group_cntRelay_log_info
mts_recovery_group_seen_beginRelay_log_info
mts_recovery_indexRelay_log_info
mts_slave_worker_queue_len_maxRelay_log_info
mts_temp_table_LOCKRelay_log_info
mts_worker_underrun_levelRelay_log_info
mts_wq_excess_cntRelay_log_info
mts_wq_oversizeRelay_log_info
mts_wq_underrun_w_idRelay_log_info
new_group_master_log_nameRelay_log_info
new_group_master_log_posRelay_log_info
new_group_relay_log_nameRelay_log_info
new_group_relay_log_posRelay_log_info
NOT_RUNNING enum valueSlave_worker
notify_group_master_log_name_update()Relay_log_infoinline
notify_relay_log_change()Relay_log_infoinline
notify_relay_log_truncated()Relay_log_info
operator=(const Slave_worker &info)Slave_workerprivate
opt_replica_parallel_workersRelay_log_info
original_commit_timestampRelay_log_info
overrun_levelSlave_worker
pending_jobsRelay_log_info
pending_jobs_condRelay_log_info
pending_jobs_lockRelay_log_info
PK_CHECK_GENERATE enum valueRelay_log_info
PK_CHECK_NONE enum valueRelay_log_info
PK_CHECK_OFF enum valueRelay_log_info
PK_CHECK_ON enum valueRelay_log_info
PK_CHECK_STREAM enum valueRelay_log_info
post_commit(bool on_rollback) overrideSlave_workerinlinevirtual
post_rollback()Relay_log_infoinline
pre_commit()Relay_log_infoinline
prepare_for_retry(Log_event &event)Slave_worker
print_applier_security_context_user_host() constRelay_log_info
PRIV_CHECKS_HOSTNAME_LENGTHRelay_log_infoprivatestatic
PRIV_CHECKS_USERNAME_LENGTHRelay_log_infoprivatestatic
purge_relay_logs(THD *thd, const char **errmsg, bool delete_only=false)Relay_log_info
read_and_apply_events(my_off_t start_relay_pos, const char *start_event_relay_log_name, my_off_t end_relay_pos, const char *end_event_relay_log_name)Slave_workerprivate
read_info(Rpl_info_handler *from) overrideSlave_workerprivatevirtual
reattach_engine_ha_data(THD *thd)Relay_log_info
recovery_groupsRelay_log_info
recovery_groups_initedRelay_log_info
recovery_parallel_workersRelay_log_info
reinit_sql_thread_io_cache(const char *log, bool need_data_lock)Relay_log_info
relay_logRelay_log_info
relay_log_change_notifiedSlave_worker
Relay_log_info(bool is_slave_recovery, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel, bool is_rli_fake)Relay_log_info
Relay_log_info(const Relay_log_info &info)Relay_log_infoprivate
relay_log_sanitizedRelay_log_infoprivate
remove_info()Rpl_infoinline
replica_parallel_workersRelay_log_info
replicate_same_server_idRelay_log_info
report(loglevel level, int err_code, const char *msg,...) constSlave_reporting_capabilityvirtual
report(loglevel level, int err_code, const Gtid_specification *gtid_next, const char *msg,...) constSlave_reporting_capabilityvirtual
report_commit_order_deadlock()Slave_worker
report_privilege_check_error(enum loglevel level, enum_priv_checks_status status_code, bool to_client, char const *channel_name=nullptr, char const *user_name=nullptr, char const *host_name=nullptr) constRelay_log_info
reported_unsafe_warningRelay_log_info
reset_commit_order_deadlock()Slave_worker
reset_gaq_index()Slave_workerinline
reset_group_relay_log_pos(const char **errmsg)Relay_log_info
reset_notified_checkpoint(ulong count, time_t new_ts, bool update_timestamp=false)Relay_log_info
reset_notified_relay_log_change()Relay_log_info
reset_recovery_info()Slave_worker
reset_row_stmt_start_timestamp()Relay_log_infoinline
retried_processing(uint transient_errno_arg, const char *transient_err_message_arg, ulong trans_retries_arg)Relay_log_infoinline
retried_transRelay_log_info
retry_transaction(my_off_t start_relay_pos, const char *start_event_relay_log_name, my_off_t end_relay_pos, const char *end_event_relay_log_name)Slave_worker
rli_checkpoint_seqnoRelay_log_info
rli_description_eventRelay_log_infoprotected
rli_fakeRelay_log_infoprivate
RLI_FLUSH_IGNORE_GTID_ONLYRelay_log_infostatic
RLI_FLUSH_IGNORE_SYNC_OPTRelay_log_infostatic
RLI_FLUSH_NO_OPTIONRelay_log_infostatic
rli_init_info(bool)Slave_worker
rollback_positions(Slave_job_group *ptr_g)Slave_worker
row_stmt_start_timestampRelay_log_infoprivate
rows_query_evRelay_log_info
rpl_filterRelay_log_info
Rpl_info(const char *type, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel)Rpl_infoprotected
Rpl_info(const Rpl_info &info)Rpl_infoprivate
run_lockRpl_info
RUNNING enum valueSlave_worker
running_statusSlave_worker
save_temporary_tablesRelay_log_info
sequence_number()Slave_workerinline
server_versionSlave_worker
set_allow_drop_write_set(bool does_not_require_ws)Relay_log_infoinline
set_applier_source_position_info_invalid(bool invalid)Relay_log_info
set_commit_order_manager(Commit_order_manager *mngr)Relay_log_infoinline
set_event_relay_log_name(const char *log_file_name)Relay_log_infoinline
set_event_relay_log_pos(ulonglong log_pos)Relay_log_infoinline
set_event_start_pos(my_off_t pos)Relay_log_infoinline
set_filter(Rpl_filter *channel_filter)Relay_log_infoinline
set_flag(enum_state_flag flag)Relay_log_infoinline
set_future_event_relay_log_pos(ulonglong log_pos)Relay_log_infoinline
set_gaq_index(ulong val)Slave_workerinline
set_group_master_log_name(const char *log_file_name)Relay_log_infoinline
set_group_master_log_pos(ulonglong log_pos)Relay_log_infoinline
set_group_relay_log_name(const char *log_file_name)Relay_log_infoinline
set_group_relay_log_name(const char *log_file_name, size_t len)Relay_log_infoinline
set_group_relay_log_pos(ulonglong log_pos)Relay_log_infoinline
set_group_source_log_start_end_pos(const Log_event *ev)Relay_log_info
set_ignore_write_set_memory_limit(bool ignore_limit)Relay_log_infoinline
set_info_search_keys(Rpl_info_handler *to) overrideSlave_workervirtual
set_long_find_row_note_printed()Relay_log_infoinline
set_master_info(Master_info *info)Relay_log_info
set_master_log_pos(ulong val)Slave_workerinline
set_nullable_fields(MY_BITMAP *nullable_fields)Slave_workerstatic
set_privilege_checks_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname)Relay_log_info
set_privilege_checks_user_corrupted(bool is_corrupted)Relay_log_info
set_require_row_format(bool require_row)Relay_log_info
set_require_table_primary_key_check(enum_require_table_primary_key require_pk)Relay_log_info
set_rli_description_event(Format_description_log_event *fdle) overrideSlave_workerinlinevirtual
set_row_stmt_start_timestamp()Relay_log_infoinline
set_rpl_info_handler(Rpl_info_handler *param_handler)Rpl_infoinline
set_sql_delay(time_t _sql_delay)Relay_log_infoinline
set_thd_tx_priority(int priority)Relay_log_infoinline
set_until_option(Until_option *option)Relay_log_infoinline
set_worker_metric_collection_status(bool status)Slave_workerinline
slave_close_thread_tables(THD *)Relay_log_info
slave_patternload_fileRelay_log_info
slave_patternload_file_sizeRelay_log_info
Slave_reporting_capability(char const *thread_name)Slave_reporting_capability
Slave_reporting_capability(const Slave_reporting_capability &rhs)Slave_reporting_capabilityprivate
slave_run_idRpl_info
slave_runningRpl_info
slave_skip_counterRelay_log_info
slave_version_splitRelay_log_info
Slave_worker(Relay_log_info *rli, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel)Slave_worker
Slave_worker(const Slave_worker &info)Slave_workerprivate
slave_worker_ends_group(Log_event *, int)Slave_worker
slave_worker_exec_event(Log_event *ev)Slave_worker
slave_worker_hash_condRelay_log_info
slave_worker_hash_lockRelay_log_info
sleep_condRpl_info
sleep_lockRpl_info
sql_delayRelay_log_infoprivate
sql_delay_endRelay_log_infoprivate
sql_thread_kill_acceptedRelay_log_info
start_condRpl_info
start_sql_delay(time_t delay_end)Relay_log_info
started_processing(Gtid gtid_arg, ulonglong original_ts_arg, ulonglong immediate_ts_arg, bool skipped=false)Relay_log_infoinline
started_processing(Gtid_log_event *gtid_log_ev_arg)Relay_log_infoinline
STATE_FLAGS_COUNT enum valueRelay_log_info
stmt_done(my_off_t event_log_pos)Relay_log_info
STOP enum valueSlave_worker
STOP_ACCEPTED enum valueSlave_worker
stop_condRpl_info
tables_to_lockRelay_log_info
tables_to_lock_countRelay_log_info
thd_tx_priorityRelay_log_infoprivate
trans_retriesRelay_log_info
transaction_parserRelay_log_info
transactions_handledSlave_worker
underrun_levelSlave_worker
unset_long_find_row_note_printed()Relay_log_infoinline
until_conditionRelay_log_info
UNTIL_DONE enum valueRelay_log_info
UNTIL_MASTER_POS enum valueRelay_log_info
UNTIL_NONE enum valueRelay_log_info
until_optionRelay_log_infoprivate
UNTIL_RELAY_POS enum valueRelay_log_info
UNTIL_SQL_AFTER_GTIDS enum valueRelay_log_info
UNTIL_SQL_AFTER_MTS_GAPS enum valueRelay_log_info
UNTIL_SQL_BEFORE_GTIDS enum valueRelay_log_info
UNTIL_SQL_VIEW_ID enum valueRelay_log_info
update_is_transactional()Rpl_infoinline
usage_partitionSlave_worker
va_report(loglevel level, int err_code, const char *prefix_msg, const char *msg, va_list v_args) constSlave_reporting_capability
wait_for_gtid_set(THD *thd, const char *gtid, double timeout, bool update_THD_status=true)Relay_log_info
wait_for_gtid_set(THD *thd, String *gtid, double timeout, bool update_THD_status=true)Relay_log_info
wait_for_gtid_set(THD *thd, const Gtid_set *wait_gtid_set, double timeout, bool update_THD_status=true)Relay_log_info
wait_for_pos(THD *thd, String *log_name, longlong log_pos, double timeout)Relay_log_info
worker_checkpoint_seqnoSlave_worker
worker_queue_mem_exceeded_countRelay_log_info
worker_sleep(ulong seconds)Slave_workerprivate
workersRelay_log_info
workers_array_initializedRelay_log_info
workers_copy_pfsRelay_log_info
wq_overrun_cntSlave_worker
write_info(Rpl_info_handler *to) overrideSlave_workerprivatevirtual
~Relay_log_info() overrideRelay_log_info
~Rpl_info() overrideRpl_info
~Slave_reporting_capability()=0Slave_reporting_capabilitypure virtual
~Slave_worker() overrideSlave_worker