#include "my_sys.h"
#include "my_thread.h"
#include "sql/binlog/group_commit/bgc_ticket_manager.h"
#include "sql/binlog_ostream.h"
#include "sql/binlog_reader.h"
#include "sql/debug_sync.h"
#include "sql/log_event.h"
#include "sql/replication.h"
#include "sql/rpl_channel_service_interface.h"
#include "sql/rpl_commit_stage_manager.h"
#include "sql/rpl_gtid.h"
#include "sql/rpl_write_set_handler.h"

Namespaces
namespace	gr

Typedefs
using	gr::Gtid_tsid = mysql::gtid::Tsid

using	gr::Gtid_tag = mysql::gtid::Tag

using	gr::Gtid_format = mysql::gtid::Gtid_format

Functions
int	group_replication_init ()
	Server side initializations. More...

my_thread_attr_t *	get_connection_attrib ()
	Returns the server connection attribute. More...

void	get_server_parameters (char *hostname, uint port, char *uuid, unsigned int server_version, uint *admin_port)
	Returns the server hostname, port and uuid. More...

void	get_server_main_ssl_parameters (st_server_ssl_variables *server_ssl_variables)
	Returns the server's client-server interface's ssl configuration values. More...

void	get_server_admin_ssl_parameters (st_server_ssl_variables *server_ssl_variables)
	Returns the server's admin interface's ssl configuration values. More...

ulong	get_server_id ()
	Returns the server_id. More...

ulong	get_auto_increment_increment ()
	Returns the server auto_increment_increment. More...

ulong	get_auto_increment_offset ()
	Returns the server auto_increment_offset. More...

void	set_auto_increment_increment (ulong auto_increment_increment)
	Set server auto_increment_increment. More...

void	set_auto_increment_offset (ulong auto_increment_offset)
	Set server auto_increment_offset. More...

void	get_server_startup_prerequirements (Trans_context_info &requirements)
	Returns a struct containing all server startup information needed to evaluate if one has conditions to proceed executing master-master replication. More...

bool	get_server_encoded_gtid_executed (uchar *encoded_gtid_executed, size_t length)
	Returns the server GTID_EXECUTED encoded as a binary string. More...

char *	encoded_gtid_set_to_string (uchar *encoded_gtid_set, size_t length)
	Returns a text representation of a encoded GTID set. More...

rpl_gno	get_last_executed_gno (rpl_sidno sidno)
	Return last gno for a given sidno, see Gtid_state::get_last_executed_gno() for details. More...

rpl_sidno	get_sidno_from_global_tsid_map (const mysql::gtid::Tsid &tsid)
	Return sidno for a given tsid, see Tsid_map::add_tsid() for details. More...

const mysql::gtid::Tsid &	get_tsid_from_global_tsid_map (rpl_sidno sidno)
	Return Tsid for a given sidno on the global_tsid_map. More...

void	set_slave_thread_options (THD *thd)
	Set slave thread default options. More...

void	global_thd_manager_add_thd (THD *thd)
	Add thread to Global_THD_manager singleton. More...

void	global_thd_manager_remove_thd (THD *thd)
	Remove thread from Global_THD_manager singleton. More...

const char *	get_write_set_algorithm_string (unsigned int algorithm)
	Function that returns the write set extraction algorithm name. More...

bool	is_gtid_committed (const Gtid &gtid)
	Returns true if the given transaction is committed. More...

unsigned long	get_replica_max_allowed_packet ()
	Returns the value of replica_max_allowed_packet. More...

bool	wait_for_gtid_set_committed (const char *gtid_set_text, double timeout, bool update_thd_status)
	Wait until the given Gtid_set is included in @GLOBAL.GTID_EXECUTED. More...

unsigned long	get_max_replica_max_allowed_packet ()

bool	is_server_restarting_after_clone ()

bool	is_server_data_dropped ()

