#include <classic_stmt_prepare_forwarder.h>

Inheritance diagram for StmtPrepareForwarder:

Public Types
enum class	Stage { Command , ForbidCommand , PoolBackend , SwitchBackend , PrepareBackend , Connect , Connected , Forward , ForwardDone , Response , Column , EndOfColumns , Param , EndOfParams , Ok , OkDone , Error , Done }

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

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

Static Public Member Functions
static std::string_view	prefix ()

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

bool	has_more_messages () const

Private Attributes
Stage	stage_ {Stage::Command}

size_t	columns_left_ {0}

size_t	params_left_ {0}

uint16_t	stmt_id_ {}

PreparedStatement	prep_stmt_ {}

TraceEvent *	trace_event_command_ {nullptr}

TraceEvent *	trace_event_connect_and_forward_command_ {nullptr}

TraceEvent *	trace_event_forward_command_ {nullptr}

Additional Inherited Members
Static Public Attributes inherited from ForwardingProcessor
static constexpr const std::chrono::milliseconds	kConnectRetryInterval
	interval between connect-retries. More...

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< Processor::Result, std::error_code >	skip_or_inject_end_of_columns (bool no_flush=false)
	adjust the end-of-columns packet. 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 (TraceEvent *parent_event)
	reconnect a socket. More...

stdx::expected< Processor::Result, std::error_code >	mysql_reconnect_start (TraceEvent *parent_event)
	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...

template<class Proto >
stdx::expected< Processor::Result, std::error_code >	reconnect_send_error_msg (TlsSwitchableConnection< Proto > &conn)

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...

template<class Proto >
stdx::expected< void, std::error_code >	discard_current_msg (TlsSwitchableConnection< Proto > &conn)

void	trace (Tracer::Event e)

Tracer &	tracer ()

TraceEvent *	trace_span (TraceEvent *parent_span, const std::string_view &prefix)
	start a span. More...

void	trace_span_end (TraceEvent *event, TraceEvent::StatusCode status_code=TraceEvent::StatusCode::kUnset)
	end a span and set a status-code. More...

TraceEvent *	trace_command (const std::string_view &prefix)
	start a command span. More...

TraceEvent *	trace_connect_and_forward_command (TraceEvent *parent_span)
	start a connect-and-forward span. More...

TraceEvent *	trace_connect (TraceEvent *parent_span)
	start a connect span. More...

void	trace_set_connection_attributes (TraceEvent *ev)
	start a connect span. More...

TraceEvent *	trace_forward_command (TraceEvent *parent_span)
	start a forward span. More...

void	trace_command_end (TraceEvent *event, TraceEvent::StatusCode status_code=TraceEvent::StatusCode::kUnset)
	end a command span and set a status-code. More...

Static Protected Member Functions inherited from ForwardingProcessor
template<class T >
static bool	message_can_be_forwarded_as_is (ClassicProtocolState &src_protocol, ClassicProtocolState &dst_protocol, const T &msg)
	check of the capabilities of the source and the destination are the same for this message. More...

static bool	connect_error_is_transient (const classic_protocol::message::server::Error &err)
	check if the error is a transient error. More...

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...

Member Enumeration Documentation

◆ Stage

enum class StmtPrepareForwarder::Stage

strong

Enumerator
Command
ForbidCommand
PoolBackend
SwitchBackend
PrepareBackend
Connect
Connected
Forward
ForwardDone
Response
Column
EndOfColumns
Param
EndOfParams
Ok
OkDone
Error
Done

Member Function Documentation

◆ column()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::column ( )

private

◆ command()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::command ( )

private

◆ connect()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::connect ( )

private

◆ connected()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::connected ( )

private

◆ end_of_columns()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::end_of_columns ( )

private

◆ end_of_params()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::end_of_params ( )

private

◆ error()

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

private

◆ forbid_command()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::forbid_command ( )

private

◆ forward()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::forward ( )

private

◆ forward_done()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::forward_done ( )

private

◆ has_more_messages()

bool StmtPrepareForwarder::has_more_messages ( ) const

private

◆ ok()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::ok ( )

private

◆ ok_done()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::ok_done ( )

private

◆ param()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::param ( )

private

◆ pool_backend()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::pool_backend ( )

private

◆ prefix()

static std::string_view StmtPrepareForwarder::prefix ( )

inlinestatic

◆ prepare_backend()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::prepare_backend ( )

private

◆ process()

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

overridevirtual

Implements BasicProcessor.

◆ response()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::response ( )

private

◆ stage() [1/2]

Stage StmtPrepareForwarder::stage ( ) const

inline

◆ stage() [2/2]

void StmtPrepareForwarder::stage ( Stage stage )

inline

◆ switch_backend()

stdx::expected< Processor::Result, std::error_code > StmtPrepareForwarder::switch_backend ( )

private

Member Data Documentation

◆ columns_left_

size_t StmtPrepareForwarder::columns_left_ {0}

private

◆ params_left_

size_t StmtPrepareForwarder::params_left_ {0}

private

◆ prep_stmt_

PreparedStatement StmtPrepareForwarder::prep_stmt_ {}

private

◆ stage_

Stage StmtPrepareForwarder::stage_ {Stage::Command}

private

◆ stmt_id_

uint16_t StmtPrepareForwarder::stmt_id_ {}

private

◆ trace_event_command_

TraceEvent* StmtPrepareForwarder::trace_event_command_ {nullptr}

private

◆ trace_event_connect_and_forward_command_

TraceEvent* StmtPrepareForwarder::trace_event_connect_and_forward_command_ {nullptr}

private

◆ trace_event_forward_command_

TraceEvent* StmtPrepareForwarder::trace_event_forward_command_ {nullptr}

private

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

router/src/routing/src/classic_stmt_prepare_forwarder.h
router/src/routing/src/classic_stmt_prepare_forwarder.cc

Public Types

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Member Enumeration Documentation

◆ Stage

Member Function Documentation

◆ column()

◆ command()

◆ connect()

◆ connected()

◆ end_of_columns()

◆ end_of_params()

◆ error()

◆ forbid_command()

◆ forward()

◆ forward_done()

◆ has_more_messages()

◆ ok()

◆ ok_done()

◆ param()

◆ pool_backend()

◆ prefix()

◆ prepare_backend()

◆ process()

◆ response()

◆ stage() [1/2]

◆ stage() [2/2]

◆ switch_backend()

Member Data Documentation

◆ columns_left_

◆ params_left_

◆ prep_stmt_

◆ stage_

◆ stmt_id_

◆ trace_event_command_

◆ trace_event_connect_and_forward_command_

◆ trace_event_forward_command_