#include <classic_connection.h>

Inheritance diagram for MysqlRoutingClassicConnection:

Public Member Functions
void	async_run () override

void	stash_server_conn () override

Public Member Functions inherited from MysqlRoutingClassicConnectionBase
std::shared_ptr< MysqlRoutingClassicConnectionBase >	getptr ()

void	on_handshake_received ()

void	on_handshake_aborted ()

SslMode	source_ssl_mode () const

SslMode	dest_ssl_mode () const

net::impl::socket::native_handle_type	get_client_fd () const override

DestinationManager *	destination_manager () const

routing_guidelines::Session_info	get_session_info ()

void	disconnect () override

void	send_server_failed (std::error_code ec, bool call_finish=true)

void	recv_server_failed (std::error_code ec, bool call_finish=true)

void	send_client_failed (std::error_code ec, bool call_finish=true)

void	recv_client_failed (std::error_code ec, bool call_finish=true)

void	server_socket_failed (std::error_code ec, bool call_finish=true)

virtual void	client_socket_failed (std::error_code ec, bool call_finish=true)

void	resume ()

void	push_processor (std::unique_ptr< BasicProcessor > processor)

void	pop_processor ()

stdx::expected< void, std::error_code >	track_session_changes (net::const_buffer session_trackers, classic_protocol::capabilities::value_type caps, bool ignore_some_state_changed=false)

void	reset_to_initial ()
	reset the connection's settings to the initial-values. More...

ClientSideConnection::protocol_state_type &	client_protocol ()

const ClientSideConnection::protocol_state_type &	client_protocol () const

ServerSideConnection::protocol_state_type &	server_protocol ()

const ServerSideConnection::protocol_state_type &	server_protocol () const

ClientSideConnection &	client_conn ()

const ClientSideConnection &	client_conn () const

ServerSideConnection &	server_conn ()

const ServerSideConnection &	server_conn () const

std::optional< mysql_harness::Destination >	get_destination_id () const override

void	destination_id (const std::optional< mysql_harness::Destination > &id)

std::optional< mysql_harness::Destination >	read_only_destination_id () const override

void	read_only_destination_id (const std::optional< mysql_harness::Destination > &destination_id)

std::optional< mysql_harness::Destination >	read_write_destination_id () const override

void	read_write_destination_id (const std::optional< mysql_harness::Destination > &destination_id)

std::optional< mysql_harness::DestinationEndpoint >	destination_endpoint () const override

void	destination_endpoint (const std::optional< mysql_harness::DestinationEndpoint > &ep)

std::optional< mysql_harness::DestinationEndpoint >	read_only_destination_endpoint () const override

void	read_only_destination_endpoint (const std::optional< mysql_harness::DestinationEndpoint > &ep)

std::optional< mysql_harness::DestinationEndpoint >	read_write_destination_endpoint () const override

void	read_write_destination_endpoint (const std::optional< mysql_harness::DestinationEndpoint > &ep)

void	set_destination (std::unique_ptr< Destination > destination)

bool	authenticated () const
	check if the connection is authenticated. More...

void	authenticated (bool v)

bool	connection_sharing_possible () const
	check if connection sharing is possible. More...

bool	connection_sharing_allowed () const
	check if connection sharing is allowed. More...

void	connection_sharing_allowed_reset ()
	reset the connection-sharing state. More...

std::string	connection_sharing_blocked_by () const

bool	greeting_from_router () const
	if the router is sending the initial server-greeting. More...

void	expected_server_transport_constraints (TransportConstraints val)

TransportConstraints	expected_server_transport_constraints () const

void	some_state_changed (bool v)

void	expected_server_mode (mysqlrouter::ServerMode v)

mysqlrouter::ServerMode	expected_server_mode () const

void	current_server_mode (mysqlrouter::ServerMode v)

mysqlrouter::ServerMode	current_server_mode () const

void	wait_for_my_writes (bool v)

bool	wait_for_my_writes () const

void	gtid_at_least_executed (const std::string &gtid)

std::string	gtid_at_least_executed () const

std::chrono::seconds	wait_for_my_writes_timeout () const

void	wait_for_my_writes_timeout (std::chrono::seconds timeout)

void	collation_connection_maybe_dirty (bool val)

bool	collation_connection_maybe_dirty () const

std::optional< classic_protocol::session_track::TransactionCharacteristics >	trx_characteristics () const

void	trx_characteristics (std::optional< classic_protocol::session_track::TransactionCharacteristics > trx_chars)

std::optional< classic_protocol::session_track::TransactionState >	trx_state () const

void	wait_until_completed () override

void	completed () override

ExecutionContext &	execution_context ()

const ExecutionContext &	execution_context () const

void	trace (Tracer::Event e)

Tracer &	tracer ()

net::steady_timer &	read_timer ()

net::steady_timer &	connect_timer ()

void	connect_error_code (const std::error_code &ec)

std::error_code	connect_error_code () const

void	diagnostic_area_changed (bool diagnostic_area_changed)

bool	diagnostic_area_changed () const