void	microseconds_to_datetime_str (uint64_t microseconds_since_epoch, char *datetime_str, uint decimal_precision)
	Copy to datetime_str parameter the date in the format 'YYYY-MM-DD hh:mm:ss.ffffff' of the moment in time represented by micro-seconds elapsed since the Epoch, 1970-01-01 00:00:00 +0000 (UTC). More...

Function Documentation

◆ encoded_gtid_set_to_string()

char * encoded_gtid_set_to_string	(	uchar *	encoded_gtid_set,
		size_t	length
	)

Returns a text representation of a encoded GTID set.

Note: Memory allocated to returned pointer must be release by caller.

Parameters

[in]	encoded_gtid_set	binary string
[in]	length	binary string length

Returns: a pointer to text representation of the encoded set

◆ get_auto_increment_increment()

ulong get_auto_increment_increment ( )

Returns the server auto_increment_increment.

Returns: auto_increment_increment

◆ get_auto_increment_offset()

ulong get_auto_increment_offset ( )

Returns the server auto_increment_offset.

Returns: auto_increment_offset

◆ get_connection_attrib()

my_thread_attr_t * get_connection_attrib ( )

Returns the server connection attribute.

Note: This method implementation is on sql_class.cc

Returns: the pthread for the connection attribute.

Returns the server connection attribute.

Return values

Reference to thread attribute for connection threads

◆ get_last_executed_gno()

rpl_gno get_last_executed_gno ( rpl_sidno sidno )

Return last gno for a given sidno, see Gtid_state::get_last_executed_gno() for details.

◆ get_max_replica_max_allowed_packet()

unsigned long get_max_replica_max_allowed_packet ( )

Returns: the maximum value of replica_max_allowed_packet.

◆ get_replica_max_allowed_packet()

unsigned long get_replica_max_allowed_packet ( )

Returns the value of replica_max_allowed_packet.

Returns: replica_max_allowed_packet

◆ get_server_admin_ssl_parameters()

void get_server_admin_ssl_parameters ( st_server_ssl_variables * server_ssl_variables )

Returns the server's admin interface's ssl configuration values.

Parameters

[out] server_ssl_variables server's ssl_variables

◆ get_server_encoded_gtid_executed()

bool get_server_encoded_gtid_executed	(	uchar **	encoded_gtid_executed,
		size_t *	length
	)

Returns the server GTID_EXECUTED encoded as a binary string.

Note: Memory allocated to encoded_gtid_executed must be release by caller.

Parameters

[out]	encoded_gtid_executed	binary string
[out]	length	binary string length

◆ get_server_id()

ulong get_server_id ( )

Returns the server_id.

Returns: server_id

◆ get_server_main_ssl_parameters()

void get_server_main_ssl_parameters ( st_server_ssl_variables * server_ssl_variables )

Returns the server's client-server interface's ssl configuration values.

Parameters

[out] server_ssl_variables server's ssl_variables

◆ get_server_parameters()

void get_server_parameters	(	char **	hostname,
		uint *	port,
		char **	uuid,
		unsigned int *	server_version,
		uint *	admin_port
	)

Returns the server hostname, port and uuid.

Parameters

[out]	hostname	hostname
[out]	port	port
[out]	uuid	uuid
[out]	server_version	server version
[out]	admin_port	mysqld admin port

◆ get_server_startup_prerequirements()

void get_server_startup_prerequirements ( Trans_context_info & requirements )

Returns a struct containing all server startup information needed to evaluate if one has conditions to proceed executing master-master replication.

Parameters

[out] requirements requirements

◆ get_sidno_from_global_tsid_map()

rpl_sidno get_sidno_from_global_tsid_map ( const mysql::gtid::Tsid & tsid )

Return sidno for a given tsid, see Tsid_map::add_tsid() for details.

◆ get_tsid_from_global_tsid_map()

const mysql::gtid::Tsid & get_tsid_from_global_tsid_map ( rpl_sidno sidno )

Return Tsid for a given sidno on the global_tsid_map.

See Tsid_map::sidno_to_tsid() for details.

◆ get_write_set_algorithm_string()

