#include <xmpp_client.h>

Inheritance diagram for XmppClient:

[legend]

Collaboration diagram for XmppClient:

[legend]

Classes
class	DeleteActor

Public Types
typedef boost::asio::ip::tcp::endpoint	Endpoint

typedef boost::function< void(XmppChannelMux *, xmps::PeerState)>	ConnectionEventCb

Public Types inherited from SslServer
typedef boost::asio::ssl::stream< boost::asio::ip::tcp::socket >	SslSocket

Public Types inherited from TcpServer
typedef boost::asio::ip::tcp::endpoint	Endpoint

typedef boost::asio::ip::tcp::socket	Socket

typedef boost::asio::ip::tcp::socket::native_handle_type	NativeSocketType

Public Member Functions
	XmppClient (EventManager *evm)

	XmppClient (EventManager evm, const XmppChannelConfig config)

virtual	~XmppClient ()

void	Shutdown ()

void	RegisterConnectionEvent (xmps::PeerId, ConnectionEventCb)

void	UnRegisterConnectionEvent (xmps::PeerId)

void	NotifyConnectionEvent (XmppChannelMux *, xmps::PeerState)

size_t	ConnectionEventCount () const

virtual TcpSession *	CreateSession ()

virtual bool	Initialize (short port)

XmppClientConnection *	CreateConnection (const XmppChannelConfig *config)

XmppClientConnection *	FindConnection (const std::string &address)

void	InsertConnection (XmppClientConnection *connection)

void	RemoveConnection (XmppClientConnection *connection)

size_t	ConnectionCount () const

XmppChannel *	FindChannel (const std::string &address)

void	ConfigUpdate (const XmppConfigData *cfg)

XmppConfigManager *	xmpp_config_mgr ()

LifetimeManager *	lifetime_manager ()

virtual LifetimeActor *	deleter ()

int	SetDscpValue (uint8_t value, const char *conn_id)

uint32_t	XmppTimeOut (const char *conn_id)

void	UpdateTimeOut (uint8_t time_out, const char *conn_id)

Public Member Functions inherited from XmppConnectionManager
	XmppConnectionManager (EventManager *evm, boost::asio::ssl::context::method m, bool ssl_enabled, bool ssl_handshake_delayed)

void	Shutdown ()

void	EnqueueSession (XmppSession *session)

size_t	GetSessionQueueSize () const

tbb::mutex &	mutex () const

Public Member Functions inherited from SslServer
	SslServer (EventManager *evm, boost::asio::ssl::context::method m, bool ssl_enabled=true, bool ssl_handshake_delayed=false)

virtual	~SslServer ()

Public Member Functions inherited from TcpServer
	TcpServer (EventManager *evm)

virtual	~TcpServer ()

virtual bool	Initialize (unsigned short port)

virtual bool	Initialize (unsigned short port, const IpAddress &host_ip, int intf_id=-1)

bool	InitializeInternal (boost::asio::ip::tcp::endpoint localaddr)

const std::string	ToString () const

void	SetAcceptor ()

void	ResetAcceptor ()

void	Shutdown ()

void	ClearSessions ()

void	UpdateSessionsDscp (uint8_t dscp)

virtual void	DeleteSession (TcpSession *session)

virtual void	Connect (TcpSession *session, Endpoint remote)

virtual bool	DisableSandeshLogMessages () const

int	GetPort () const

const io::SocketStats &	GetSocketStats () const

size_t	GetSessionCount () const

EventManager *	event_manager ()

bool	HasSessionReadAvailable () const

bool	HasSessions () const

TcpSession *	GetSession (Endpoint remote)

void	WaitForEmpty ()

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 (NativeSocketType fd, uint32_t peer_ip, const std::string &md5_password)

int	SetListenSocketMd5Option (uint32_t peer_ip, const std::string &md5_password)

int	SetDscpSocketOption (NativeSocketType fd, uint8_t value)

uint8_t	GetDscpValue (NativeSocketType fd) const

int	SetListenSocketDscp (uint8_t value)

int	SetSocketOptions (const SandeshConfig &sandesh_config)

int	SetKeepAliveSocketOption (int fd, const SandeshConfig &sandesh_config)

Protected Member Functions
virtual SslSession *	AllocSession (SslSocket *socket)

Protected Member Functions inherited from SslServer
boost::asio::ssl::context *	context ()

Protected Member Functions inherited from TcpServer
virtual bool	AcceptSession (TcpSession *session)

void	set_socket_open_failure (bool flag)

bool	socket_open_failure () const

Endpoint	LocalEndpoint () const

Private Types
typedef std::map< Endpoint, XmppClientConnection * >	ConnectionMap

typedef std::map< xmps::PeerId, ConnectionEventCb >	ConnectionEventCbMap