const TraceSpan &	events () const

TraceSpan &	events ()

void	recv_from_either (FromEither v)

FromEither	recv_from_either () const

void	has_transient_error_at_connect (bool val)

bool	has_transient_error_at_connect () const

Public Member Functions inherited from MySQLRoutingConnectionBase
	MySQLRoutingConnectionBase (MySQLRoutingContext &context, std::function< void(MySQLRoutingConnectionBase *)> remove_callback)

virtual	~MySQLRoutingConnectionBase ()=default

MySQLRoutingContext &	context ()

const MySQLRoutingContext &	context () const

std::string	get_server_address () const
	Returns address of server to which connection is established. More...

void	server_address (const std::string &dest)

std::string	get_client_address () const
	Returns address of client which connected to router. More...

void	client_address (const std::string &dest)

std::size_t	get_bytes_up () const

std::size_t	get_bytes_down () const

time_point_type	get_started () const

time_point_type	get_connected_to_server () const

time_point_type	get_last_sent_to_server () const

time_point_type	get_last_received_from_server () const

Stats	get_stats () const

void	transfered_to_server (size_t bytes)

void	transfered_to_client (size_t bytes)

void	disassociate ()

void	accepted ()

virtual void	connected ()

template<class F >
auto	disconnect_request (F &&f)

bool	disconnect_requested () const

routing_guidelines::Session_info	get_session_info () const

void	set_routing_guidelines_session_rand ()

Static Public Member Functions
template<typename... Args>
static std::shared_ptr< MysqlRoutingClassicConnectionBase >	create (Args &&...args)

Static Public Member Functions inherited from MysqlRoutingClassicConnectionBase
template<typename... Args>
static std::shared_ptr< MysqlRoutingClassicConnectionBase >	create (Args &&...args)

static stdx::expected< size_t, std::error_code >	encode_error_packet (std::vector< uint8_t > &error_frame, const uint8_t seq_id, const classic_protocol::capabilities::value_type caps, const uint16_t error_code, const std::string &msg, const std::string &sql_state)

Private Member Functions
	MysqlRoutingClassicConnection (MySQLRoutingContext &context, DestinationManager destination_manager, std::unique_ptr< ConnectionBase > client_connection, std::unique_ptr< RoutingConnectionBase > client_routing_connection, std::function< void(MySQLRoutingConnectionBase )> remove_callback)

Additional Inherited Members
Public Types inherited from MysqlRoutingClassicConnectionBase
enum class	FromEither { None , Started , RecvedFromClient , RecvedFromServer }

using	ClientSideConnection = TlsSwitchableClientConnection< ClientSideClassicProtocolState >

using	ServerSideConnection = TlsSwitchableConnection< ServerSideClassicProtocolState >

Public Types inherited from MySQLRoutingConnectionBase
using	clock_type = std::chrono::system_clock

using	time_point_type = clock_type::time_point

Protected Types inherited from MysqlRoutingClassicConnectionBase
enum class	Function { kLoop , kFinish }

Protected Member Functions inherited from MysqlRoutingClassicConnectionBase
	MysqlRoutingClassicConnectionBase (MySQLRoutingContext &context, DestinationManager destination_manager, std::unique_ptr< ConnectionBase > client_connection, std::unique_ptr< RoutingConnectionBase > client_routing_connection, std::function< void(MySQLRoutingConnectionBase )> remove_callback)

void	call_next_function (Function next)

Protected Member Functions inherited from MySQLRoutingConnectionBase
void	log_connection_summary ()

Protected Attributes inherited from MySQLRoutingConnectionBase
MySQLRoutingContext &	context_
	wrapper for common data used by all routing threads More...

std::function< void(MySQLRoutingConnectionBase *)>	remove_callback_
	callback that is called when thread of execution completes More...

Monitor< Stats >	stats_ {{}}

Monitor< bool >	disconnect_ {{}}

Constructor & Destructor Documentation

◆ MysqlRoutingClassicConnection()

MysqlRoutingClassicConnection::MysqlRoutingClassicConnection	(	MySQLRoutingContext &	context,
		DestinationManager *	destination_manager,
		std::unique_ptr< ConnectionBase >	client_connection,
		std::unique_ptr< RoutingConnectionBase >	client_routing_connection,
		std::function< void(MySQLRoutingConnectionBase *)>	remove_callback
	)

inlineprivate

Member Function Documentation

◆ async_run()

void MysqlRoutingClassicConnection::async_run ( )

overridevirtual

Reimplemented from MysqlRoutingClassicConnectionBase.

◆ create()

template<typename... Args>

static std::shared_ptr< MysqlRoutingClassicConnectionBase > MysqlRoutingClassicConnection::create ( Args &&... args )

inlinestatic

◆ stash_server_conn()

void MysqlRoutingClassicConnection::stash_server_conn ( )

overridevirtual

Reimplemented from MysqlRoutingClassicConnectionBase.

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

router/src/routing/src/classic_connection.h
router/src/routing/src/classic_connection.cc

Public Member Functions

Static Public Member Functions