const char * get_write_set_algorithm_string ( unsigned int algorithm )

Function that returns the write set extraction algorithm name.

Parameters

[in] algorithm The algorithm value

Returns: the algorithm name

◆ global_thd_manager_add_thd()

void global_thd_manager_add_thd ( THD * thd )

Add thread to Global_THD_manager singleton.

Parameters

[in] thd The thread

◆ global_thd_manager_remove_thd()

void global_thd_manager_remove_thd ( THD * thd )

Remove thread from Global_THD_manager singleton.

Parameters

[in] thd The thread

◆ group_replication_init()

int group_replication_init ( )

Server side initializations.

◆ is_gtid_committed()

bool is_gtid_committed ( const Gtid & gtid )

Returns true if the given transaction is committed.

Parameters

[in] gtid The transaction identifier

Returns: true the transaction is committed false otherwise

◆ is_server_data_dropped()

bool is_server_data_dropped ( )

Returns: if the server already dropped its data when cloning

◆ is_server_restarting_after_clone()

bool is_server_restarting_after_clone ( )

Returns: if the server is restarting after a clone

◆ microseconds_to_datetime_str()

void microseconds_to_datetime_str	(	uint64_t	microseconds_since_epoch,
		char *	datetime_str,
		uint	decimal_precision
	)

Copy to datetime_str parameter the date in the format 'YYYY-MM-DD hh:mm:ss.ffffff' of the moment in time represented by micro-seconds elapsed since the Epoch, 1970-01-01 00:00:00 +0000 (UTC).

Parameters

[in]	microseconds_since_epoch	micro-seconds since Epoch.
[out]	datetime_str	The string pointer to print at. This function is guaranteed not to write more than MAX_DATE_STRING_REP_LENGTH characters.
[in]	decimal_precision	decimal precision, in the range 0..6

◆ set_auto_increment_increment()

void set_auto_increment_increment ( ulong auto_increment_increment )

Set server auto_increment_increment.

Parameters

[in] auto_increment_increment auto-increment increment

◆ set_auto_increment_offset()

void set_auto_increment_offset ( ulong auto_increment_offset )

Set server auto_increment_offset.

Parameters

[in] auto_increment_offset auto-increment offset

◆ wait_for_gtid_set_committed()

bool wait_for_gtid_set_committed	(	const char *	gtid_set_text,
		double	timeout,
		bool	update_thd_status
	)

Wait until the given Gtid_set is included in @GLOBAL.GTID_EXECUTED.

Parameters

[in]	gtid_set_text	Gtid_set to wait for.
[in]	timeout	The maximum number of seconds that the function should wait, or 0 to wait indefinitely.
[in]	update_thd_status	when true updates the stage info with the new wait condition, when false keeps the current stage info.

Return values

false	the Gtid_set is included in @GLOBAL.GTID_EXECUTED
true	otherwise

Namespaces

Typedefs

Functions

Function Documentation

◆ encoded_gtid_set_to_string()

◆ get_auto_increment_increment()

◆ get_auto_increment_offset()

◆ get_connection_attrib()

◆ get_last_executed_gno()

◆ get_max_replica_max_allowed_packet()

◆ get_replica_max_allowed_packet()

◆ get_server_admin_ssl_parameters()

◆ get_server_encoded_gtid_executed()

◆ get_server_id()

◆ get_server_main_ssl_parameters()

◆ get_server_parameters()

◆ get_server_startup_prerequirements()

◆ get_sidno_from_global_tsid_map()

◆ get_tsid_from_global_tsid_map()

◆ get_write_set_algorithm_string()

◆ global_thd_manager_add_thd()

◆ global_thd_manager_remove_thd()

◆ group_replication_init()

◆ is_gtid_committed()

◆ is_server_data_dropped()

◆ is_server_restarting_after_clone()

◆ microseconds_to_datetime_str()

◆ set_auto_increment_increment()

◆ set_auto_increment_offset()

◆ wait_for_gtid_set_committed()