MySQL 8.4.3
Source Code Documentation
|
#include "sql/rpl_channel_service_interface.h"
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <atomic>
#include <map>
#include <sstream>
#include <utility>
#include "mutex_lock.h"
#include "my_compiler.h"
#include "my_dbug.h"
#include "my_inttypes.h"
#include "my_sys.h"
#include "my_thread.h"
#include "mysql/components/services/bits/psi_bits.h"
#include "mysql/components/services/bits/psi_stage_bits.h"
#include "mysql/components/services/log_builtins.h"
#include "mysql/my_loglevel.h"
#include "mysql/psi/mysql_cond.h"
#include "mysql/psi/mysql_mutex.h"
#include "mysql/service_mysql_alloc.h"
#include "mysql_com.h"
#include "mysqld_error.h"
#include "sql/auth/sql_security_ctx.h"
#include "sql/binlog.h"
#include "sql/changestreams/apply/replication_thread_status.h"
#include "sql/current_thd.h"
#include "sql/log.h"
#include "sql/log_event.h"
#include "sql/mysqld.h"
#include "sql/mysqld_thd_manager.h"
#include "sql/protocol_classic.h"
#include "sql/raii/sentry.h"
#include "sql/rpl_async_conn_failover_configuration_propagation.h"
#include "sql/rpl_channel_credentials.h"
#include "sql/rpl_gtid.h"
#include "sql/rpl_info_factory.h"
#include "sql/rpl_info_handler.h"
#include "sql/rpl_mi.h"
#include "sql/rpl_msr.h"
#include "sql/rpl_mta_submode.h"
#include "sql/rpl_replica.h"
#include "sql/rpl_rli.h"
#include "sql/rpl_rli_pdb.h"
#include "sql/rpl_trx_boundary_parser.h"
#include "sql/sql_class.h"
#include "sql/sql_lex.h"
Classes | |
class | Kill_binlog_dump |
Functions | |
int | channel_stop (Master_info *mi, int threads_to_stop, long timeout) |
Auxiliary function to stop all the running channel threads according to the given mask. More... | |
int | initialize_channel_service_interface () |
Initializes channel structures if needed. More... | |
static void | set_mi_settings (Master_info *mi, Channel_creation_info *channel_info) |
static bool | init_thread_context () |
static void | clean_thread_context () |
static THD * | create_surrogate_thread () |
static void | delete_surrogate_thread (THD *thd) |
void | initialize_channel_creation_info (Channel_creation_info *channel_info) |
void | initialize_channel_ssl_info (Channel_ssl_info *channel_ssl_info) |
void | initialize_channel_connection_info (Channel_connection_info *channel_info) |
static void | set_mi_ssl_options (LEX_SOURCE_INFO *lex_mi, Channel_ssl_info *channel_ssl_info) |
int | channel_create (const char *channel, Channel_creation_info *channel_info) |
Initializes a channel connection in a similar way to a change replication source command. More... | |
int | channel_start (const char *channel, Channel_connection_info *connection_info, int threads_to_start, int wait_for_connection, bool use_server_mta_configuration, bool channel_map_already_locked) |
Start the Applier/Receiver threads according to the given options. More... | |
int | channel_stop (const char *channel, int threads_to_stop, long timeout) |
Stops the channel threads according to the given options. More... | |
int | channel_stop_all (int threads_to_stop, long timeout, std::string *error_message) |
Stops all the running channel threads according to the given options. More... | |
int | binlog_dump_thread_kill () |
Kills the Binlog Dump threads. More... | |
int | channel_purge_queue (const char *channel, bool reset_all) |
Purges the channel logs. More... | |
bool | channel_is_active (const char *channel, enum_channel_thread_types thd_type) |
Tells if the selected component of the channel is active or not. More... | |
int | channel_get_thread_id (const char *channel, enum_channel_thread_types thd_type, unsigned long **thread_id, bool need_lock) |
Returns the id(s) of the channel threads: receiver or applier. More... | |
long long | channel_get_last_delivered_gno (const char *channel, int sidno) |
Returns last GNO from applier from a given UUID. More... | |
int | channel_add_executed_gtids_to_received_gtids (const char *channel) |
Adds server executed GTID set to channel received GTID set. More... | |
int | channel_queue_packet (const char *channel, const char *buf, unsigned long event_len) |
Queues a event packet into the current active channel. More... | |
int | channel_wait_until_apply_queue_applied (const char *channel, double timeout) |
Checks if all the queued transactions were executed. More... | |
int | channel_wait_until_transactions_applied (const char *channel, const char *gtid_set, double timeout, bool update_THD_status) |
Checks if all the transactions in the given set were executed. More... | |
int | channel_is_applier_waiting (const char *channel) |
Checks if the applier, and its workers when parallel applier is enabled, has already consumed all relay log, that is, applier is waiting for transactions to be queued. More... | |
int | channel_is_applier_thread_waiting (unsigned long thread_id, bool worker) |
Checks if the applier thread, and its workers when parallel applier is enabled, has already consumed all relay log, that is, applier thread is waiting for transactions to be queued. More... | |
int | channel_flush (const char *channel) |
Flush the channel. More... | |
int | channel_get_retrieved_gtid_set (const char *channel, char **retrieved_set) |
Returns the receiver thread retrieved GTID set in string format. More... | |
int | channel_get_credentials (const char *channel, std::string &username, std::string &password) |
Method to get the credentials configured for a channel. More... | |
int | channel_get_network_namespace (const char *channel, std::string &net_ns) |
Method to get the network namespace configured for a channel. More... | |
int | channel_get_gtid_set_to_apply (const char *channel, std::string >id_set_to_apply) |
Calculate transactions that are waiting to be applied on channel. More... | |
bool | channel_is_stopping (const char *channel, enum_channel_thread_types thd_type) |
Tells if the selected component of the channel is stopping or not. More... | |
bool | is_partial_transaction_on_channel_relay_log (const char *channel) |
Checks if the given channel's relaylog contains a partial transaction. More... | |
bool | channel_has_same_uuid_as_group_name (const char *group_name) |
Checks if any running channel uses the same UUID for assign_gtids_to_anonymous_transactions as the group_name. More... | |
bool | is_any_slave_channel_running (int thread_mask) |
Checks if any slave threads of any channel is running. More... | |
bool | is_any_slave_channel_running_with_failover_enabled (int thread_mask) |
Checks if any slave threads of any channel configured with SOURCE_CONNECTION_AUTO_FAILOVER is running. More... | |
enum_slave_channel_status | has_any_slave_channel_open_temp_table_or_is_its_applier_running () |
Checks if any slave channel applier is running or any slave channel has open temporary table(s). More... | |
int | channel_delete_credentials (const char *channel_name) |
Delete stored credentials from Slave_credentials. More... | |
bool | start_failover_channels () |
Start channels which have SOURCE_CONNECTION_AUTO_FAILOVER=1. More... | |
bool | channel_change_source_connection_auto_failover (const char *channel, bool status) |
Set SOURCE_CONNECTION_AUTO_FAILOVER on the given channel to the given status value. More... | |
bool | unset_source_connection_auto_failover_on_all_channels () |
Unset SOURCE_CONNECTION_AUTO_FAILOVER=0 on all channels. More... | |
void | reload_failover_channels_status () |
Reload the status values on Rpl_acf_status_configuration singleton. More... | |
bool | get_replication_failover_channels_configuration (std::string &serialized_configuration) |
Get replication failover channels configuration in a serialized protobuf_replication_asynchronous_connection_failover::SourceAndManagedAndStatusList message. More... | |
bool | set_replication_failover_channels_configuration (const std::vector< std::string > &exchanged_replication_failover_channels_serialized_configuration) |
Set replication failover channels configuration that was received from the group. More... | |
bool | force_my_replication_failover_channels_configuration_on_all_members () |
Collect and broadcast the replication failover channels configuration in a serialized protobuf_replication_asynchronous_connection_failover::SourceAndManagedAndStatusList message, that will override the configuration on all group members. More... | |
int binlog_dump_thread_kill | ( | ) |
Kills the Binlog Dump threads.
0 | OK |
int channel_add_executed_gtids_to_received_gtids | ( | const char * | channel | ) |
Adds server executed GTID set to channel received GTID set.
channel | the channel name |
0 | OK |
!= | 0 Error |
bool channel_change_source_connection_auto_failover | ( | const char * | channel, |
bool | status | ||
) |
Set SOURCE_CONNECTION_AUTO_FAILOVER on the given channel to the given status value.
[in] | channel | The channel name |
[in] | status | true, enables SOURCE_CONNECTION_AUTO_FAILOVER false, disables SOURCE_CONNECTION_AUTO_FAILOVER |
false | OK |
true | Error |
int channel_create | ( | const char * | channel, |
Channel_creation_info * | channel_information | ||
) |
Initializes a channel connection in a similar way to a change replication source command.
channel | The channel name |
channel_information | Channel creation information. |
0 | OK |
!=0 | Error on channel creation |
int channel_delete_credentials | ( | const char * | channel_name | ) |
Delete stored credentials from Slave_credentials.
[in] | channel_name | The channel name |
0 | OK |
1 | Error, channel not found |
int channel_flush | ( | const char * | channel | ) |
Flush the channel.
0 | OK |
!= | 0 Error on flush |
int channel_get_credentials | ( | const char * | channel, |
std::string & | user, | ||
std::string & | password | ||
) |
Method to get the credentials configured for a channel.
[in] | channel | The channel name |
[out] | user | The user to extract |
[out] | password | The password to extract |
false | OK |
true | Error, channel not found |
int channel_get_gtid_set_to_apply | ( | const char * | channel, |
std::string & | gtid_set_to_apply | ||
) |
Calculate transactions that are waiting to be applied on channel.
gtid_set_to_apply will contain a list of UUIDs with intervals that represent transactions that will be applied.
[in] | channel | name of the channel |
[out] | gtid_set_to_apply | transactions on backlog to be applied. |
0 | OK |
!=0 | Error |
long long channel_get_last_delivered_gno | ( | const char * | channel, |
int | sidno | ||
) |
Returns last GNO from applier from a given UUID.
channel | the channel name |
sidno | the uuid associated to the desired gno |
<0 | the channel does no exists, or the applier is not present |
>0 | the gno |
int channel_get_network_namespace | ( | const char * | channel, |
std::string & | net_ns | ||
) |
Method to get the network namespace configured for a channel.
[in] | channel | The channel name |
[out] | net_ns | The network namespace to extract |
false | OK |
true | Error, channel not found |
int channel_get_retrieved_gtid_set | ( | const char * | channel, |
char ** | retrieved_set | ||
) |
Returns the receiver thread retrieved GTID set in string format.
channel | The channel name. | |
[out] | retrieved_set | Pointer to pointer to string. The function will set it to point to a newly allocated buffer, or NULL on out of memory. |
0 | OK |
!=0 | Error on retrieval |
int channel_get_thread_id | ( | const char * | channel, |
enum_channel_thread_types | thread_type, | ||
unsigned long ** | thread_id, | ||
bool | need_lock = true |
||
) |
Returns the id(s) of the channel threads: receiver or applier.
If more than one applier exists, an array is returned, on which first index is coordinator thread id.
[in] | channel | The channel name |
[in] | thread_type | The thread type (receiver or applier) |
[out] | thread_id | The array of id(s) |
[in] | need_lock | Is channel_map read lock needed? |
-1 | the channel does no exists, or the thread is not present |
>0 | the number of thread ids returned. |
bool channel_has_same_uuid_as_group_name | ( | const char * | group_name | ) |
Checks if any running channel uses the same UUID for assign_gtids_to_anonymous_transactions as the group_name.
[in] | group_name | the group name |
true | at least one channel has the same uuid |
false | none of the the channels have the same uuid |
bool channel_is_active | ( | const char * | channel, |
enum_channel_thread_types | type | ||
) |
Tells if the selected component of the channel is active or not.
If no component is passed, this method returns if the channel exists or not
channel | The channel name |
type | The thread that should be checked. If 0, this method applies to the channel existence. |
true | Yes |
false | No |
int channel_is_applier_thread_waiting | ( | unsigned long | thread_id, |
bool | worker = false |
||
) |
Checks if the applier thread, and its workers when parallel applier is enabled, has already consumed all relay log, that is, applier thread is waiting for transactions to be queued.
thread_id | the applier thread id to check |
worker | flag to indicate if thread is a parallel worker |
-1 | Unable to find applier thread |
0 | Applier thread is not waiting |
1 | Applier thread is waiting |
int channel_is_applier_waiting | ( | const char * | channel | ) |
Checks if the applier, and its workers when parallel applier is enabled, has already consumed all relay log, that is, applier is waiting for transactions to be queued.
channel | The channel name |
<0 | Error |
0 | Applier is not waiting |
1 | Applier is waiting |
bool channel_is_stopping | ( | const char * | channel, |
enum_channel_thread_types | type | ||
) |
Tells if the selected component of the channel is stopping or not.
channel | The channel name |
type | The thread that should be checked. |
true | Yes |
false | No, no type was specified or the channel does not exist. |
int channel_purge_queue | ( | const char * | channel, |
bool | reset_all | ||
) |
Purges the channel logs.
channel | The channel name |
reset_all | If true, the method will purge logs and remove the channel If false, only the channel information will be reset. |
0 | OK |
!=0 | Error |
int channel_queue_packet | ( | const char * | channel, |
const char * | buf, | ||
unsigned long | len | ||
) |
Queues a event packet into the current active channel.
channel | the channel name |
buf | the event buffer |
len | the event buffer length |
0 | OK |
!= | 0 Error on queue |
int channel_start | ( | const char * | channel, |
Channel_connection_info * | connection_info, | ||
int | threads_to_start, | ||
int | wait_for_connection, | ||
bool | use_server_mta_configuration = false , |
||
bool | channel_map_already_locked = false |
||
) |
Start the Applier/Receiver threads according to the given options.
If the receiver thread is to be started, connection credential must be supported.
channel | The channel name |
connection_info | Channel connection information |
threads_to_start | The types of threads to be started |
wait_for_connection | If when starting the receiver, the method should wait for the connection to succeed |
use_server_mta_configuration | If true, the channel uses the server parallel applier configuration when starting the applier thread, instead of the configuration given on channel_create() |
channel_map_already_locked | If set to true, will not acquire a write lock of channel_map |
0 | OK |
!=0 | Error |
int channel_stop | ( | const char * | channel, |
int | threads_to_stop, | ||
long | timeout | ||
) |
Stops the channel threads according to the given options.
channel | The channel name |
threads_to_stop | The types of threads to be stopped |
timeout | The expected time in which the thread should stop |
0 | OK |
!=0 | Error |
int channel_stop | ( | Master_info * | mi, |
int | threads_to_stop, | ||
long | timeout | ||
) |
Auxiliary function to stop all the running channel threads according to the given mask.
mi | The pointer to Master_info instance |
threads_to_stop | The types of threads to be stopped |
timeout | The expected time in which the thread should stop |
0 | OK |
!=0 | Error |
int channel_stop_all | ( | int | threads_to_stop, |
long | timeout, | ||
std::string * | error_message | ||
) |
Stops all the running channel threads according to the given options.
threads_to_stop | The types of threads to be stopped |
timeout | The expected time in which the thread should stop |
error_message | The returned error_message |
0 | OK |
!=0 | Error |
int channel_wait_until_apply_queue_applied | ( | const char * | channel, |
double | timeout | ||
) |
Checks if all the queued transactions were executed.
channel | the channel name |
timeout | the time (seconds) after which the method returns if the above condition was not satisfied |
0 | All transactions were executed |
REPLICATION_THREAD_WAIT_TIMEOUT_ERROR | A timeout occurred |
REPLICATION_THREAD_WAIT_NO_INFO_ERROR | An error occurred |
int channel_wait_until_transactions_applied | ( | const char * | channel, |
const char * | gtid_set, | ||
double | timeout, | ||
bool | update_THD_status = true |
||
) |
Checks if all the transactions in the given set were executed.
channel | the channel name |
gtid_set | the set in string format of transaction to wait for |
timeout | the time (seconds) after which the method returns if the above condition was not satisfied |
update_THD_status | Shall the method update the THD stage |
0 | All transactions were executed |
REPLICATION_THREAD_WAIT_TIMEOUT_ERROR | A timeout occurred |
REPLICATION_THREAD_WAIT_NO_INFO_ERROR | An error occurred |
|
static |
|
static |
|
static |
bool force_my_replication_failover_channels_configuration_on_all_members | ( | ) |
Collect and broadcast the replication failover channels configuration in a serialized protobuf_replication_asynchronous_connection_failover::SourceAndManagedAndStatusList message, that will override the configuration on all group members.
false | OK |
true | Error |
bool get_replication_failover_channels_configuration | ( | std::string & | serialized_configuration | ) |
Get replication failover channels configuration in a serialized protobuf_replication_asynchronous_connection_failover::SourceAndManagedAndStatusList message.
[out] | serialized_configuration | the serialized configuration |
false | OK |
true | Error |
enum_slave_channel_status has_any_slave_channel_open_temp_table_or_is_its_applier_running | ( | ) |
Checks if any slave channel applier is running or any slave channel has open temporary table(s).
This holds handled appliers' run_locks until finding a running slave channel applier or a slave channel which has open temporary table(s), or handling all slave channels.
|
static |
void initialize_channel_connection_info | ( | Channel_connection_info * | channel_info | ) |
void initialize_channel_creation_info | ( | Channel_creation_info * | channel_info | ) |
int initialize_channel_service_interface | ( | ) |
Initializes channel structures if needed.
0 | OK |
!= | 0 Error on queue |
void initialize_channel_ssl_info | ( | Channel_ssl_info * | channel_ssl_info | ) |
bool is_any_slave_channel_running | ( | int | thread_mask | ) |
Checks if any slave threads of any channel is running.
[in] | thread_mask | type of slave thread- IO/SQL or any |
true | at least one channel thread is running. |
false | none of the the channels are running. |
bool is_any_slave_channel_running_with_failover_enabled | ( | int | thread_mask | ) |
Checks if any slave threads of any channel configured with SOURCE_CONNECTION_AUTO_FAILOVER is running.
[in] | thread_mask | type of slave thread- IO/SQL or any |
true | at least one channel threads are running. |
false | none of the the channels are running. |
bool is_partial_transaction_on_channel_relay_log | ( | const char * | channel | ) |
Checks if the given channel's relaylog contains a partial transaction.
channel | The channel name |
true | If relaylog contains partial transcation. |
false | If relaylog does not contain partial transaction. |
void reload_failover_channels_status | ( | ) |
Reload the status values on Rpl_acf_status_configuration
singleton.
|
static |
|
static |
bool set_replication_failover_channels_configuration | ( | const std::vector< std::string > & | exchanged_replication_failover_channels_serialized_configuration | ) |
Set replication failover channels configuration that was received from the group.
Each member of the group will send its own configuration in a serialized protobuf_replication_asynchronous_connection_failover::SourceAndManagedAndStatusList message.
[in] | exchanged_replication_failover_channels_serialized_configuration | vector with the serialized configuration from each member |
false | OK |
true | Error |
bool start_failover_channels | ( | ) |
Start channels which have SOURCE_CONNECTION_AUTO_FAILOVER=1.
false | OK |
true | Error |
bool unset_source_connection_auto_failover_on_all_channels | ( | ) |
Unset SOURCE_CONNECTION_AUTO_FAILOVER=0 on all channels.
false | OK |
true | Error |