Implementation of a. More...

#include <gcs_mysql_network_provider.h>

Inheritance diagram for Gcs_mysql_network_provider:

Public Member Functions
	Gcs_mysql_network_provider (Gcs_mysql_network_provider_auth_interface auth_provider, Gcs_mysql_network_provider_native_interface native_interface)
	Construct a new Gcs_mysql_network_provider. More...

virtual	~Gcs_mysql_network_provider () override

std::pair< bool, int >	start () override
	See. More...

std::pair< bool, int >	stop () override
	See. More...

enum_transport_protocol	get_communication_stack () const override
	Get the communication stack implemented by this class. More...

bool	configure (const Network_configuration_parameters &params) override
	See. More...

bool	configure_secure_connections (const Network_configuration_parameters &params) override
	See. More...

void	cleanup_secure_connections_context () override

bool	finalize_secure_connections_context () override

std::unique_ptr< Network_connection >	open_connection (const std::string &address, const unsigned short port, const Network_security_credentials &security_credentials, int connection_timeout=Network_provider::default_connection_timeout()) override
	See. More...

int	close_connection (const Network_connection &connection) override
	Closes an open connection to another XCom endpoint served by the same Network provider. More...

void	set_new_connection (THD thd, Network_connection connection)
	Set the new connection coming form MySQL server. More...

Public Member Functions inherited from Network_provider
	Network_provider ()

	Network_provider (Network_provider &&param)

Network_provider &	operator= (Network_provider &param)=delete

	Network_provider (Network_provider &param)=delete

virtual	~Network_provider ()

virtual std::function< void()>	get_secure_connections_context_cleaner ()

void	set_new_connection (Network_connection *connection)
	Lock-free Set connection. More...

Network_connection *	get_new_connection ()
	Get the new connection object. More...

void	reset_new_connection ()

Private Attributes
std::map< int, MYSQL * >	m_connection_map
	A map that holds all open MySQL client connections. More...

std::map< int, THD * >	m_incoming_connection_map
	A map that holds THD's for all open MySQL Server connections. More...

mysql_mutex_t	m_GR_LOCK_connection_map_mutex

Network_configuration_parameters	m_config_parameters

Gcs_mysql_network_provider_auth_interface *	m_auth_provider
	External IoC dependencies. More...

Gcs_mysql_network_provider_native_interface *	m_native_interface

Additional Inherited Members
Static Public Member Functions inherited from Network_provider
static constexpr int	default_connection_timeout ()

Detailed Description

Implementation of a.

See also: Network_provider that will manage MySQL protocol connection for GCS/XCOM.

Constructor & Destructor Documentation

◆ Gcs_mysql_network_provider()

Gcs_mysql_network_provider::Gcs_mysql_network_provider	(	Gcs_mysql_network_provider_auth_interface *	auth_provider,
		Gcs_mysql_network_provider_native_interface *	native_interface
	)

inline

Construct a new Gcs_mysql_network_provider.

Parameters

auth_provider	A provider interface implementation for authentication parameters.
native_interface	A provider interface for all mysql native methods.

◆ ~Gcs_mysql_network_provider()

virtual Gcs_mysql_network_provider::~Gcs_mysql_network_provider ( )

inlineoverridevirtual

Member Function Documentation

◆ cleanup_secure_connections_context()

void Gcs_mysql_network_provider::cleanup_secure_connections_context ( )

overridevirtual

Implements Network_provider.

◆ close_connection()

int Gcs_mysql_network_provider::close_connection ( const Network_connection & connection )

overridevirtual

Closes an open connection to another XCom endpoint served by the same Network provider.

Parameters

connection an open and valid connection

Returns: int an error code in case of error. 0, otherwise.

Implements Network_provider.

◆ configure()

bool Gcs_mysql_network_provider::configure ( const Network_configuration_parameters & params )

overridevirtual

See.

See also: Network_provider::configure

Implements Network_provider.

◆ configure_secure_connections()

bool Gcs_mysql_network_provider::configure_secure_connections ( const Network_configuration_parameters & params )

overridevirtual

See.

See also: Network_provider::configure_secure_connections

Implements Network_provider.

◆ finalize_secure_connections_context()

bool Gcs_mysql_network_provider::finalize_secure_connections_context ( )

overridevirtual

Implements Network_provider.

◆ get_communication_stack()

enum_transport_protocol Gcs_mysql_network_provider::get_communication_stack ( ) const

inlineoverridevirtual

Get the communication stack implemented by this class.

Returns: a CommunicationStack enum value. In this case -> MYSQL_PROTOCOL

Implements Network_provider.

◆ open_connection()

std::unique_ptr< Network_connection > Gcs_mysql_network_provider::open_connection	(	const std::string &	address,
		const unsigned short	port,
		const Network_security_credentials &	security_credentials,
		int	connection_timeout = `Network_provider::default_connection_timeout()`
	)

overridevirtual

See.

See also: Network_provider::open_connection

Implements Network_provider.

◆ set_new_connection()

void Gcs_mysql_network_provider::set_new_connection	(	THD *	thd,
		Network_connection *	connection
	)

Set the new connection coming form MySQL server.

Parameters

thd	the THD to which the connection belongs to.
connection	the connection data itself.

◆ start()

std::pair< bool, int > Gcs_mysql_network_provider::start ( )

overridevirtual

See.

See also: Network_provider::start

Implements Network_provider.

◆ stop()

std::pair< bool, int > Gcs_mysql_network_provider::stop ( )

overridevirtual

See.

See also: Network_provider::stop

Implements Network_provider.

Member Data Documentation

◆ m_auth_provider

Gcs_mysql_network_provider_auth_interface* Gcs_mysql_network_provider::m_auth_provider

private

External IoC dependencies.

A provider for authentication parameters
A provider for all mysql native methods

◆ m_config_parameters

Network_configuration_parameters Gcs_mysql_network_provider::m_config_parameters

private

◆ m_connection_map

std::map<int, MYSQL *> Gcs_mysql_network_provider::m_connection_map

private

A map that holds all open MySQL client connections.

Since the public interface of Network Managers only knows about File Descriptors, this is the repository for all MySQL client connections. This object is required when using mysql_close.

The map's index is the open connection's file descriptor.

◆ m_GR_LOCK_connection_map_mutex

mysql_mutex_t Gcs_mysql_network_provider::m_GR_LOCK_connection_map_mutex

private

◆ m_incoming_connection_map

std::map<int, THD *> Gcs_mysql_network_provider::m_incoming_connection_map

private

A map that holds THD's for all open MySQL Server connections.

We need to maintain this reference in order to call the appropriate closing mechanisms when destroying an incoming connection.

The map's index is the open connection's file descriptor.

◆ m_native_interface

Gcs_mysql_network_provider_native_interface* Gcs_mysql_network_provider::m_native_interface

private

The documentation for this class was generated from the following files:

plugin/group_replication/include/gcs_mysql_network_provider.h
plugin/group_replication/src/gcs_mysql_network_provider.cc

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ Gcs_mysql_network_provider()

◆ ~Gcs_mysql_network_provider()

Member Function Documentation

◆ cleanup_secure_connections_context()

◆ close_connection()

◆ configure()

◆ configure_secure_connections()

◆ finalize_secure_connections_context()

◆ get_communication_stack()

◆ open_connection()

◆ set_new_connection()

◆ start()

◆ stop()

Member Data Documentation

◆ m_auth_provider

◆ m_config_parameters

◆ m_connection_map

◆ m_GR_LOCK_connection_map_mutex

◆ m_incoming_connection_map

◆ m_native_interface