MysqlRoutingClassicConnectionBase Class Reference

#include <classic_connection_base.h>

Inheritance diagram for MysqlRoutingClassicConnectionBase:

Public Types
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

Public Member Functions
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
std::string	get_client_address () const override
	Returns address of client which connected to router. More...
std::string	get_server_address () const override
	Returns address of server to which connection is established. More...
void	disconnect () override
virtual void	async_run ()
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
virtual void	stash_server_conn ()
std::string	get_destination_id () const override
void	destination_id (const std::string &id)
std::string	read_only_destination_id () const override
void	read_only_destination_id (const std::string &destination_id)
std::string	read_write_destination_id () const override
void	read_write_destination_id (const std::string &destination_id)
std::optional< net::ip::tcp::endpoint >	destination_endpoint () const override
void	destination_endpoint (const std::optional< net::ip::tcp::endpoint > &ep)
std::optional< net::ip::tcp::endpoint >	read_only_destination_endpoint () const override
void	read_only_destination_endpoint (const std::optional< net::ip::tcp::endpoint > &ep)
std::optional< net::ip::tcp::endpoint >	read_write_destination_endpoint () const override
void	read_write_destination_endpoint (const std::optional< net::ip::tcp::endpoint > &ep)
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	requires_tls (bool v)
	set if the server-connection requires TLS More...
bool	requires_tls () const
	get if the server-connection requires TLS More...
void	requires_client_cert (bool v)
	set if the server-connection requires a client cert More...
bool	requires_client_cert () const
	get if the server-connection requires a client cert More...
void	some_state_changed (bool v)
void	expected_server_mode (mysqlrouter::ServerMode v)
mysqlrouter::ServerMode	expected_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)
RouteDestination *	destinations ()
Destinations &	current_destinations ()
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
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::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

Static Public Member Functions
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)

Protected Types
enum class	Function { kLoop , kFinish }

