#include <ovsdb_client_ssl.h>

Inheritance diagram for OVSDB::OvsdbClientSslSession:

[legend]

Collaboration diagram for OVSDB::OvsdbClientSslSession:

[legend]

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)

Public Member Functions inherited from OVSDB::OvsdbClientSession
	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 ()

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)

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

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)

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
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 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)

Static Public Attributes inherited from TcpSession
static const int	kDefaultBufferSize = 16 * 1024

static const int	kDefaultWriteBufferSize = 32 * 1024

Protected Types inherited from TcpSession
typedef boost::intrusive_ptr< TcpSession >	TcpSessionPtr

typedef boost::asio::strand< boost::asio::io_context::executor_type >	Strand

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_

Static Protected Attributes inherited from OVSDB::OvsdbClientSession
static int	ovsdb_io_task_id_ = -1

Detailed Description

Definition at line 23 of file ovsdb_client_ssl.h.

Constructor & Destructor Documentation

◆ OvsdbClientSslSession()

OvsdbClientSslSession::OvsdbClientSslSession	(	Agent *	agent,
		OvsPeerManager *	manager,
		OvsdbClientSsl *	server,
		SslSocket *	sock,
		bool	async_ready = `true`
	)

Definition at line 167 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ ~OvsdbClientSslSession()

OvsdbClientSslSession::~OvsdbClientSslSession ( )

Definition at line 182 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

Member Function Documentation

◆ connection_table()

ConnectionStateTable * OvsdbClientSslSession::connection_table ( )

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 213 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

OVSDB::OvsdbClientSslSession::DISALLOW_COPY_AND_ASSIGN ( OvsdbClientSslSession )

private

◆ EnqueueEvent()

void OvsdbClientSslSession::EnqueueEvent ( TcpSession::Event event )

Definition at line 287 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ keepalive_interval()

int OvsdbClientSslSession::keepalive_interval ( )

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 203 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ ksync_obj_manager()

KSyncObjectManager * OvsdbClientSslSession::ksync_obj_manager ( )

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 218 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ OnCleanup()

void OvsdbClientSslSession::OnCleanup ( )

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 228 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ OnRead()

void OvsdbClientSslSession::OnRead ( Buffer buffer )

protectedvirtual

Implements TcpSession.

Definition at line 188 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ ovsdb_close_reason()

const boost::system::error_code & OvsdbClientSslSession::ovsdb_close_reason ( ) const

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 209 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ ProcessSessionEvent()

bool OvsdbClientSslSession::ProcessSessionEvent ( OvsdbSessionEvent event )

Definition at line 250 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ reader_task_id()

virtual int OVSDB::OvsdbClientSslSession::reader_task_id ( ) const

inlineprotectedvirtual

Reimplemented from TcpSession.

Definition at line 74 of file ovsdb_client_ssl.h.

◆ RecvMsg()

bool OvsdbClientSslSession::RecvMsg	(	const u_int8_t *	buf,
		std::size_t	len
	)

Definition at line 197 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ remote_ip()

Ip4Address OvsdbClientSslSession::remote_ip ( ) const

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 242 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ remote_port()

uint16_t OvsdbClientSslSession::remote_port ( ) const

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 246 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ SendMsg()

void OvsdbClientSslSession::SendMsg	(	u_int8_t *	buf,
		std::size_t	len
	)

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 192 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ set_status()

void OVSDB::OvsdbClientSslSession::set_status ( std::string status )

inline

Definition at line 50 of file ovsdb_client_ssl.h.

Here is the call graph for this function:

◆ status()

std::string OVSDB::OvsdbClientSslSession::status ( )

inlinevirtual

Implements OVSDB::OvsdbClientSession.

Definition at line 51 of file ovsdb_client_ssl.h.

◆ ThrottleInFlightTxnMessages()

bool OVSDB::OvsdbClientSslSession::ThrottleInFlightTxnMessages ( )

inlinevirtual

Reimplemented from OVSDB::OvsdbClientSession.

Definition at line 42 of file ovsdb_client_ssl.h.

◆ TriggerClose()

void OvsdbClientSslSession::TriggerClose ( )

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 233 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

◆ tsn_ip()

Ip4Address OvsdbClientSslSession::tsn_ip ( )

virtual

Implements OVSDB::OvsdbClientSession.

Definition at line 223 of file ovsdb_client_ssl.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ OvsdbClientSsl

friend class OvsdbClientSsl

friend

Definition at line 79 of file ovsdb_client_ssl.h.

Member Data Documentation

◆ reader_

OvsdbClientTcpSessionReader* OVSDB::OvsdbClientSslSession::reader_

private

Definition at line 81 of file ovsdb_client_ssl.h.

◆ session_event_queue_

WorkQueue<OvsdbSessionEvent>* OVSDB::OvsdbClientSslSession::session_event_queue_

private

Definition at line 82 of file ovsdb_client_ssl.h.

◆ status_

std::string OVSDB::OvsdbClientSslSession::status_

private

Definition at line 80 of file ovsdb_client_ssl.h.

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

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ OvsdbClientSslSession()

◆ ~OvsdbClientSslSession()

Member Function Documentation

◆ connection_table()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ EnqueueEvent()

◆ keepalive_interval()

◆ ksync_obj_manager()

◆ OnCleanup()

◆ OnRead()

◆ ovsdb_close_reason()

◆ ProcessSessionEvent()

◆ reader_task_id()

◆ RecvMsg()

◆ remote_ip()

◆ remote_port()

◆ SendMsg()

◆ set_status()

◆ status()

◆ ThrottleInFlightTxnMessages()

◆ TriggerClose()

◆ tsn_ip()

Friends And Related Function Documentation

◆ OvsdbClientSsl

Member Data Documentation

◆ reader_

◆ session_event_queue_

◆ status_