124 using mask = std::bitset<NUM_MODULES>;
204 char **error_message =
nullptr,
205 bool rejoin =
false);
static const sasl_callback_t callbacks[]
Definition: auth_ldap_sasl_client.h:44
Definition: applier.h:282
Definition: asynchronous_channels_state_observer.h:29
Represents and encapsulates the logic responsible for handling the auto-rejoin process within Group R...
Definition: autorejoin.h:48
Definition: plugin_utils.h:100
A class to hold different channel observation manager.
Definition: channel_observation_manager.h:64
This has the functionality of mysql_rwlock_t, with two differences:
Definition: rpl_gtid.h:309
Definition: compatibility_module.h:39
Deals with the orchestration necessary to set the appropriate "consensus leaders" on GCS.
Definition: consensus_leaders_handler.h:38
Definition: delayed_plugin_initialization.h:28
Coordinates all operations to GCS interface.
Definition: gcs_operations.h:48
The coordinator class where group actions are submitted.
Definition: group_action_coordinator.h:65
Class alerts listeners of group events like view changes and elections.
Definition: group_event_observer.h:86
Definition: member_info.h:741
Definition: member_info.h:79
Definition: group_partition_handling.h:29
Definition: group_transaction_observation_manager.h:88
Handles member actions configuration and trigger.
Definition: member_actions_handler.h:95
Handles the deliver of recv service messages to subscribed modules.
Definition: message_service.h:44
Definition: metrics_handler.h:39
A generic single thread executor.
Definition: mysql_thread.h:207
Definition: gcs_event_handlers.h:58
The base class to request and execute an election.
Definition: primary_election_invocation_handler.h:40
Definition: recovery.h:44
This is the interface for the registrty module.
Definition: registry.h:37
Class that hold the logic to decide if we should or not execute a clone operation and the logic to la...
Definition: remote_clone_handler.h:34
This class holds the references to server services that Group Replication acquires on plugin install.
Definition: server_services_references.h:40
Definition: plugin_utils.h:709
The consistency information of all ongoing transactions which have consistency GROUP_REPLICATION_CONS...
Definition: consistency_manager.h:280
Ticket register/wait auxiliary class.
Definition: plugin_utils.h:500
const char * p
Definition: ctype-mb.cc:1234
void * MYSQL_PLUGIN
Definition: plugin.h:81
unsigned long long int ulonglong
Definition: my_inttypes.h:55
bool is_running(const PluginFuncEnv *env) noexcept
Definition: loader.cc:201
ulong get_flow_control_mode_var()
Definition: plugin.cc:310
bool plugin_get_group_member_stats(uint index, const GROUP_REPLICATION_GROUP_MEMBER_STATS_CALLBACKS &callbacks)
Definition: plugin.cc:517
int get_flow_control_release_percent_var()
Definition: plugin.cc:338
Group_action_coordinator * group_action_coordinator
The coordinator for group actions.
Definition: plugin.cc:117
Blocked_transaction_handler * blocked_transaction_handler
The handler for transaction killing when an error or partition happens.
Definition: plugin.cc:115
ulong get_transaction_size_limit()
Definition: plugin.cc:2776
Metrics_handler * metrics_handler
Definition: plugin.cc:140
enum_channel_observation_manager_position
Position of channel observation manager's in channel_observation_manager_list.
Definition: plugin.h:74
@ ASYNC_CHANNEL_OBSERVATION_MANAGER_POS
Definition: plugin.h:76
@ END_CHANNEL_OBSERVATION_MANAGER_POS
Definition: plugin.h:77
@ GROUP_CHANNEL_OBSERVATION_MANAGER_POS
Definition: plugin.h:75
Applier_module * applier_module
The plugin applier.
Definition: plugin.cc:87
int initialize_plugin_and_join(enum_plugin_con_isolation sql_api_isolation, Delayed_initialization_thread *delayed_init_thd)
Definition: plugin.cc:697
Server_services_references * server_services_references_module
Module with the acquired server services on plugin install.
Definition: plugin.cc:139
rpl_sidno get_view_change_sidno()
Definition: plugin.cc:281
int plugin_group_replication_init(MYSQL_PLUGIN plugin_info)
Definition: plugin.cc:1948
bool plugin_is_group_replication_cloning()
Definition: plugin.cc:260
ulong get_exit_state_action_var()
Definition: plugin.cc:308
bool get_allow_single_leader()
Definition: plugin.cc:354
bool is_plugin_auto_starting_on_non_bootstrap_member()
Definition: plugin.cc:264
void reset_auto_increment_handler_values(bool force_reset=false)
Definition: plugin.cc:2420
void mysql_thread_handler_finalize()
Definition: plugin.cc:1888
ulong get_components_stop_timeout_var()
Definition: plugin.cc:342
void set_wait_on_start_process(bool cond)
Set condition to block or unblock the calling threads.
Definition: plugin.cc:395
Group_member_info * local_member_info
Definition: plugin.cc:147
long get_flow_control_min_quota_var()
Definition: plugin.cc:320
bool plugin_get_connection_status(const GROUP_REPLICATION_CONNECTION_STATUS_CALLBACKS &callbacks)
Definition: plugin.cc:486
void set_plugin_is_setting_read_mode(bool value)
Definition: plugin.cc:296
Transaction_consistency_manager * transaction_consistency_manager
The plugin transaction consistency manager.
Definition: plugin.cc:107
enum_wait_on_start_process_result
Reasons why asynchronous channels start wait for Group Replication status can be aborted.
Definition: plugin.h:143
@ WAIT_ON_START_PROCESS_ABORT_SECONDARY_MEMBER
Definition: plugin.h:146
@ WAIT_ON_START_PROCESS_ABORT_ON_CLONE
Definition: plugin.h:145
@ WAIT_ON_START_PROCESS_SUCCESS
Definition: plugin.h:144
Autorejoin_thread * autorejoin_module
The thread that handles the auto-rejoin process.
Definition: plugin.cc:121
Message_service_handler * message_service_handler
The thread that handles the message service process.
Definition: plugin.cc:125
bool is_autorejoin_enabled()
Definition: plugin.cc:348
const mysql_service_registry_t * get_plugin_registry()
Definition: plugin.cc:2794
bool get_server_shutdown_status()
Definition: plugin.cc:294
Checkable_rwlock * get_plugin_running_lock()
Definition: plugin.cc:250
bool plugin_is_group_replication_running()
Definition: plugin.cc:256
bool server_engine_initialized()
Definition: plugin.cc:2764
Mysql_thread * mysql_thread_handler
Handle tasks on mysql_thread.
Definition: plugin.cc:130
bool plugin_get_group_members(uint index, const GROUP_REPLICATION_GROUP_MEMBERS_CALLBACKS &callbacks)
Definition: plugin.cc:494
long get_flow_control_max_quota_var()
Definition: plugin.cc:326
void declare_plugin_cloning(bool is_running)
Definition: plugin.cc:2345
Group_partition_handling * group_partition_handler
The transaction handler for network partitions.
Definition: plugin.cc:113
Member_actions_handler * member_actions_handler
Definition: plugin.cc:128
bool check_async_channel_running_on_secondary()
Definition: plugin.cc:2683
mysql_mutex_t * get_plugin_applier_module_initialize_terminate_lock()
Definition: plugin.cc:252
Registry_module_interface * registry_module
The registry module.
Definition: plugin.cc:93
int initialize_plugin_modules(gr_modules::mask modules_to_init)
Definition: plugin.cc:1322
Group_transaction_observation_manager * group_transaction_observation_manager
The transaction observation module.
Definition: plugin.cc:102
mysql_service_mysql_runtime_error_t * mysql_runtime_error_service
Definition: plugin.cc:153
int plugin_group_replication_leave_group()
Definition: plugin.cc:1128
Channel_observation_manager_list * channel_observation_manager_list
The channel observation modules.
Definition: plugin.cc:97
Recovery_module * recovery_module
The plugin recovery module.
Definition: plugin.cc:89
Delayed_initialization_thread * delayed_initialization_thread
Initialization thread for server starts.
Definition: plugin.cc:111
Shared_writelock * shared_plugin_stop_lock
Class to coordinate access to the plugin stop lock.
Definition: plugin.cc:109
int get_flow_control_period_var()
Definition: plugin.cc:332
bool is_plugin_waiting_to_set_server_read_mode()
Definition: plugin.cc:2781
enum_tls_source_values
Source of TLS configuration for the connection between Group Replication members.
Definition: plugin.h:133
@ TLS_SOURCE_MYSQL_ADMIN
Definition: plugin.h:135
@ TLS_SOURCE_MYSQL_MAIN
Definition: plugin.h:134
const char * get_view_change_uuid_var()
Definition: plugin.cc:306
Asynchronous_channels_state_observer * asynchronous_channels_state_observer
The Single primary channel observation module.
Definition: plugin.cc:99
void * get_plugin_pointer()
Definition: plugin.cc:248
Remote_clone_handler * remote_clone_handler
The handler to invoke clone.
Definition: plugin.cc:123
uint plugin_get_group_members_number()
Definition: plugin.cc:506
int plugin_group_replication_stop(char **error_message=nullptr)
Definition: plugin.cc:1200
bool get_wait_on_engine_initialization()
Definition: plugin.cc:288
bool is_plugin_configured_and_starting()
Definition: plugin.cc:268
uint get_number_of_autorejoin_tries()
Definition: plugin.cc:350
long get_flow_control_applier_threshold_var()
Definition: plugin.cc:316
int plugin_group_replication_set_retrieved_certification_info(void *info)
Method to set retrieved certification info from a recovery channel extracted from a given View_change...
Definition: plugin.cc:272
Plugin_gcs_events_handler * events_handler
Definition: plugin.cc:142
Group_events_observation_manager * group_events_observation_manager
The observation module for group events.
Definition: plugin.cc:95
Gcs_operations * gcs_module
The plugin modules.
Definition: plugin.cc:91
ulonglong get_rejoin_timeout()
Definition: plugin.cc:352
void terminate_wait_on_start_process(enum_wait_on_start_process_result abort=WAIT_ON_START_PROCESS_SUCCESS)
Release all the blocked threads.
Definition: plugin.cc:419
bool get_plugin_is_stopping()
Definition: plugin.cc:286
void set_single_primary_mode_var(bool option)
Definition: plugin.cc:2790
int get_flow_control_hold_percent_var()
Definition: plugin.cc:334
enum_exit_state_action
Action performed when the member leaves the group unexpectedly.
Definition: plugin.h:85
@ EXIT_STATE_ACTION_ABORT_SERVER
Definition: plugin.h:87
@ EXIT_STATE_ACTION_OFFLINE_MODE
Definition: plugin.h:88
@ EXIT_STATE_ACTION_READ_ONLY
Definition: plugin.h:86
const char * get_group_name_var()
Definition: plugin.cc:304
bool get_plugin_is_setting_read_mode()
Definition: plugin.cc:300
void set_auto_increment_handler_values()
Definition: plugin.cc:2415
ulong get_communication_stack_var()
Definition: plugin.cc:346
Mysql_thread * mysql_thread_handler_read_only_mode
Dedicated mysql_thread to enable read_only and super_read_only since these are blocking operations.
Definition: plugin.cc:137
Consensus_leaders_handler * consensus_leaders_handler
Definition: plugin.cc:156
Primary_election_handler * primary_election_handler
The primary election handler.
Definition: plugin.cc:119
bool attempt_rejoin()
Encapsulates the logic necessary to attempt a rejoin, i.e.
Definition: plugin.cc:1696
long get_flow_control_certifier_threshold_var()
Definition: plugin.cc:312
int plugin_group_replication_deinit(void *p)
Definition: plugin.cc:2131
bool get_allow_local_lower_version_join()
Definition: plugin.cc:2771
void enable_server_shutdown_status()
Definition: plugin.cc:292
rpl_sidno get_group_sidno()
Definition: plugin.cc:276
Group_member_info_manager_interface * group_member_mgr
Definition: plugin.cc:146
Compatibility_module * compatibility_mgr
Definition: plugin.cc:150
enum_wait_on_start_process_result initiate_wait_on_start_process()
Blocks the calling thread.
Definition: plugin.cc:402
int get_flow_control_member_quota_percent_var()
Definition: plugin.cc:328
void set_enforce_update_everywhere_checks(bool option)
Definition: plugin.cc:2786
int terminate_plugin_modules(gr_modules::mask modules_to_terminate, char **error_message=nullptr, bool rejoin=false)
Definition: plugin.cc:1475
int plugin_group_replication_start(char **error_message=nullptr)
Definition: plugin.cc:525
long get_flow_control_min_recovery_quota_var()
Definition: plugin.cc:322
void register_server_reset_master()
Definition: plugin.cc:2769
Wait_ticket< my_thread_id > * transactions_latch
Transactions latch.
Definition: plugin.cc:105
API for Group Replication plugin.
static MYSQL_PLUGIN plugin_info
Definition: rewriter_plugin.cc:88
int rpl_sidno
Type of SIDNO (source ID number, first component of GTID)
Definition: rpl_gtid.h:96
#define SERVICE_TYPE(name)
Generates the standard Service type name.
Definition: service.h:75
#define SERVICE_TYPE_NO_CONST(name)
Generates the standard Service type name.
Definition: service.h:70
enum_plugin_con_isolation
What is the policy when creation a new server session for SQL execution.
Definition: sql_service_command.h:37
Definition: plugin_group_replication.h:53
Definition: plugin_group_replication.h:72
Definition: plugin_group_replication.h:100
MYSQL_PLUGIN_VAR_HEADER
Definition: plugin.h:68
This struct provides a namespace for the GR layer components.
Definition: plugin.h:94
static constexpr mask all_modules
Definition: plugin.h:125
std::bitset< NUM_MODULES > mask
Definition: plugin.h:124
gr_modules_enum
Represents the GR layer modules that can be initialized and/or terminated at will while the plugin is...
Definition: plugin.h:101
@ WAIT_ON_START
Definition: plugin.h:114
@ GROUP_ACTION_COORDINATOR
Definition: plugin.h:103
@ BLOCKED_TRANSACTION_HANDLER
Definition: plugin.h:110
@ AUTOREJOIN_THREAD
Definition: plugin.h:109
@ REMOTE_CLONE_HANDLER
Definition: plugin.h:117
@ MESSAGE_SERVICE_HANDLER
Definition: plugin.h:118
@ COMPATIBILITY_MANAGER
Definition: plugin.h:115
@ GROUP_PARTITION_HANDLER
Definition: plugin.h:108
@ NUM_MODULES
Definition: plugin.h:122
@ ASYNC_REPL_CHANNELS
Definition: plugin.h:107
@ METRICS_HANDLER
Definition: plugin.h:121
@ AUTO_INCREMENT_HANDLER
Definition: plugin.h:105
@ RECOVERY_MODULE
Definition: plugin.h:102
@ GROUP_MEMBER_MANAGER
Definition: plugin.h:112
@ MEMBER_ACTIONS_HANDLER
Definition: plugin.h:120
@ BINLOG_DUMP_THREAD_KILL
Definition: plugin.h:119
@ PRIMARY_ELECTION_HANDLER
Definition: plugin.h:104
@ CERTIFICATION_LATCH
Definition: plugin.h:111
@ GCS_EVENTS_HANDLER
Definition: plugin.h:116
@ APPLIER_MODULE
Definition: plugin.h:106
@ REGISTRY_MODULE
Definition: plugin.h:113
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:49