Private Member Functions
void	ProcessConfigUpdate (XmppConfigManager::DiffType delta, const XmppChannelConfig current, const XmppChannelConfig future)

	DISALLOW_COPY_AND_ASSIGN (XmppClient)

Private Attributes
ConnectionMap	connection_map_

ConnectionEventCbMap	connection_event_map_

tbb::mutex	connection_event_map_mutex_

boost::scoped_ptr< XmppConfigManager >	config_mgr_

boost::scoped_ptr< LifetimeManager >	lifetime_manager_

boost::scoped_ptr< DeleteActor >	deleter_

bool	auth_enabled_

int	tcp_hold_time_

Friends
class	XmppSessionTest

class	XmppStreamMessageTest

class	DeleteActor

Additional Inherited Members
Protected Types inherited from TcpServer
typedef boost::intrusive_ptr< TcpServer >	TcpServerPtr

typedef boost::intrusive_ptr< TcpSession >	TcpSessionPtr

Detailed Description

Definition at line 22 of file xmpp_client.h.

Member Typedef Documentation

◆ ConnectionEventCb

typedef boost::function<void(XmppChannelMux *, xmps::PeerState)> XmppClient::ConnectionEventCb

Definition at line 33 of file xmpp_client.h.

◆ ConnectionEventCbMap

typedef std::map<xmps::PeerId, ConnectionEventCb> XmppClient::ConnectionEventCbMap

private

Definition at line 68 of file xmpp_client.h.

◆ ConnectionMap

typedef std::map<Endpoint, XmppClientConnection *> XmppClient::ConnectionMap

private

Definition at line 67 of file xmpp_client.h.

◆ Endpoint

typedef boost::asio::ip::tcp::endpoint XmppClient::Endpoint

Definition at line 24 of file xmpp_client.h.

Constructor & Destructor Documentation

◆ XmppClient() [1/2]

XmppClient::XmppClient ( EventManager * evm )

explicit

Definition at line 42 of file xmpp_client.cc.

◆ XmppClient() [2/2]

XmppClient::XmppClient	(	EventManager *	evm,
		const XmppChannelConfig *	config
	)

Definition at line 52 of file xmpp_client.cc.

Here is the call graph for this function:

◆ ~XmppClient()

XmppClient::~XmppClient ( )

virtual

Definition at line 119 of file xmpp_client.cc.

Member Function Documentation

◆ AllocSession()

SslSession * XmppClient::AllocSession ( SslSocket * socket )

protectedvirtual

Implements SslServer.

Definition at line 226 of file xmpp_client.cc.

◆ ConfigUpdate()

void XmppClient::ConfigUpdate ( const XmppConfigData * cfg )

Definition at line 188 of file xmpp_client.cc.

Here is the call graph for this function:

◆ ConnectionCount()

size_t XmppClient::ConnectionCount ( ) const

Definition at line 222 of file xmpp_client.cc.

◆ ConnectionEventCount()

size_t XmppClient::ConnectionEventCount ( ) const

Definition at line 218 of file xmpp_client.cc.

◆ CreateConnection()

XmppClientConnection * XmppClient::CreateConnection ( const XmppChannelConfig * config )

Definition at line 239 of file xmpp_client.cc.

Here is the call graph for this function:

◆ CreateSession()

TcpSession * XmppClient::CreateSession ( )

virtual

Reimplemented from TcpServer.

Definition at line 135 of file xmpp_client.cc.

Here is the call graph for this function:

◆ deleter()

LifetimeActor * XmppClient::deleter ( )

virtual

Implements XmppConnectionManager.

Definition at line 127 of file xmpp_client.cc.

◆ DISALLOW_COPY_AND_ASSIGN()

XmppClient::DISALLOW_COPY_AND_ASSIGN ( XmppClient )

private

◆ FindChannel()

XmppChannel * XmppClient::FindChannel ( const std::string & address )

Definition at line 269 of file xmpp_client.cc.

Here is the call graph for this function:

◆ FindConnection()

XmppClientConnection * XmppClient::FindConnection ( const std::string & address )

Definition at line 231 of file xmpp_client.cc.

◆ Initialize()

bool XmppClient::Initialize ( short port )

virtual

Definition at line 122 of file xmpp_client.cc.

Here is the call graph for this function:

◆ InsertConnection()

void XmppClient::InsertConnection ( XmppClientConnection * connection )

Definition at line 252 of file xmpp_client.cc.

Here is the call graph for this function:

◆ lifetime_manager()

LifetimeManager * XmppClient::lifetime_manager ( )

Definition at line 131 of file xmpp_client.cc.

◆ NotifyConnectionEvent()

void XmppClient::NotifyConnectionEvent	(	XmppChannelMux *	mux,
		xmps::PeerState	state
	)

