StmtPrepareForwarder Class Reference

#include <classic_stmt_prepare_forwarder.h>

Inheritance diagram for StmtPrepareForwarder:

Public Types
enum class	Stage {   Command , Connect , Connected , 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 ()

Private Member Functions
stdx::expected< Result, std::error_code >	command ()
stdx::expected< Result, std::error_code >	connect ()
stdx::expected< Result, std::error_code >	connected ()
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_ {}

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

Member Enumeration Documentation

Stage

enum class StmtPrepareForwarder::Stage

strong

Enumerator
Command
Connect
Connected
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

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

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

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

---

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