Protected Member Functions
	MysqlRoutingClassicConnectionBase (MySQLRoutingContext &context, RouteDestination *route_destination, 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 ()

Private Member Functions
void	trace_and_call_function (Tracer::Event::Direction dir, std::string_view stage, Function func)
void	async_send_client (Function next)
void	async_recv_client (Function next)
void	async_send_server (Function next)
void	async_recv_server (Function next)
void	async_recv_both (Function next)
void	async_send_client_and_finish ()
void	async_wait_client_closed ()
void	async_wait_send_server (Function next)
void	server_side_client_greeting ()
void	loop ()
void	finish ()
virtual void	done ()

Private Attributes
std::vector< std::unique_ptr< BasicProcessor > >	processors_
int	active_work_ {0}
bool	authenticated_ {false}
RouteDestination *	route_destination_
Destinations	destinations_
ClientSideConnection	client_conn_
ServerSideConnection	server_conn_
std::string	rw_destination_id_
std::string	ro_destination_id_
std::optional< net::ip::tcp::endpoint >	rw_destination_endpoint_
std::optional< net::ip::tcp::endpoint >	ro_destination_endpoint_
bool	in_handshake_ {true}
	client side handshake isn't finished yet. More...
std::optional< classic_protocol::session_track::TransactionState >	trx_state_
std::optional< classic_protocol::session_track::TransactionCharacteristics >	trx_characteristics_
bool	some_state_changed_ {false}
bool	collation_connection_maybe_dirty_ {false}
bool	requires_tls_ {true}
bool	requires_client_cert_ {false}
ExecutionContext	exec_ctx_
Tracer	tracer_ {false}
net::steady_timer	read_timer_
net::steady_timer	connect_timer_
std::error_code	connect_ec_ {}
bool	diagnostic_area_changed_ {}
FromEither	recv_from_either_ {FromEither::None}
TraceSpan	events_
mysqlrouter::ServerMode	expected_server_mode_
bool	wait_for_my_writes_
std::string	gtid_at_least_executed_
std::chrono::seconds	wait_for_my_writes_timeout_
bool	has_transient_error_at_connect_ {false}

Additional Inherited Members
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_ {{}}

Member Typedef Documentation

ClientSideConnection

using MysqlRoutingClassicConnectionBase::ClientSideConnection = TlsSwitchableClientConnection<ClientSideClassicProtocolState>

ServerSideConnection

using MysqlRoutingClassicConnectionBase::ServerSideConnection = TlsSwitchableConnection<ServerSideClassicProtocolState>

Member Enumeration Documentation

FromEither

enum class MysqlRoutingClassicConnectionBase::FromEither

strong

Enumerator
None
Started
RecvedFromClient
RecvedFromServer

Function

enum class MysqlRoutingClassicConnectionBase::Function

strongprotected

Enumerator
kLoop
kFinish

Constructor & Destructor Documentation

MysqlRoutingClassicConnectionBase()

MysqlRoutingClassicConnectionBase::MysqlRoutingClassicConnectionBase ( MySQLRoutingContext &  context, RouteDestination *  route_destination, std::unique_ptr< ConnectionBase >  client_connection, std::unique_ptr< RoutingConnectionBase >  client_routing_connection, std::function< void(MySQLRoutingConnectionBase *)>  remove_callback  )

inlineprotected

Member Function Documentation

async_recv_both()

void MysqlRoutingClassicConnectionBase::async_recv_both ( Function  next )

private

async_recv_client()

void MysqlRoutingClassicConnectionBase::async_recv_client ( Function  next )

private

async_recv_server()

void MysqlRoutingClassicConnectionBase::async_recv_server ( Function  next )

private

async_run()

virtual void MysqlRoutingClassicConnectionBase::async_run ( )

inlinevirtual

Reimplemented in MysqlRoutingClassicConnection.

async_send_client()

void MysqlRoutingClassicConnectionBase::async_send_client ( Function  next )

private

async_send_client_and_finish()

void MysqlRoutingClassicConnectionBase::async_send_client_and_finish ( )

private

async_send_server()

void MysqlRoutingClassicConnectionBase::async_send_server ( Function  next )

private

async_wait_client_closed()

void MysqlRoutingClassicConnectionBase::async_wait_client_closed ( )

private

async_wait_send_server()

void MysqlRoutingClassicConnectionBase::async_wait_send_server ( Function  next )

private

authenticated() [1/2]

bool MysqlRoutingClassicConnectionBase::authenticated ( ) const

inline

check if the connection is authenticated.

'true' after the initial handshake and change-user finished with "ok". 'false' at connection start and after change-user is started.

Return values

true	if the connection is authenticated.

Returns

false otherwise

authenticated() [2/2]

void MysqlRoutingClassicConnectionBase::authenticated ( bool  v )

inline

call_next_function()

void MysqlRoutingClassicConnectionBase::call_next_function ( Function  next )

inlineprotected

client_conn() [1/2]

ClientSideConnection & MysqlRoutingClassicConnectionBase::client_conn ( )

inline

client_conn() [2/2]

const ClientSideConnection & MysqlRoutingClassicConnectionBase::client_conn ( ) const

inline

client_protocol() [1/2]

ClientSideConnection::protocol_state_type & MysqlRoutingClassicConnectionBase::client_protocol ( )

inline

client_protocol() [2/2]

const ClientSideConnection::protocol_state_type & MysqlRoutingClassicConnectionBase::client_protocol ( ) const

inline

client_socket_failed()

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

virtual

collation_connection_maybe_dirty() [1/2]

bool MysqlRoutingClassicConnectionBase::collation_connection_maybe_dirty ( ) const

inline

collation_connection_maybe_dirty() [2/2]

void MysqlRoutingClassicConnectionBase::collation_connection_maybe_dirty ( bool  val )

inline

connect_error_code() [1/2]

std::error_code MysqlRoutingClassicConnectionBase::connect_error_code ( ) const

inline

connect_error_code() [2/2]

void MysqlRoutingClassicConnectionBase::connect_error_code ( const std::error_code &  ec )

inline

connect_timer()

net::steady_timer & MysqlRoutingClassicConnectionBase::connect_timer ( )

inline

connection_sharing_allowed()

bool MysqlRoutingClassicConnectionBase::connection_sharing_allowed

(

)

const

check if connection sharing is allowed.

• connection sharing is possible.
• no active transaction
• no SET TRANSACTION

connection_sharing_allowed_reset()

void MysqlRoutingClassicConnectionBase::connection_sharing_allowed_reset

(

)

reset the connection-sharing state.

• after COM_RESET_CONNECTION::ok
• after COM_CHANGE_USER::ok

connection_sharing_blocked_by()

std::string MysqlRoutingClassicConnectionBase::connection_sharing_blocked_by

(

)

const

Returns

a string representing the reason why sharing is blocked.

connection_sharing_possible()

bool MysqlRoutingClassicConnectionBase::connection_sharing_possible

(

)

const

check if connection sharing is possible.

• the configuration enabled it

create()

template<typename... Args>

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

inlinestatic

current_destinations()

Destinations & MysqlRoutingClassicConnectionBase::current_destinations ( )

inline

dest_ssl_mode()

SslMode MysqlRoutingClassicConnectionBase::dest_ssl_mode ( ) const

inline

destination_endpoint() [1/2]

std::optional< net::ip::tcp::endpoint > MysqlRoutingClassicConnectionBase::destination_endpoint ( ) const

inlineoverridevirtual

Implements MySQLRoutingConnectionBase.

destination_endpoint() [2/2]

void MysqlRoutingClassicConnectionBase::destination_endpoint ( const std::optional< net::ip::tcp::endpoint > &  ep )

inline

destination_id()

void MysqlRoutingClassicConnectionBase::destination_id ( const std::string &  id )

inline

destinations()

RouteDestination * MysqlRoutingClassicConnectionBase::destinations ( )

inline

diagnostic_area_changed() [1/2]

bool MysqlRoutingClassicConnectionBase::diagnostic_area_changed ( ) const

inline

diagnostic_area_changed() [2/2]

void MysqlRoutingClassicConnectionBase::diagnostic_area_changed ( bool  diagnostic_area_changed )

inline

disconnect()

void MysqlRoutingClassicConnectionBase::disconnect ( )

overridevirtual

Implements MySQLRoutingConnectionBase.

done()

void MysqlRoutingClassicConnectionBase::done ( )

privatevirtual

encode_error_packet()

stdx::expected< size_t, std::error_code > MysqlRoutingClassicConnectionBase::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  )

