OpenSDN source code
|
#include <ovsdb_client_ssl.h>
Public Member Functions | |
OvsdbClientSslSession (Agent *agent, OvsPeerManager *manager, OvsdbClientSsl *server, SslSocket *sock, bool async_ready=true) | |
~OvsdbClientSslSession () | |
void | SendMsg (u_int8_t *buf, std::size_t len) |
bool | RecvMsg (const u_int8_t *buf, std::size_t len) |
int | keepalive_interval () |
bool | ThrottleInFlightTxnMessages () |
const boost::system::error_code & | ovsdb_close_reason () const |
ConnectionStateTable * | connection_table () |
KSyncObjectManager * | ksync_obj_manager () |
Ip4Address | tsn_ip () |
void | set_status (std::string status) |
std::string | status () |
void | OnCleanup () |
void | TriggerClose () |
virtual Ip4Address | remote_ip () const |
virtual uint16_t | remote_port () const |
bool | ProcessSessionEvent (OvsdbSessionEvent event) |
void | EnqueueEvent (TcpSession::Event event) |
![]() | |
OvsdbClientSession (Agent *agent, OvsPeerManager *manager) | |
virtual | ~OvsdbClientSession () |
void | MessageProcess (const u_int8_t *buf, std::size_t len) |
void | SendJsonRpc (struct jsonrpc_msg *msg) |
void | OnEstablish () |
void | OnClose () |
OvsdbClientIdl * | client_idl () |
void | AddSessionInfo (SandeshOvsdbClientSession &session) |
virtual bool | TestConcurrencyAllow () |
![]() | |
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) |
virtual int | GetSessionInstance () const |
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) |
Protected Member Functions | |
virtual void | OnRead (Buffer buffer) |
virtual int | reader_task_id () const |
![]() | |
virtual | ~SslSession () |
![]() | |
void | AsyncReadStartInternal (TcpSessionPtr session) |
virtual | ~TcpSession () |
virtual void | WriteReady (const boost::system::error_code &error) |
void | AsyncWriteInternal (TcpSessionPtr session) |
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 () |
Private Member Functions | |
DISALLOW_COPY_AND_ASSIGN (OvsdbClientSslSession) | |
Private Attributes | |
std::string | status_ |
OvsdbClientTcpSessionReader * | reader_ |
WorkQueue< OvsdbSessionEvent > * | session_event_queue_ |
Friends | |
class | OvsdbClientSsl |
Additional Inherited Members | |
![]() | |
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 | 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) |
![]() | |
static const int | kDefaultBufferSize = 16 * 1024 |
static const int | kDefaultWriteBufferSize = 32 * 1024 |
![]() | |
typedef boost::intrusive_ptr < TcpSession > | TcpSessionPtr |
typedef boost::asio::strand < boost::asio::io_context::executor_type > | Strand |
![]() | |
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_ |
![]() | |
static int | ovsdb_io_task_id_ = -1 |
Definition at line 23 of file ovsdb_client_ssl.h.
OvsdbClientSslSession::OvsdbClientSslSession | ( | Agent * | agent, |
OvsPeerManager * | manager, | ||
OvsdbClientSsl * | server, | ||
SslSocket * | sock, | ||
bool | async_ready = true |
||
) |
OvsdbClientSslSession::~OvsdbClientSslSession | ( | ) |
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 213 of file ovsdb_client_ssl.cc.
|
private |
void OvsdbClientSslSession::EnqueueEvent | ( | TcpSession::Event | event | ) |
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 203 of file ovsdb_client_ssl.cc.
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 218 of file ovsdb_client_ssl.cc.
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 228 of file ovsdb_client_ssl.cc.
|
protectedvirtual |
Implements TcpSession.
Definition at line 188 of file ovsdb_client_ssl.cc.
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 209 of file ovsdb_client_ssl.cc.
bool OvsdbClientSslSession::ProcessSessionEvent | ( | OvsdbSessionEvent | event | ) |
|
inlineprotectedvirtual |
Reimplemented from TcpSession.
Definition at line 74 of file ovsdb_client_ssl.h.
bool OvsdbClientSslSession::RecvMsg | ( | const u_int8_t * | buf, |
std::size_t | len | ||
) |
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 242 of file ovsdb_client_ssl.cc.
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 246 of file ovsdb_client_ssl.cc.
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 192 of file ovsdb_client_ssl.cc.
|
inline |
|
inlinevirtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 51 of file ovsdb_client_ssl.h.
|
inlinevirtual |
Reimplemented from OVSDB::OvsdbClientSession.
Definition at line 42 of file ovsdb_client_ssl.h.
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 233 of file ovsdb_client_ssl.cc.
|
virtual |
Implements OVSDB::OvsdbClientSession.
Definition at line 223 of file ovsdb_client_ssl.cc.
|
friend |
Definition at line 79 of file ovsdb_client_ssl.h.
|
private |
Definition at line 81 of file ovsdb_client_ssl.h.
|
private |
Definition at line 82 of file ovsdb_client_ssl.h.
|
private |
Definition at line 80 of file ovsdb_client_ssl.h.