MySQL 8.0.39
Source Code Documentation
|
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) override | Gcs_xcom_control | virtual |
belongs_to_group() override | Gcs_xcom_control | virtual |
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_control | private |
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_control | private |
build_member_list(std::set< Gcs_member_identifier * > *origin, std::vector< Gcs_member_identifier > *to_fill) | Gcs_xcom_control | private |
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_control | private |
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_control | private |
build_total_members(Gcs_xcom_nodes *xcom_nodes, std::vector< Gcs_member_identifier * > &alive_members, std::vector< Gcs_member_identifier * > &failed_members) | Gcs_xcom_control | private |
clear_peer_nodes() | Gcs_xcom_control | |
connect_to_peer(Gcs_xcom_node_address &peer, std::map< std::string, int > const &my_addresses) | Gcs_xcom_control | private |
CONNECTION_ATTEMPTS | Gcs_xcom_control | static |
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_listeners | Gcs_xcom_control | private |
expel_incompatible_members(std::vector< Gcs_xcom_node_information > const &incompatible_members) | Gcs_xcom_control | private |
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_control | explicit |
Gcs_xcom_control(const Gcs_xcom_control &) | Gcs_xcom_control | private |
get_connection_to_node(std::vector< Gcs_xcom_node_address * > *peers_list) | Gcs_xcom_control | private |
get_current_view() override | Gcs_xcom_control | virtual |
get_event_listeners() | Gcs_xcom_control | |
get_local_member_identifier() const override | Gcs_xcom_control | virtual |
get_node_address() | Gcs_xcom_control | |
get_node_information() const | Gcs_xcom_control | |
get_socket_util() | Gcs_xcom_control | |
get_suspicions_manager() | Gcs_xcom_control | |
get_xcom_proxy() | Gcs_xcom_control | |
init_me() | Gcs_xcom_control | private |
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_control | private |
is_killer_node(const std::vector< Gcs_member_identifier * > &alive_members) const | Gcs_xcom_control | private |
is_this_node_in(std::vector< Gcs_member_identifier * > *members) | Gcs_xcom_control | private |
is_xcom_running() | Gcs_xcom_control | |
join() override | Gcs_xcom_control | virtual |
leave() override | Gcs_xcom_control | virtual |
m_boot | Gcs_xcom_control | protected |
m_comms_operation_interface | Gcs_xcom_control | private |
m_gcs_engine | Gcs_xcom_control | protected |
m_gid | Gcs_xcom_control | private |
m_gid_hash | Gcs_xcom_control | private |
m_initial_peers | Gcs_xcom_control | protected |
m_join_attempts | Gcs_xcom_control | private |
m_join_sleep_time | Gcs_xcom_control | private |
m_leave_view_delivered | Gcs_xcom_control | protected |
m_leave_view_requested | Gcs_xcom_control | protected |
m_local_node_address | Gcs_xcom_control | private |
m_local_node_info | Gcs_xcom_control | private |
m_sock_probe_interface | Gcs_xcom_control | private |
m_socket_util | Gcs_xcom_control | private |
m_state_exchange | Gcs_xcom_control | private |
m_suspicions_manager | Gcs_xcom_control | private |
m_suspicions_processing_thread | Gcs_xcom_control | private |
m_view_control | Gcs_xcom_control | protected |
m_xcom_group_management | Gcs_xcom_control | private |
m_xcom_proxy | Gcs_xcom_control | private |
m_xcom_running | Gcs_xcom_control | protected |
m_xcom_thread | Gcs_xcom_control | private |
operator=(const Gcs_xcom_control &) | Gcs_xcom_control | private |
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) override | Gcs_xcom_control | virtual |
retry_do_join() | Gcs_xcom_control | |
send_add_node_request(std::map< std::string, int > const &my_addresses) | Gcs_xcom_control | private |
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) override | Gcs_xcom_control | virtual |
try_send_add_node_request_to_seeds(std::map< std::string, int > const &my_addresses) | Gcs_xcom_control | private |
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()=default | Gcs_control_interface | virtual |
~Gcs_xcom_control() override | Gcs_xcom_control |