classic protocol handshake between client<->router and router<->server. More...

#include <classic_greeting_forwarder.h>

Inheritance diagram for ServerGreetor:

Public Types
enum class	Stage { ServerGreeting , ServerGreetingError , ServerGreetingGreeting , ClientGreeting , ClientGreetingStartTls , ClientGreetingFull , TlsConnectInit , TlsConnect , ClientGreetingAfterTls , InitialResponse , FinalResponse , AuthOk , AuthError , ServerGreetingSent , Error , Ok }
	stages of the handshake flow. More...

Public Types inherited from BasicProcessor
enum class	Result { Again , RecvFromClient , SendToClient , RecvFromServer , RecvFromBoth , SendToServer , SendableToServer , Suspend , Done , Void }

Public Member Functions
	ServerGreetor (MysqlRoutingClassicConnectionBase *conn, bool in_handshake, std::function< void(const classic_protocol::message::server::Error &)> on_error)
	construct a server::greeting processor. More...

stdx::expected< Result, std::error_code >	process () override

void	stage (Stage stage)

Stage	stage () const

Public Member Functions inherited from Processor
	BasicProcessor (MysqlRoutingClassicConnectionBase *conn)

Public Member Functions inherited from BasicProcessor
	BasicProcessor (MysqlRoutingClassicConnectionBase *conn)

virtual	~BasicProcessor ()=default

const MysqlRoutingClassicConnectionBase *	connection () const

MysqlRoutingClassicConnectionBase *	connection ()

Private Member Functions
stdx::expected< Result, std::error_code >	server_greeting ()

stdx::expected< Result, std::error_code >	server_greeting_greeting ()
	received a server::greeting from the server. More...

stdx::expected< Result, std::error_code >	server_greeting_error ()
	received an server::error from the server. More...

stdx::expected< Result, std::error_code >	client_greeting ()

stdx::expected< Result, std::error_code >	client_greeting_start_tls ()

stdx::expected< Result, std::error_code >	client_greeting_full ()
	send a non-TLS client greeting to the server. More...

stdx::expected< Result, std::error_code >	tls_connect_init ()

stdx::expected< Result, std::error_code >	tls_connect ()

stdx::expected< Result, std::error_code >	client_greeting_after_tls ()
	a TLS client greeting. More...

stdx::expected< Result, std::error_code >	initial_response ()

stdx::expected< Result, std::error_code >	final_response ()

stdx::expected< Result, std::error_code >	auth_error ()
	router<-server: auth error. More...

stdx::expected< Result, std::error_code >	auth_ok ()
	server-side: auth is ok. More...

stdx::expected< Result, std::error_code >	error ()

void	client_greeting_server_adjust_caps (ClassicProtocolState src_protocol, ClassicProtocolState dst_protocol)

Private Attributes
bool	in_handshake_

Stage	stage_ {Stage::ServerGreeting}

std::function< void(const classic_protocol::message::server::Error &err)>	on_error_

Additional Inherited Members
Protected Member Functions inherited from ForwardingProcessor
stdx::expected< Result, std::error_code >	forward_server_to_client (bool noflush=false)
	forward the current packet from the server-side to the client-side. More...

stdx::expected< Result, std::error_code >	forward_client_to_server (bool noflush=false)
	forward the current packet from the client-side to the server-side. More...

stdx::expected< bool, std::error_code >	pool_server_connection ()
	move the server connection to the pool. More...

stdx::expected< Processor::Result, std::error_code >	socket_reconnect_start ()
	reconnect a socket. More...

stdx::expected< Processor::Result, std::error_code >	mysql_reconnect_start ()
	reconnect a mysql classic connection. More...

stdx::expected< Result, std::error_code >	recv_server_failed_and_check_client_socket (std::error_code ec)
	handle error-code of a failed receive() from the server-socket and check the status of the client socket. More...

stdx::expected< Processor::Result, std::error_code >	reconnect_send_error_msg (Channel src_channel, ClassicProtocolState src_protocol)
	send a Error msg based on the reconnect_error(). More...

void	reconnect_error (classic_protocol::message::server::Error err)
	set the reconnect error. More...

classic_protocol::message::server::Error	reconnect_error () const
	get the reconnect error. More...

Protected Member Functions inherited from Processor
stdx::expected< Result, std::error_code >	send_server_failed (std::error_code ec)

stdx::expected< Result, std::error_code >	recv_server_failed (std::error_code ec)

stdx::expected< Result, std::error_code >	send_client_failed (std::error_code ec)

stdx::expected< Result, std::error_code >	recv_client_failed (std::error_code ec)

