check_connection_and_run_query(THD *thd, Master_info *mi, RPL_FAILOVER_SOURCE_TUPLE &conn_detail) | Source_IO_monitor | private |
COL_GROUP_NAME enum value | Source_IO_monitor | private |
COL_HOST enum value | Source_IO_monitor | private |
COL_PORT enum value | Source_IO_monitor | private |
COL_ROLE enum value | Source_IO_monitor | private |
COL_STATE enum value | Source_IO_monitor | private |
connect_senders(THD *thd, const std::string &channel_name) | Source_IO_monitor | private |
delete_rows(Rpl_sys_table_access &table_op, TABLE *table, std::vector< std::string > field_name, std::tuple< std::string, std::string, uint > conn_detail) | Source_IO_monitor | private |
enum_res_col enum name | Source_IO_monitor | private |
get_instance() | Source_IO_monitor | static |
get_monitoring_wait() | Source_IO_monitor | |
get_online_members(THD *thd, Master_info *mi, const Mysql_connection *conn, SENDER_CONN_MERGE_TUPLE source_conn_detail, std::vector< RPL_FAILOVER_SOURCE_TUPLE > &group_membership_detail, uint &curr_highest_group_weight, uint &curr_conn_weight) | Source_IO_monitor | private |
get_query(enum_sql_query_tag qtag) | Source_IO_monitor | |
get_senders_details(const std::string &channel_name) | Source_IO_monitor | |
has_primary_lost_contact_with_majority() | Source_IO_monitor | private |
is_monitor_killed(THD *thd, Master_info *mi) | Source_IO_monitor | |
is_monitoring_process_running() | Source_IO_monitor | |
launch_monitoring_process(PSI_thread_key thread_key) | Source_IO_monitor | |
m_abort_monitor | Source_IO_monitor | private |
m_monitor_thd | Source_IO_monitor | private |
m_monitor_thd_state | Source_IO_monitor | private |
m_primary_lost_contact_with_majority_warning_logged | Source_IO_monitor | private |
m_retry_monitor_wait | Source_IO_monitor | private |
m_run_cond | Source_IO_monitor | private |
m_run_lock | Source_IO_monitor | private |
m_th | Source_IO_monitor | private |
operator=(const Source_IO_monitor &)=delete | Source_IO_monitor | |
primary_weight_str() | Source_IO_monitor | inlineprivate |
save_group_members(std::string channel_name, std::string managed_name, std::vector< RPL_FAILOVER_SOURCE_TUPLE > &source_conn_list) | Source_IO_monitor | private |
secondary_weight_str() | Source_IO_monitor | inlineprivate |
set_monitoring_wait(uint wait_time) | Source_IO_monitor | |
Source_IO_monitor() | Source_IO_monitor | |
Source_IO_monitor(const Source_IO_monitor &)=delete | Source_IO_monitor | |
source_monitor_handler() | Source_IO_monitor | |
sync_senders_details(THD *thd) | Source_IO_monitor | private |
terminate_monitoring_process() | Source_IO_monitor | |
write_rows(Rpl_sys_table_access &table_op, TABLE *table, std::vector< std::string > field_name, RPL_FAILOVER_SOURCE_TUPLE conn_detail) | Source_IO_monitor | private |
~Source_IO_monitor() | Source_IO_monitor | virtual |