MySQL 9.1.0
Source Code Documentation
Gcs_xcom_control Member List

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

add_event_listener(const Gcs_control_event_listener &event_listener) overrideGcs_xcom_controlvirtual
belongs_to_group() overrideGcs_xcom_controlvirtual
build_joined_members(std::vector< Gcs_member_identifier * > &joined_members, std::vector< Gcs_member_identifier * > &alive_members, const std::vector< Gcs_member_identifier > *current_members)Gcs_xcom_controlprivate
build_left_members(std::vector< Gcs_member_identifier * > &left_members, std::vector< Gcs_member_identifier * > &alive_members, std::vector< Gcs_member_identifier * > &failed_members, const std::vector< Gcs_member_identifier > *current_members)Gcs_xcom_controlprivate
build_member_list(std::set< Gcs_member_identifier * > *origin, std::vector< Gcs_member_identifier > *to_fill)Gcs_xcom_controlprivate
build_member_suspect_nodes(std::vector< Gcs_member_identifier * > &member_suspect_nodes, std::vector< Gcs_member_identifier * > &failed_members, const std::vector< Gcs_member_identifier > *current_members)Gcs_xcom_controlprivate
build_non_member_suspect_nodes(std::vector< Gcs_member_identifier * > &non_member_suspect_nodes, std::vector< Gcs_member_identifier * > &failed_members, const std::vector< Gcs_member_identifier > *current_members)Gcs_xcom_controlprivate
build_total_members(Gcs_xcom_nodes *xcom_nodes, std::vector< Gcs_member_identifier * > &alive_members, std::vector< Gcs_member_identifier * > &failed_members)Gcs_xcom_controlprivate
clear_peer_nodes()Gcs_xcom_control
connect_to_peer(Gcs_xcom_node_address &peer, std::map< std::string, int > const &my_addresses)Gcs_xcom_controlprivate
CONNECTION_ATTEMPTSGcs_xcom_controlstatic
do_join(const bool retry=true)Gcs_xcom_control
do_leave()Gcs_xcom_control
do_leave_view()Gcs_xcom_control
do_remove_node_from_group()Gcs_xcom_control
event_listenersGcs_xcom_controlprivate
expel_incompatible_members(std::vector< Gcs_xcom_node_information > const &incompatible_members)Gcs_xcom_controlprivate
Gcs_xcom_control(Gcs_xcom_node_address *xcom_node_address, std::vector< Gcs_xcom_node_address * > &xcom_peers, Gcs_group_identifier group_identifier, Gcs_xcom_proxy *xcom_proxy, Gcs_xcom_group_management *xcom_group_management, Gcs_xcom_engine *gcs_engine, Gcs_xcom_state_exchange_interface *state_exchange, Gcs_xcom_view_change_control_interface *view_control, bool boot, My_xp_socket_util *socket_util, std::unique_ptr< Network_provider_operations_interface > comms_operation_interface, Gcs_xcom_statistics_manager_interface *stats_mgr)Gcs_xcom_controlexplicit
Gcs_xcom_control(const Gcs_xcom_control &)Gcs_xcom_controlprivate
get_connection_to_node(std::vector< Gcs_xcom_node_address * > *peers_list)Gcs_xcom_controlprivate
get_current_view() overrideGcs_xcom_controlvirtual
get_event_listeners()Gcs_xcom_control
get_local_member_identifier() const overrideGcs_xcom_controlvirtual
get_node_address()Gcs_xcom_control
get_node_information() constGcs_xcom_control
get_socket_util()Gcs_xcom_control
get_suspicions_manager()Gcs_xcom_control
get_xcom_proxy()Gcs_xcom_control
init_me()Gcs_xcom_controlprivate
install_leave_view(Gcs_view::Gcs_view_error_code error_code)Gcs_xcom_control
install_view(Gcs_xcom_view_identifier *new_view_id, const Gcs_group_identifier &group_id, std::map< Gcs_member_identifier, Xcom_member_state * > *states, std::set< Gcs_member_identifier * > *total, std::set< Gcs_member_identifier * > *left, std::set< Gcs_member_identifier * > *join, Gcs_view::Gcs_view_error_code error_code=Gcs_view::OK)Gcs_xcom_controlprivate
is_killer_node(const std::vector< Gcs_member_identifier * > &alive_members) constGcs_xcom_controlprivate
is_this_node_in(std::vector< Gcs_member_identifier * > *members)Gcs_xcom_controlprivate
is_xcom_running()Gcs_xcom_control
join() overrideGcs_xcom_controlvirtual
leave() overrideGcs_xcom_controlvirtual
m_bootGcs_xcom_controlprotected
m_comms_operation_interfaceGcs_xcom_controlprivate
m_gcs_engineGcs_xcom_controlprotected
m_gidGcs_xcom_controlprivate
m_gid_hashGcs_xcom_controlprivate
m_initial_peersGcs_xcom_controlprotected
m_join_attemptsGcs_xcom_controlprivate
m_join_sleep_timeGcs_xcom_controlprivate
m_leave_view_deliveredGcs_xcom_controlprotected
m_leave_view_requestedGcs_xcom_controlprotected
m_local_node_addressGcs_xcom_controlprivate
m_local_node_infoGcs_xcom_controlprivate
m_sock_probe_interfaceGcs_xcom_controlprivate
m_socket_utilGcs_xcom_controlprivate
m_state_exchangeGcs_xcom_controlprivate
m_stats_mgrGcs_xcom_controlprivate
m_suspicions_managerGcs_xcom_controlprivate
m_suspicions_processing_threadGcs_xcom_controlprivate
m_view_controlGcs_xcom_controlprotected
m_xcom_group_managementGcs_xcom_controlprivate
m_xcom_proxyGcs_xcom_controlprivate
m_xcom_runningGcs_xcom_controlprotected
m_xcom_threadGcs_xcom_controlprivate
operator=(const Gcs_xcom_control &)Gcs_xcom_controlprivate
process_control_message(Gcs_message *msg, Gcs_protocol_version maximum_supported_protocol_version, Gcs_protocol_version used_protocol_version)Gcs_xcom_control
remove_event_listener(int event_listener_handle) overrideGcs_xcom_controlvirtual
retry_do_join()Gcs_xcom_control
send_add_node_request(std::map< std::string, int > const &my_addresses)Gcs_xcom_controlprivate
set_boot_node(bool boot)Gcs_xcom_control
set_join_behavior(unsigned int join_attempts, unsigned int join_sleep_time)Gcs_xcom_control
set_node_address(Gcs_xcom_node_address *node_address)Gcs_xcom_control
set_peer_nodes(std::vector< Gcs_xcom_node_address * > &xcom_peers)Gcs_xcom_control
set_xcom_cache_size(uint64_t size) overrideGcs_xcom_controlvirtual
try_send_add_node_request_to_seeds(std::map< std::string, int > const &my_addresses)Gcs_xcom_controlprivate
wait_for_xcom_thread()Gcs_xcom_control
xcom_receive_global_view(synode_no const config_id, synode_no message_id, Gcs_xcom_nodes *xcom_nodes, bool do_not_deliver_to_client, synode_no max_synode)Gcs_xcom_control
xcom_receive_leave()Gcs_xcom_control
xcom_receive_local_view(synode_no const config_id, Gcs_xcom_nodes *xcom_nodes, synode_no max_synode)Gcs_xcom_control
~Gcs_control_interface()=defaultGcs_control_interfacevirtual
~Gcs_xcom_control() overrideGcs_xcom_control