static

events() [1/2]

TraceSpan & MysqlRoutingClassicConnectionBase::events ( )

inline

events() [2/2]

const TraceSpan & MysqlRoutingClassicConnectionBase::events ( ) const

inline

execution_context() [1/2]

ExecutionContext & MysqlRoutingClassicConnectionBase::execution_context ( )

inline

execution_context() [2/2]

const ExecutionContext & MysqlRoutingClassicConnectionBase::execution_context ( ) const

inline

expected_server_mode() [1/2]

mysqlrouter::ServerMode MysqlRoutingClassicConnectionBase::expected_server_mode ( ) const

inline

expected_server_mode() [2/2]

void MysqlRoutingClassicConnectionBase::expected_server_mode ( mysqlrouter::ServerMode  v )

inline

finish()

void MysqlRoutingClassicConnectionBase::finish ( )

private

get_client_address()

std::string MysqlRoutingClassicConnectionBase::get_client_address ( ) const

inlineoverridevirtual

Returns address of client which connected to router.

Returns

address of client

Implements MySQLRoutingConnectionBase.

get_client_fd()

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

inlineoverridevirtual

Implements MySQLRoutingConnectionBase.

get_destination_id()

std::string MysqlRoutingClassicConnectionBase::get_destination_id ( ) const

inlineoverridevirtual

Implements MySQLRoutingConnectionBase.

get_server_address()

std::string MysqlRoutingClassicConnectionBase::get_server_address ( ) const

inlineoverridevirtual

Returns address of server to which connection is established.

Returns

address of server

Implements MySQLRoutingConnectionBase.

getptr()

std::shared_ptr< MysqlRoutingClassicConnectionBase > MysqlRoutingClassicConnectionBase::getptr ( )

inline

greeting_from_router()

bool MysqlRoutingClassicConnectionBase::greeting_from_router ( ) const

inline

if the router is sending the initial server-greeting.

if true, the router sends the initial greeting to the client, if false, the server is sending the initial greeting and router is forward it.

gtid_at_least_executed() [1/2]

std::string MysqlRoutingClassicConnectionBase::gtid_at_least_executed ( ) const

inline

gtid_at_least_executed() [2/2]

void MysqlRoutingClassicConnectionBase::gtid_at_least_executed ( const std::string &  gtid )

inline

has_transient_error_at_connect() [1/2]

bool MysqlRoutingClassicConnectionBase::has_transient_error_at_connect ( ) const

inline

has_transient_error_at_connect() [2/2]

void MysqlRoutingClassicConnectionBase::has_transient_error_at_connect ( bool  val )

inline

loop()

void MysqlRoutingClassicConnectionBase::loop ( )

private

on_handshake_aborted()

void MysqlRoutingClassicConnectionBase::on_handshake_aborted

(

)

on_handshake_received()

void MysqlRoutingClassicConnectionBase::on_handshake_received

(

)

pop_processor()

void MysqlRoutingClassicConnectionBase::pop_processor ( )

