MetadataServerSession Class Reference
#include <metadata_server_session.h>
Inheritance diagram for MetadataServerSession:
Collaboration diagram for MetadataServerSession:
Public Member Functions | |
| MetadataServerSession (HttpServer *server, SslSocket *socket) | |
| virtual | ~MetadataServerSession () |
| virtual int | GetSessionInstance () const |
 Public Member Functions inherited from HttpSession | |
| HttpSession (HttpServer *server, SslSocket *sock, bool async_ready=true) | |
| virtual | ~HttpSession () |
| const std::string | get_context () |
| void | AcceptSession () |
| void | RegisterEventCb (SessionEventCb cb) |
| Public Member Functions inherited from SslSession | |
| SslSession (SslServer *server, SslSocket *socket, bool async_read_ready=true) | |
| virtual Socket * | socket () const |
| void | TriggerSslHandShake (SslHandShakeCallbackHandler) |
| bool | IsSslDisabled () |
| bool | IsSslHandShakeDelayed () |
| bool | IsSslHandShakeSuccess () |
| bool | IsSslHandShakeSuccessLocked () |
| bool | IsSslHandShakeInProgress () |
| void | SetSslHandShakeInProgress (bool state) |
| Public Member Functions inherited from TcpSession | |
| TcpSession (TcpServer *server, Socket *socket, bool async_read_ready=true, size_t buffer_send_size=TcpSession::kDefaultWriteBufferSize) | |
| virtual bool | Send (const uint8_t *data, size_t size, size_t *sent) |
| virtual bool | Connected (Endpoint remote) |
| virtual void | Accepted () |
| void | ConnectFailed () |
| void | Close () |
| virtual std::string | ToString () const |
| NativeSocketType | sock_descriptor () |
| TcpServer * | server () |
| int32_t | local_port () const |
| int32_t | remote_port () const |
| void | set_observer (EventObserver observer) |
| virtual void | ReleaseBuffer (Buffer buffer) |
| bool | IsEstablished () const |
| bool | IsClosed () const |
| bool | IsServerSession () |
| Endpoint | remote_endpoint () const |
| const std::string & | remote_addr_string () const |
| Endpoint | local_endpoint () const |
| const boost::system::error_code & | close_reason () const |
| virtual boost::system::error_code | SetSocketOptions () |
| void | set_read_on_connect (bool read) |
| void | SessionEstablished (Endpoint remote, Direction direction) |
| virtual void | AsyncReadStart () |
| virtual void | SetDeferReader (bool defer_reader) |
| virtual bool | IsReaderDeferred () const |
| const io::SocketStats & | GetSocketStats () const |
| void | GetRxSocketStats (SocketIOStats *socket_stats) const |
| void | GetTxSocketStats (SocketIOStats *socket_stats) const |
| void | GetRxSocketStats (SocketIOStats &socket_stats) const |
| void | GetTxSocketStats (SocketIOStats &socket_stats) const |
| int | SetMd5SocketOption (uint32_t peer_ip, const std::string &md5_password) |
| int | ClearMd5SocketOption (uint32_t peer_ip) |
| int | SetDscpSocketOption (uint8_t value) |
| uint8_t | GetDscpValue () const |
| const std::string & | ToUVEKey () const |
| boost::system::error_code | SetTcpNoDelay () |
| boost::system::error_code | SetTcpSendBufSize (uint32_t size) |
| boost::system::error_code | SetTcpRecvBufSize (uint32_t size) |
Static Public Attributes | |
| static const int | kMetadataSessionInstance = 0 |
| Static Public Attributes inherited from TcpSession | |
| static const int | kDefaultBufferSize = 16 * 1024 |
| static const int | kDefaultWriteBufferSize = 32 * 1024 |
Private Member Functions | |
| DISALLOW_COPY_AND_ASSIGN (MetadataServerSession) | |
Additional Inherited Members | |
| Public Types inherited from HttpSession | |
| typedef boost::function< void(HttpSession *session, enum TcpSession::Event event)> | SessionEventCb |
| Public Types inherited from SslSession | |
| typedef boost::asio::ssl::stream< boost::asio::ip::tcp::socket > | SslSocket |
| Public Types inherited from TcpSession | |
| enum | Event { EVENT_NONE , ACCEPT , CONNECT_COMPLETE , CONNECT_FAILED , CLOSE } |
| enum | Direction { ACTIVE , PASSIVE } |
| typedef boost::asio::ip::tcp::socket | Socket |
| typedef boost::asio::ip::tcp::socket::native_handle_type | NativeSocketType |
| typedef boost::asio::ip::tcp::endpoint | Endpoint |
| typedef boost::function< void(TcpSession *, Event)> | EventObserver |
| typedef boost::asio::const_buffer | Buffer |
| Static Public Member Functions inherited from HttpSession | |
| static bool | SendSession (std::string const &s, const uint8_t *data, size_t size, size_t *sent) |
| static std::string | get_client_context (std::string const &s) |
| static bool | set_client_context (std::string const &s, const std::string &ctx) |
| static tbb::atomic< long > | GetPendingTaskCount () |
| Static Public Member Functions inherited from SslSession | |
| static bool | IsSocketErrorHard (const boost::system::error_code &ec) |
| Static Public Member Functions inherited from TcpSession | |
| static const uint8_t * | BufferData (const Buffer &buffer) |
| static size_t | BufferSize (const Buffer &buffer) |
| static bool | IsSocketErrorHard (const boost::system::error_code &ec) |
| Public Attributes inherited from HttpSession | |
| OnMessageBegin | |
| OnUrl | |
| OnStatusComplete | |
| OnHeaderField | |
| OnHeaderValue | |
| OnHeadersComplete | |
| OnBody | |
| Protected Types inherited from TcpSession | |
| typedef boost::intrusive_ptr< TcpSession > | TcpSessionPtr |
| typedef boost::asio::strand< boost::asio::io_context::executor_type > | Strand |
| Protected Member Functions inherited from HttpSession | |
| virtual void | OnRead (Buffer buffer) |
| Protected Member Functions inherited from SslSession | |
| virtual | ~SslSession () |
| Protected Member Functions inherited from TcpSession | |
| void | AsyncReadStartInternal (TcpSessionPtr session) |
| virtual | ~TcpSession () |
| virtual void | WriteReady (const boost::system::error_code &error) |
| void | AsyncWriteInternal (TcpSessionPtr session) |
| virtual int | reader_task_id () const |
| bool | established () const |
| EventObserver | observer () |
| boost::system::error_code | SetSocketKeepaliveOptions (int keepalive_time, int keepalive_intvl, int keepalive_probes, int tcp_user_timeout_val=0) |
| void | CloseInternal (const boost::system::error_code &ec, bool call_observer, bool notify_server=true) |
| void | TriggerAsyncReadHandler () |
| Static Protected Member Functions inherited from TcpSession | |
| static void | AsyncReadHandler (TcpSessionPtr session) |
| static void | AsyncWriteHandler (TcpSessionPtr session, const boost::system::error_code &error, std::size_t bytes_transferred) |
| Protected Attributes inherited from TcpSession | |
| tbb::mutex | mutex_ |
| io::SocketStats | stats_ |
| boost::scoped_ptr< Strand > | io_strand_ |
Detailed Description
Definition at line 11 of file metadata_server_session.h.
Constructor & Destructor Documentation
◆ MetadataServerSession()
|
inline |
Definition at line 15 of file metadata_server_session.h.
◆ ~MetadataServerSession()
|
inlinevirtual |
Definition at line 17 of file metadata_server_session.h.
Member Function Documentation
◆ DISALLOW_COPY_AND_ASSIGN()
|
private |
◆ GetSessionInstance()
|
inlinevirtual |
Reimplemented from TcpSession.
Definition at line 21 of file metadata_server_session.h.
Member Data Documentation
◆ kMetadataSessionInstance
|
static |
Definition at line 13 of file metadata_server_session.h.
The documentation for this class was generated from the following file:
