OpenSDN source code
|
#include <metadata_server_session.h>
Public Member Functions | |
MetadataServerSession (HttpServer *server, SslSocket *socket) | |
virtual | ~MetadataServerSession () |
virtual int | GetSessionInstance () const |
![]() | |
HttpSession (HttpServer *server, SslSocket *sock, bool async_ready=true) | |
virtual | ~HttpSession () |
const std::string | get_context () |
void | AcceptSession () |
void | RegisterEventCb (SessionEventCb cb) |
![]() | |
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) |
![]() | |
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 const int | kDefaultBufferSize = 16 * 1024 |
static const int | kDefaultWriteBufferSize = 32 * 1024 |
Private Member Functions | |
DISALLOW_COPY_AND_ASSIGN (MetadataServerSession) | |
Additional Inherited Members | |
![]() | |
typedef boost::function< void(HttpSession *session, enum TcpSession::Event event)> | SessionEventCb |
![]() | |
typedef boost::asio::ssl::stream < boost::asio::ip::tcp::socket > | SslSocket |
![]() | |
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 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 bool | IsSocketErrorHard (const boost::system::error_code &ec) |
![]() | |
static const uint8_t * | BufferData (const Buffer &buffer) |
static size_t | BufferSize (const Buffer &buffer) |
static bool | IsSocketErrorHard (const boost::system::error_code &ec) |
![]() | |
OnMessageBegin | |
OnUrl | |
OnStatusComplete | |
OnHeaderField | |
OnHeaderValue | |
OnHeadersComplete | |
OnBody | |
![]() | |
typedef boost::intrusive_ptr < TcpSession > | TcpSessionPtr |
typedef boost::asio::strand < boost::asio::io_context::executor_type > | Strand |
![]() | |
virtual void | OnRead (Buffer buffer) |
![]() | |
virtual | ~SslSession () |
![]() | |
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 void | AsyncReadHandler (TcpSessionPtr session) |
static void | AsyncWriteHandler (TcpSessionPtr session, const boost::system::error_code &error, std::size_t bytes_transferred) |
![]() | |
tbb::mutex | mutex_ |
io::SocketStats | stats_ |
boost::scoped_ptr< Strand > | io_strand_ |
Definition at line 11 of file metadata_server_session.h.
|
inline |
Definition at line 15 of file metadata_server_session.h.
|
inlinevirtual |
Definition at line 17 of file metadata_server_session.h.
|
private |
|
inlinevirtual |
Reimplemented from TcpSession.
Definition at line 21 of file metadata_server_session.h.
|
static |
Definition at line 13 of file metadata_server_session.h.