inline

push_processor()

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

inline

read_only_destination_endpoint() [1/2]

std::optional< net::ip::tcp::endpoint > MysqlRoutingClassicConnectionBase::read_only_destination_endpoint ( ) const

inlineoverridevirtual

Reimplemented from MySQLRoutingConnectionBase.

read_only_destination_endpoint() [2/2]

void MysqlRoutingClassicConnectionBase::read_only_destination_endpoint ( const std::optional< net::ip::tcp::endpoint > &  ep )

inline

read_only_destination_id() [1/2]

std::string MysqlRoutingClassicConnectionBase::read_only_destination_id ( ) const

inlineoverridevirtual

Reimplemented from MySQLRoutingConnectionBase.

read_only_destination_id() [2/2]

void MysqlRoutingClassicConnectionBase::read_only_destination_id ( const std::string &  destination_id )

inline

read_timer()

net::steady_timer & MysqlRoutingClassicConnectionBase::read_timer ( )

inline

read_write_destination_endpoint() [1/2]

std::optional< net::ip::tcp::endpoint > MysqlRoutingClassicConnectionBase::read_write_destination_endpoint ( ) const

inlineoverridevirtual

Reimplemented from MySQLRoutingConnectionBase.

read_write_destination_endpoint() [2/2]

void MysqlRoutingClassicConnectionBase::read_write_destination_endpoint ( const std::optional< net::ip::tcp::endpoint > &  ep )

inline

read_write_destination_id() [1/2]

std::string MysqlRoutingClassicConnectionBase::read_write_destination_id ( ) const

inlineoverridevirtual

Reimplemented from MySQLRoutingConnectionBase.

read_write_destination_id() [2/2]

void MysqlRoutingClassicConnectionBase::read_write_destination_id ( const std::string &  destination_id )

inline

recv_client_failed()

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

recv_from_either() [1/2]

FromEither MysqlRoutingClassicConnectionBase::recv_from_either ( ) const

inline

recv_from_either() [2/2]

void MysqlRoutingClassicConnectionBase::recv_from_either ( FromEither  v )

inline

recv_server_failed()

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

requires_client_cert() [1/2]

bool MysqlRoutingClassicConnectionBase::requires_client_cert ( ) const

inline

get if the server-connection requires a client cert

requires_client_cert() [2/2]

void MysqlRoutingClassicConnectionBase::requires_client_cert ( bool  v )

inline

set if the server-connection requires a client cert

requires_tls() [1/2]

bool MysqlRoutingClassicConnectionBase::requires_tls ( ) const

inline

get if the server-connection requires TLS

requires_tls() [2/2]

void MysqlRoutingClassicConnectionBase::requires_tls ( bool  v )

inline

set if the server-connection requires TLS

reset_to_initial()

void MysqlRoutingClassicConnectionBase::reset_to_initial

(

)

reset the connection's settings to the initial-values.

resume()

void MysqlRoutingClassicConnectionBase::resume ( )

inline

send_client_failed()

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

send_server_failed()

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

server_conn() [1/2]

ServerSideConnection & MysqlRoutingClassicConnectionBase::server_conn ( )

inline

server_conn() [2/2]

const ServerSideConnection & MysqlRoutingClassicConnectionBase::server_conn ( ) const

inline

server_protocol() [1/2]

ServerSideConnection::protocol_state_type & MysqlRoutingClassicConnectionBase::server_protocol ( )

inline

server_protocol() [2/2]

const ServerSideConnection::protocol_state_type & MysqlRoutingClassicConnectionBase::server_protocol ( ) const

inline

server_side_client_greeting()

void MysqlRoutingClassicConnectionBase::server_side_client_greeting ( )

private

server_socket_failed()

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

some_state_changed()

void MysqlRoutingClassicConnectionBase::some_state_changed ( bool  v )

inline

source_ssl_mode()

SslMode MysqlRoutingClassicConnectionBase::source_ssl_mode ( ) const

inline

stash_server_conn()

void MysqlRoutingClassicConnectionBase::stash_server_conn ( )

virtual

Reimplemented in MysqlRoutingClassicConnection.

trace()

void MysqlRoutingClassicConnectionBase::trace ( Tracer::Event  e )

inline

trace_and_call_function()

void MysqlRoutingClassicConnectionBase::trace_and_call_function ( Tracer::Event::Direction  dir, std::string_view  stage, MysqlRoutingClassicConnectionBase::Function  func  )

private

tracer()

Tracer & MysqlRoutingClassicConnectionBase::tracer ( )

