MySQL 9.1.0
Source Code Documentation
ResetConnectionForwarder Member List

This is the complete list of members for ResetConnectionForwarder, including all inherited members.

BasicProcessor(MysqlRoutingClassicConnectionBase *conn)Processorinline
client_socket_failed(std::error_code ec)Processorprotected
command()ResetConnectionForwarderprivate
conn_BasicProcessorprivate
connect()ResetConnectionForwarderprivate
connect_error_is_transient(const classic_protocol::message::server::Error &err)ForwardingProcessorprotectedstatic
connected()ResetConnectionForwarderprivate
connection() constBasicProcessorinline
connection()BasicProcessorinline
discard_current_msg(Channel &src_channel, ClassicProtocolState &src_protocol)Processorprotected
discard_current_msg(TlsSwitchableConnection< Proto > &conn)Processorinlineprotected
end_loop()ResetConnectionForwarderprivate
failed(const std::optional< classic_protocol::message::server::Error > &err)ResetConnectionForwarderinline
failed() constResetConnectionForwarderinline
failed_ResetConnectionForwarderprivate
fetch_sys_vars()ResetConnectionForwarderprivate
fetch_sys_vars_done()ResetConnectionForwarderprivate
forward_client_to_server(bool noflush=false)ForwardingProcessorprotected
forward_server_to_client(bool noflush=false)ForwardingProcessorprotected
kConnectRetryIntervalForwardingProcessorstatic
log_fatal_error_code(const char *msg, std::error_code ec)Processorprotectedstatic
message_can_be_forwarded_as_is(ClassicProtocolState &src_protocol, ClassicProtocolState &dst_protocol, const T &msg)ForwardingProcessorinlineprotectedstatic
mysql_reconnect_start(TraceEvent *parent_event)ForwardingProcessorprotected
ok()ResetConnectionForwarderprivate
pool_server_connection()ForwardingProcessorprotected
process() overrideResetConnectionForwardervirtual
reconnect_error(classic_protocol::message::server::Error err)ForwardingProcessorinlineprotected
reconnect_error() constForwardingProcessorinlineprotected
reconnect_error_ForwardingProcessorprivate
reconnect_send_error_msg(Channel &src_channel, ClassicProtocolState &src_protocol)ForwardingProcessorprotected
reconnect_send_error_msg(TlsSwitchableConnection< Proto > &conn)ForwardingProcessorinlineprotected
recv_client_failed(std::error_code ec)Processorprotected
recv_server_failed(std::error_code ec)Processorprotected
recv_server_failed_and_check_client_socket(std::error_code ec)ForwardingProcessorprotected
response()ResetConnectionForwarderprivate
Result enum nameBasicProcessor
round_ResetConnectionForwarderprivate
send_client_failed(std::error_code ec)Processorprotected
send_ok()ResetConnectionForwarderprivate
send_server_failed(std::error_code ec)Processorprotected
server_socket_failed(std::error_code ec)Processorprotected
set_vars()ResetConnectionForwarderprivate
set_vars_done()ResetConnectionForwarderprivate
skip_or_inject_end_of_columns(bool no_flush=false)ForwardingProcessorprotected
socket_reconnect_start(TraceEvent *parent_event)ForwardingProcessorprotected
Stage enum nameResetConnectionForwarder
stage(Stage stage)ResetConnectionForwarderinline
stage() constResetConnectionForwarderinline
stage_ResetConnectionForwarderprivate
start_loop()ResetConnectionForwarderprivate
trace(Tracer::Event e)Processorprotected
trace_command(const std::string_view &prefix)Processorprotected
trace_command_end(TraceEvent *event, TraceEvent::StatusCode status_code=TraceEvent::StatusCode::kUnset)Processorprotected
trace_connect(TraceEvent *parent_span)Processorprotected
trace_connect_and_forward_command(TraceEvent *parent_span)Processorprotected
trace_forward_command(TraceEvent *parent_span)Processorprotected
trace_set_connection_attributes(TraceEvent *ev)Processorprotected
trace_span(TraceEvent *parent_span, const std::string_view &prefix)Processorprotected
trace_span_end(TraceEvent *event, TraceEvent::StatusCode status_code=TraceEvent::StatusCode::kUnset)Processorprotected
tracer()Processorprotected
~BasicProcessor()=defaultBasicProcessorvirtual