MySQL 8.4.0
Source Code Documentation
FlowProcessor Class Reference

the classic protocol flow. More...

#include <classic_flow.h>

Inheritance diagram for FlowProcessor:
[legend]

Public Types

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

Public Member Functions

stdx::expected< Processor::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 MysqlRoutingClassicConnectionBaseconnection () const
 
MysqlRoutingClassicConnectionBaseconnection ()
 

Private Member Functions

stdx::expected< Processor::Result, std::error_code > greeting ()
 the handshake part. More...
 
stdx::expected< Processor::Result, std::error_code > command ()
 the command part. More...
 

Private Attributes

Stage stage_ {Stage::Greeting}
 

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...
 
template<class Proto >
stdx::expected< void, std::error_code > discard_current_msg (TlsSwitchableConnection< Proto > &conn)
 
void trace (Tracer::Event e)
 
Tracertracer ()
 
TraceEventtrace_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...
 
TraceEventtrace_command (const std::string_view &prefix)
 start a command span. More...
 
TraceEventtrace_connect_and_forward_command (TraceEvent *parent_span)
 start a connect-and-forward span. More...
 
TraceEventtrace_connect (TraceEvent *parent_span)
 start a connect span. More...
 
void trace_set_connection_attributes (TraceEvent *ev)
 start a connect span. More...
 
TraceEventtrace_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 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

the classic protocol flow.

  1. Greeting handshake
  2. Commands

Member Enumeration Documentation

◆ Stage

enum class FlowProcessor::Stage
strong
Enumerator
Greeting 
Command 
Done 

Member Function Documentation

◆ command()

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

the command part.

◆ greeting()

stdx::expected< Processor::Result, std::error_code > FlowProcessor::greeting ( )
private

the handshake part.

◆ process()

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

Implements BasicProcessor.

◆ stage() [1/2]

Stage FlowProcessor::stage ( ) const
inline

◆ stage() [2/2]

void FlowProcessor::stage ( Stage  stage)
inline

Member Data Documentation

◆ stage_

Stage FlowProcessor::stage_ {Stage::Greeting}
private

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