inline

track_session_changes()

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

trx_characteristics() [1/2]

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

inline

trx_characteristics() [2/2]

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

inline

trx_state()

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

inline

wait_for_my_writes() [1/2]

bool MysqlRoutingClassicConnectionBase::wait_for_my_writes ( ) const

inline

wait_for_my_writes() [2/2]

void MysqlRoutingClassicConnectionBase::wait_for_my_writes ( bool  v )

inline

wait_for_my_writes_timeout() [1/2]

std::chrono::seconds MysqlRoutingClassicConnectionBase::wait_for_my_writes_timeout ( ) const

inline

wait_for_my_writes_timeout() [2/2]

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

inline

Member Data Documentation

active_work_

int MysqlRoutingClassicConnectionBase::active_work_ {0}

private

authenticated_

bool MysqlRoutingClassicConnectionBase::authenticated_ {false}

private

client_conn_

ClientSideConnection MysqlRoutingClassicConnectionBase::client_conn_

private

collation_connection_maybe_dirty_

bool MysqlRoutingClassicConnectionBase::collation_connection_maybe_dirty_ {false}

private

connect_ec_

std::error_code MysqlRoutingClassicConnectionBase::connect_ec_ {}

private

connect_timer_

net::steady_timer MysqlRoutingClassicConnectionBase::connect_timer_

private

destinations_

Destinations MysqlRoutingClassicConnectionBase::destinations_

private

diagnostic_area_changed_

bool MysqlRoutingClassicConnectionBase::diagnostic_area_changed_ {}

private

events_

TraceSpan MysqlRoutingClassicConnectionBase::events_

private

exec_ctx_

ExecutionContext MysqlRoutingClassicConnectionBase::exec_ctx_

private

expected_server_mode_

mysqlrouter::ServerMode MysqlRoutingClassicConnectionBase::expected_server_mode_

private

Initial value:

{
      mysqlrouter::ServerMode::Unavailable}

gtid_at_least_executed_

std::string MysqlRoutingClassicConnectionBase::gtid_at_least_executed_

private

has_transient_error_at_connect_

bool MysqlRoutingClassicConnectionBase::has_transient_error_at_connect_ {false}

private

in_handshake_

bool MysqlRoutingClassicConnectionBase::in_handshake_ {true}

private

client side handshake isn't finished yet.

processors_

std::vector<std::unique_ptr<BasicProcessor> > MysqlRoutingClassicConnectionBase::processors_

private

read_timer_

net::steady_timer MysqlRoutingClassicConnectionBase::read_timer_

private

recv_from_either_

FromEither MysqlRoutingClassicConnectionBase::recv_from_either_ {FromEither::None}

private

requires_client_cert_

bool MysqlRoutingClassicConnectionBase::requires_client_cert_ {false}

private

requires_tls_

bool MysqlRoutingClassicConnectionBase::requires_tls_ {true}

private

ro_destination_endpoint_

std::optional<net::ip::tcp::endpoint> MysqlRoutingClassicConnectionBase::ro_destination_endpoint_

private

ro_destination_id_

std::string MysqlRoutingClassicConnectionBase::ro_destination_id_

private

route_destination_

RouteDestination* MysqlRoutingClassicConnectionBase::route_destination_

private

rw_destination_endpoint_

std::optional<net::ip::tcp::endpoint> MysqlRoutingClassicConnectionBase::rw_destination_endpoint_

private

rw_destination_id_

std::string MysqlRoutingClassicConnectionBase::rw_destination_id_

private

server_conn_

ServerSideConnection MysqlRoutingClassicConnectionBase::server_conn_

private

some_state_changed_

bool MysqlRoutingClassicConnectionBase::some_state_changed_ {false}

private

tracer_

Tracer MysqlRoutingClassicConnectionBase::tracer_ {false}

private

trx_characteristics_

std::optional<classic_protocol::session_track::TransactionCharacteristics> MysqlRoutingClassicConnectionBase::trx_characteristics_

private

trx_state_

std::optional<classic_protocol::session_track::TransactionState> MysqlRoutingClassicConnectionBase::trx_state_

private

wait_for_my_writes_

bool MysqlRoutingClassicConnectionBase::wait_for_my_writes_

private

wait_for_my_writes_timeout_

std::chrono::seconds MysqlRoutingClassicConnectionBase::wait_for_my_writes_timeout_

private

---

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

• router/src/routing/src/classic_connection_base.h
• router/src/routing/src/classic_connection_base.cc