MySQL 8.0.40
Source Code Documentation
|
forward a mysql packet from the client to the server. More...
#include <classic_forwarder.h>
Public Types | |
enum class | Stage { Forward , Done } |
Public Types inherited from Forwarder | |
enum class | ForwardResult { kWantRecvSource , kWantSendSource , kWantRecvDestination , kWantSendDestination , kFinished } |
Public Types inherited from BasicProcessor | |
enum class | Result { Again , RecvFromClient , SendToClient , RecvFromServer , RecvFromBoth , SendToServer , SendableToServer , Suspend , Done , Void } |
Public Member Functions | |
ClientToServerForwarder (MysqlRoutingClassicConnectionBase *conn, bool flush_before_next_func_optional=true) | |
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< ForwardResult, std::error_code > | forward_frame_sequence () |
stdx::expected< Result, std::error_code > | forward () |
Private Attributes | |
bool | flush_before_next_func_optional_ |
Stage | stage_ {Stage::Forward} |
Additional Inherited Members | |
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... | |
forward a mysql packet from the client to the server.
|
strong |
|
inlineexplicit |
|
private |
|
private |
|
overridevirtual |
Implements BasicProcessor.
|
inline |
|
inline |
|
private |
|
private |