applier_module | Plugin_gcs_events_handler | private |
check_group_compatibility(size_t number_of_members) const | Plugin_gcs_events_handler | private |
check_version_compatibility_with_group() const | Plugin_gcs_events_handler | private |
collect_members_executed_sets(View_change_packet *view_packet) const | Plugin_gcs_events_handler | private |
compare_member_option_compatibility() const | Plugin_gcs_events_handler | private |
compare_member_transaction_sets() const | Plugin_gcs_events_handler | private |
compatibility_manager | Plugin_gcs_events_handler | private |
disable_read_mode_for_compatible_members(bool force_check=false) const | Plugin_gcs_events_handler | |
get_exchangeable_data() const override | Plugin_gcs_events_handler | virtual |
get_hosts_from_view(const std::vector< Gcs_member_identifier > &members, std::string &all_hosts, std::string &primary_host) const | Plugin_gcs_events_handler | private |
handle_certifier_message(const Gcs_message &message) const | Plugin_gcs_events_handler | private |
handle_group_action_message(const Gcs_message &message) const | Plugin_gcs_events_handler | private |
handle_joining_members(const Gcs_view &new_view, bool is_joining, bool is_leaving) const | Plugin_gcs_events_handler | private |
handle_leader_election_if_needed(enum_primary_election_mode election_mode, std::string &suggested_primary) const | Plugin_gcs_events_handler | private |
handle_leaving_members(const Gcs_view &new_view, bool is_joining, bool is_leaving) const | Plugin_gcs_events_handler | private |
handle_recovery_message(Plugin_gcs_message *message) const | Plugin_gcs_events_handler | private |
handle_single_primary_message(Plugin_gcs_message *processed_message) const | Plugin_gcs_events_handler | private |
handle_stats_message(const Gcs_message &message) const | Plugin_gcs_events_handler | private |
handle_sync_before_execution_message(const Gcs_message &message) const | Plugin_gcs_events_handler | private |
handle_transaction_prepared_message(const Gcs_message &message) const | Plugin_gcs_events_handler | private |
handle_transactional_message(const Gcs_message &message) const | Plugin_gcs_events_handler | private |
handle_transactional_with_guarantee_message(const Gcs_message &message) const | Plugin_gcs_events_handler | private |
is_group_running_a_configuration_change(std::string &group_action_running_initiator, std::string &group_action_running_description) const | Plugin_gcs_events_handler | private |
is_group_running_a_primary_election() const | Plugin_gcs_events_handler | private |
is_member_on_vector(const std::vector< Gcs_member_identifier > &members, const Gcs_member_identifier &member_id) const | Plugin_gcs_events_handler | private |
joiner_compatibility_status | Plugin_gcs_events_handler | private |
log_members_joining_message(const Gcs_view &new_view) const | Plugin_gcs_events_handler | private |
log_members_leaving_message(const Gcs_view &new_view) const | Plugin_gcs_events_handler | private |
m_notification_ctx | Plugin_gcs_events_handler | mutableprivate |
on_message_received(const Gcs_message &message) const override | Plugin_gcs_events_handler | virtual |
on_suspicions(const std::vector< Gcs_member_identifier > &members, const std::vector< Gcs_member_identifier > &unreachable) const override | Plugin_gcs_events_handler | virtual |
on_view_changed(const Gcs_view &new_view, const Exchanged_data &exchanged_data) const override | Plugin_gcs_events_handler | virtual |
Plugin_gcs_events_handler(Applier_module_interface *applier_module, Recovery_module *recovery_module, Compatibility_module *compatibility_manager, ulong components_stop_timeout) | Plugin_gcs_events_handler | |
pre_process_message(Plugin_gcs_message *plugin_message, const std::string &message_origin) const | Plugin_gcs_events_handler | private |
process_local_exchanged_data(const Exchanged_data &exchanged_data, bool is_joining) const | Plugin_gcs_events_handler | private |
recovery_module | Plugin_gcs_events_handler | private |
set_number_of_members_on_view_changed_to_10 | Plugin_gcs_events_handler | private |
set_stop_wait_timeout(ulong timeout) | Plugin_gcs_events_handler | inline |
stop_wait_timeout | Plugin_gcs_events_handler | private |
temporary_states | Plugin_gcs_events_handler | private |
update_group_info_manager(const Gcs_view &new_view, const Exchanged_data &exchanged_data, bool is_joining, bool is_leaving) const | Plugin_gcs_events_handler | private |
update_member_status(const std::vector< Gcs_member_identifier > &members, Group_member_info::Group_member_status status, Group_member_info::Group_member_status old_equal_to, Group_member_info::Group_member_status old_different_from) const | Plugin_gcs_events_handler | private |
was_member_expelled_from_group(const Gcs_view &view) const | Plugin_gcs_events_handler | private |
~Gcs_communication_event_listener()=default | Gcs_communication_event_listener | virtual |
~Gcs_control_event_listener()=default | Gcs_control_event_listener | virtual |
~Plugin_gcs_events_handler() override | Plugin_gcs_events_handler | |