stdx::expected< Result, std::error_code >	server_socket_failed (std::error_code ec)

stdx::expected< Result, std::error_code >	client_socket_failed (std::error_code ec)

stdx::expected< void, std::error_code >	discard_current_msg (Channel src_channel, ClassicProtocolState src_protocol)
	discard to current message. More...

void	trace (Tracer::Event e)

Tracer &	tracer ()

Static Protected Member Functions inherited from Processor
static void	log_fatal_error_code (const char *msg, std::error_code ec)
	log a message with error-code as error. More...

Detailed Description

classic protocol handshake between client<->router and router<->server.

Member Enumeration Documentation

◆ Stage

enum class ServerGreetor::Stage

strong

stages of the handshake flow.

Client stages are on the client<->router side.
Server stages are on the router<->server side.

Enumerator
ServerGreeting
ServerGreetingError
ServerGreetingGreeting
ClientGreeting
ClientGreetingStartTls
ClientGreetingFull
TlsConnectInit
TlsConnect
ClientGreetingAfterTls
InitialResponse
FinalResponse
AuthOk
AuthError
ServerGreetingSent
Error
Ok

Constructor & Destructor Documentation

◆ ServerGreetor()

ServerGreetor::ServerGreetor	(	MysqlRoutingClassicConnectionBase *	conn,
		bool	in_handshake,
		std::function< void(const classic_protocol::message::server::Error &)>	on_error
	)

inline

construct a server::greeting processor.

c->r   : ...
   r->s: connect()
   r<-s: server::greeting

a server greeting may be sent as part of the initial connection setup between client<->router<->server (in_handshake=true) or when router starts a connection on its own.

If in_handshake is true, the ServerGreetor expects it can send:

server::AuthMethodSwitch and
server::Ok

to the client connection.

Parameters

conn	the connection the greeting will be transferred on.
in_handshake	true if the greeting is part of the initial handshake.
on_error	callback called on failure.

Member Function Documentation

◆ auth_error()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::auth_error ( )

private

router<-server: auth error.

◆ auth_ok()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::auth_ok ( )

private

server-side: auth is ok.

◆ client_greeting()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::client_greeting ( )

private

◆ client_greeting_after_tls()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::client_greeting_after_tls ( )

private

a TLS client greeting.

◆ client_greeting_full()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::client_greeting_full ( )

private

send a non-TLS client greeting to the server.

◆ client_greeting_server_adjust_caps()

void ServerGreetor::client_greeting_server_adjust_caps	(	ClassicProtocolState *	src_protocol,
		ClassicProtocolState *	dst_protocol
	)

private

◆ client_greeting_start_tls()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::client_greeting_start_tls ( )

private

◆ error()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::error ( )

private

◆ final_response()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::final_response ( )

private

◆ initial_response()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::initial_response ( )

private

◆ process()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::process ( )

overridevirtual

Implements BasicProcessor.

◆ server_greeting()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::server_greeting ( )

private

◆ server_greeting_error()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::server_greeting_error ( )

private

received an server::error from the server.

forward it to the client and close the connection.

◆ server_greeting_greeting()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::server_greeting_greeting ( )

private

received a server::greeting from the server.

decode it.

◆ stage() [1/2]

Stage ServerGreetor::stage ( ) const

inline

◆ stage() [2/2]

void ServerGreetor::stage ( Stage stage )

inline

◆ tls_connect()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::tls_connect ( )

private

◆ tls_connect_init()

stdx::expected< Processor::Result, std::error_code > ServerGreetor::tls_connect_init ( )

private

Member Data Documentation

◆ in_handshake_

bool ServerGreetor::in_handshake_

private

◆ on_error_

std::function<void(const classic_protocol::message::server::Error &err)> ServerGreetor::on_error_

private

◆ stage_

Stage ServerGreetor::stage_ {Stage::ServerGreeting}

private

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

router/src/routing/src/classic_greeting_forwarder.h
router/src/routing/src/classic_greeting_forwarder.cc

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ Stage

Constructor & Destructor Documentation

◆ ServerGreetor()

Member Function Documentation

◆ auth_error()

◆ auth_ok()

◆ client_greeting()

◆ client_greeting_after_tls()

◆ client_greeting_full()

◆ client_greeting_server_adjust_caps()

◆ client_greeting_start_tls()

◆ error()

◆ final_response()

◆ initial_response()

◆ process()

◆ server_greeting()

◆ server_greeting_error()

◆ server_greeting_greeting()

◆ stage() [1/2]

◆ stage() [2/2]

◆ tls_connect()

◆ tls_connect_init()

Member Data Documentation

◆ in_handshake_

◆ on_error_

◆ stage_