Definition at line 208 of file xmpp_client.cc.

◆ ProcessConfigUpdate()

void XmppClient::ProcessConfigUpdate	(	XmppConfigManager::DiffType	delta,
		const XmppChannelConfig *	current,
		const XmppChannelConfig *	future
	)

private

Definition at line 173 of file xmpp_client.cc.

Here is the call graph for this function:

◆ RegisterConnectionEvent()

void XmppClient::RegisterConnectionEvent	(	xmps::PeerId	id,
		ConnectionEventCb	cb
	)

Definition at line 195 of file xmpp_client.cc.

◆ RemoveConnection()

void XmppClient::RemoveConnection ( XmppClientConnection * connection )

Definition at line 261 of file xmpp_client.cc.

Here is the call graph for this function:

◆ SetDscpValue()

int XmppClient::SetDscpValue	(	uint8_t	value,
		const char *	conn_id
	)

Definition at line 274 of file xmpp_client.cc.

Here is the call graph for this function:

◆ Shutdown()

void XmppClient::Shutdown ( void )

Definition at line 167 of file xmpp_client.cc.

Here is the call graph for this function:

◆ UnRegisterConnectionEvent()

void XmppClient::UnRegisterConnectionEvent ( xmps::PeerId id )

Definition at line 201 of file xmpp_client.cc.

◆ UpdateTimeOut()

void XmppClient::UpdateTimeOut	(	uint8_t	time_out,
		const char *	conn_id
	)

Definition at line 282 of file xmpp_client.cc.

Here is the call graph for this function:

◆ xmpp_config_mgr()

XmppConfigManager* XmppClient::xmpp_config_mgr ( )

inline

Definition at line 50 of file xmpp_client.h.

◆ XmppTimeOut()

uint32_t XmppClient::XmppTimeOut ( const char * conn_id )

Definition at line 289 of file xmpp_client.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ DeleteActor

friend class DeleteActor

friend

Definition at line 65 of file xmpp_client.h.

◆ XmppSessionTest

friend class XmppSessionTest

friend

Definition at line 63 of file xmpp_client.h.

◆ XmppStreamMessageTest

friend class XmppStreamMessageTest

friend

Definition at line 64 of file xmpp_client.h.

Member Data Documentation

◆ auth_enabled_

bool XmppClient::auth_enabled_

private

Definition at line 81 of file xmpp_client.h.

◆ config_mgr_

boost::scoped_ptr<XmppConfigManager> XmppClient::config_mgr_

private

Definition at line 77 of file xmpp_client.h.

◆ connection_event_map_

ConnectionEventCbMap XmppClient::connection_event_map_

private

Definition at line 74 of file xmpp_client.h.

◆ connection_event_map_mutex_

tbb::mutex XmppClient::connection_event_map_mutex_

private

Definition at line 75 of file xmpp_client.h.

◆ connection_map_

ConnectionMap XmppClient::connection_map_

private

Definition at line 73 of file xmpp_client.h.

◆ deleter_

boost::scoped_ptr<DeleteActor> XmppClient::deleter_

private

Definition at line 79 of file xmpp_client.h.

◆ lifetime_manager_

boost::scoped_ptr<LifetimeManager> XmppClient::lifetime_manager_

private

Definition at line 78 of file xmpp_client.h.

◆ tcp_hold_time_

int XmppClient::tcp_hold_time_

private

Definition at line 82 of file xmpp_client.h.

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

Classes

Public Types

Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ConnectionEventCb

◆ ConnectionEventCbMap

◆ ConnectionMap

◆ Endpoint

Constructor & Destructor Documentation

◆ XmppClient() [1/2]

◆ XmppClient() [2/2]

◆ ~XmppClient()

Member Function Documentation

◆ AllocSession()

◆ ConfigUpdate()

◆ ConnectionCount()

◆ ConnectionEventCount()

◆ CreateConnection()

◆ CreateSession()

◆ deleter()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ FindChannel()

◆ FindConnection()

◆ Initialize()

◆ InsertConnection()

◆ lifetime_manager()

◆ NotifyConnectionEvent()

◆ ProcessConfigUpdate()

◆ RegisterConnectionEvent()

◆ RemoveConnection()

◆ SetDscpValue()

◆ Shutdown()

◆ UnRegisterConnectionEvent()

◆ UpdateTimeOut()

◆ xmpp_config_mgr()

◆ XmppTimeOut()

Friends And Related Function Documentation

◆ DeleteActor

◆ XmppSessionTest

◆ XmppStreamMessageTest

Member Data Documentation

◆ auth_enabled_

◆ config_mgr_

◆ connection_event_map_

◆ connection_event_map_mutex_

◆ connection_map_

◆ deleter_

◆ lifetime_manager_

◆ tcp_hold_time_