gcs_xcom_utils.cc File Reference

#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_utils.h"
#include <algorithm>
#include <cerrno>
#include <cinttypes>
#include <cstdlib>
#include <sstream>
#include <netdb.h>
#include <sys/socket.h>
#include "plugin/group_replication/libmysqlgcs/include/mysql/gcs/gcs_logging_system.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_message_stage_lz4.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_message_stage_split.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/gcs_xcom_networking.h"
#include "plugin/group_replication/libmysqlgcs/src/bindings/xcom/xcom/xcom_transport.h"

Functions
bool	is_valid_hostname (const std::string &server_and_port)
	Parses the string "host:port" and checks if it is correct. More...
void	fix_parameters_syntax (Gcs_interface_parameters &interface_params)
	Does some transformations on the parameters. More...
static enum_gcs_error	is_valid_flag (const std::string &param, std::string &flag)
bool	is_valid_protocol (std::string const &protocol_string)
	Checks whether the given string is a valid GCS protocol known by this node. More...
bool	is_parameters_syntax_correct (const Gcs_interface_parameters &interface_params, Network_namespace_manager *netns_manager)
	Checks that parameters are syntactically valid. More...
std::string	gcs_protocol_to_mysql_version (Gcs_protocol_version protocol)
	Converts the given GCS protocol version into the MySQL version that introduced it. More...

Variables
static const unsigned int	WAITING_TIME = 30
static const unsigned int	JOIN_ATTEMPTS = 0
static const uint64_t	JOIN_SLEEP_TIME = 5
static const uint64_t	DEFAULT_XCOM_MAX_CACHE_SIZE = 1073741824
static const uint64_t	MIN_XCOM_MAX_CACHE_SIZE = 134217728

Function Documentation

fix_parameters_syntax()

void fix_parameters_syntax

(

Gcs_interface_parameters &

params

)

Does some transformations on the parameters.

For instance, replaces aliases with the correct ones

gcs_protocol_to_mysql_version()

std::string gcs_protocol_to_mysql_version

(

Gcs_protocol_version

protocol

)

Converts the given GCS protocol version into the MySQL version that introduced it.

Parameters

protocol

the GCS protocol

Returns

the MySQL version that introduced it, in format major.minor.patch

is_parameters_syntax_correct()

bool is_parameters_syntax_correct	(	const Gcs_interface_parameters &	params,
		Network_namespace_manager *	netns_manager
	)

Checks that parameters are syntactically valid.

Parameters

params	The parameters to validate syntactically.
netns_manager	A reference to a Network Namespace Manager. This is needed because of the allowlist configuration and local address validation.

Returns

false if there is a syntax error, true otherwise.

is_valid_flag()

static enum_gcs_error is_valid_flag ( const std::string &  param, std::string &  flag  )

static

is_valid_hostname()

bool is_valid_hostname

(

const std::string &

server_and_port

)

Parses the string "host:port" and checks if it is correct.

Parameters

server_and_port

the server hostname and port in the form hostname:port.

Returns

true if it is a valid URL, false otherwise.

is_valid_protocol()

bool is_valid_protocol

(

std::string const &

protocol

)

Checks whether the given string is a valid GCS protocol known by this node.

Returns

true If it is, false otherwise.

Variable Documentation

DEFAULT_XCOM_MAX_CACHE_SIZE

const uint64_t DEFAULT_XCOM_MAX_CACHE_SIZE = 1073741824

static

JOIN_ATTEMPTS

const unsigned int JOIN_ATTEMPTS = 0

static

JOIN_SLEEP_TIME

const uint64_t JOIN_SLEEP_TIME = 5

static

MIN_XCOM_MAX_CACHE_SIZE

const uint64_t MIN_XCOM_MAX_CACHE_SIZE = 134217728

static

WAITING_TIME

const unsigned int WAITING_TIME = 30

static