#include <xmpp_state_machine.h>

Inheritance diagram for XmppStateMachine:

Collaboration diagram for XmppStateMachine:

[legend]

Public Member Functions
	XmppStateMachine (XmppConnection *connection, bool active, bool auth_enabled=false, int config_hold_time=kHoldTime)

	~XmppStateMachine ()

void	Initialize ()

void	Clear ()

void	SetAdminState (bool down)

void	OnStart (const xmsm::EvStart &event)

virtual void	StartConnectTimer (int seconds)

void	CancelConnectTimer ()

virtual void	StartOpenTimer (int seconds)

void	CancelOpenTimer ()

int	GetConfiguredHoldTime () const

virtual void	StartHoldTimer ()

void	CancelHoldTimer ()

void	ResetSession ()

bool	IsAuthEnabled ()

void	TimerErrorHandler (std::string name, std::string error)

virtual void	OnSessionEvent (TcpSession *session, TcpSession::Event event)

bool	PassiveOpen (XmppSession *session)

void	OnMessage (XmppSession session, const XmppStanza::XmppMessage msg)

void	ProcessMessage (XmppSession session, const XmppStanza::XmppMessage msg)

void	OnEvent (SslSession *session, xmsm::SslHandShakeResponse)

void	AssignSession ()

int	GetConnectTime () const

void	SetHandShakeCbHandler (SslHandShakeCallbackHandler cb)

SslHandShakeCallbackHandler	HandShakeCbHandler ()

std::string	StateName () const

std::string	LastStateName () const

std::string	LastStateChangeAt () const

xmsm::XmState	StateType () const

xmsm::XmOpenConfirmState	OpenConfirmStateType () const

XmppConnection *	connection ()

void	set_connection (const XmppConnection *connection)

void	SwapXmppConnection (XmppStateMachine *other)

bool	IsActiveChannel ()

bool	logUVE ()

const char *	ChannelType ()

void	set_session (TcpSession *session)

void	clear_session ()

void	DeleteSession (XmppSession *session)

XmppSession *	session ()

void	RemoveSession ()

void	set_state (xmsm::XmState state)

xmsm::XmState	get_state ()

void	set_openconfirm_state (xmsm::XmOpenConfirmState state)

xmsm::XmOpenConfirmState	get_openconfirm_state ()

void	connect_attempts_inc ()

void	connect_attempts_clear ()

int	get_connect_attempts () const

void	keepalive_count_inc ()

void	keepalive_count_clear ()

int	get_keepalive_count () const

int	hold_time () const

virtual int	hold_time_msecs () const

void	set_hold_time (int hold_time)

void	unconsumed_event (const sc::event_base &event)

void	SendConnectionInfo (const std::string &event, const std::string &nextstate="")

void	SendConnectionInfo (XmppConnectionInfo *info, const std::string &event, const std::string &nextstate="")

void	ResurrectOldConnection (XmppConnection connection, XmppSession session)

void	set_last_event (const std::string &event)

void	update_last_event (const std::string &event)

const std::string	last_event () const

bool	ConnectTimerCancelled ()

bool	OpenTimerCancelled ()

bool	HoldTimerCancelled ()

void	AssertOnHoldTimeout ()

bool	HoldTimerExpired ()

const Timer *	hold_timer () const

Static Public Attributes
static const int	kOpenTime = 15

static const int	kConnectInterval = 30

static const int	kHoldTime = 90

static const int	kMaxAttempts = 4

static const int	kJitter = 10

Private Member Functions
bool	ConnectTimerExpired ()

bool	OpenTimerExpired ()

bool	Enqueue (const sc::event_base &ev)

bool	DequeueEvent (boost::intrusive_ptr< const sc::event_base > event)

void	ProcessEvent (const sc::event_base &event)

void	ProcessStreamHeaderMessage (XmppSession session, const XmppStanza::XmppMessage msg)

	DISALLOW_COPY_AND_ASSIGN (XmppStateMachine)

Private Attributes
WorkQueue< boost::intrusive_ptr< const sc::event_base > >	work_queue_

XmppConnection *	connection_

XmppSession *	session_

TcpServer *	server_

Timer *	connect_timer_

Timer *	open_timer_

Timer *	hold_timer_

int	config_hold_time_

int	hold_time_

uint32_t	attempts_

uint32_t	keepalive_count_

bool	deleted_

bool	in_dequeue_

bool	is_active_

bool	auth_enabled_

xmsm::XmState	state_

xmsm::XmState	last_state_

xmsm::XmOpenConfirmState	openconfirm_state_

uint64_t	state_since_

std::string	last_event_

uint64_t	last_event_at_

SslHandShakeCallbackHandler	handshake_cb_

tbb::mutex	mutex_

Friends
class	XmppStateMachineTest

Detailed Description

Definition at line 60 of file xmpp_state_machine.h.

Constructor & Destructor Documentation

◆ XmppStateMachine()

XmppStateMachine::XmppStateMachine	(	XmppConnection *	connection,
		bool	active,
		bool	auth_enabled = `false`,
		int	config_hold_time = `kHoldTime`
	)

Definition at line 1088 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ ~XmppStateMachine()

XmppStateMachine::~XmppStateMachine ( )

Definition at line 1126 of file xmpp_state_machine.cc.

Here is the call graph for this function:

Member Function Documentation

◆ AssertOnHoldTimeout()

void XmppStateMachine::AssertOnHoldTimeout ( )

Definition at line 1047 of file xmpp_state_machine.cc.

◆ AssignSession()

void XmppStateMachine::AssignSession ( )

Definition at line 1586 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ CancelConnectTimer()

void XmppStateMachine::CancelConnectTimer ( )

Definition at line 1194 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ CancelHoldTimer()

void XmppStateMachine::CancelHoldTimer ( )

Definition at line 1244 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ CancelOpenTimer()

void XmppStateMachine::CancelOpenTimer ( )

Definition at line 1205 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ ChannelType()

const char * XmppStateMachine::ChannelType ( )

Definition at line 1605 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ Clear()

void XmppStateMachine::Clear ( )

Definition at line 1507 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ clear_session()

void XmppStateMachine::clear_session ( )

Definition at line 1150 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ connect_attempts_clear()

void XmppStateMachine::connect_attempts_clear ( )

inline

Definition at line 150 of file xmpp_state_machine.h.

◆ connect_attempts_inc()

void XmppStateMachine::connect_attempts_inc ( )

inline

Definition at line 149 of file xmpp_state_machine.h.

◆ connection()

XmppConnection* XmppStateMachine::connection ( )

inline

Definition at line 129 of file xmpp_state_machine.h.

◆ ConnectTimerCancelled()

bool XmppStateMachine::ConnectTimerCancelled ( )

inline

Definition at line 184 of file xmpp_state_machine.h.

Here is the call graph for this function:

◆ ConnectTimerExpired()

bool XmppStateMachine::ConnectTimerExpired ( )

private

Definition at line 1251 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ DeleteSession()

void XmppStateMachine::DeleteSession ( XmppSession * session )

Definition at line 1160 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ DequeueEvent()

bool XmppStateMachine::DequeueEvent ( boost::intrusive_ptr< const sc::event_base > event )

private

Definition at line 1609 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

XmppStateMachine::DISALLOW_COPY_AND_ASSIGN ( XmppStateMachine )

private

◆ Enqueue()

bool XmppStateMachine::Enqueue ( const sc::event_base & ev )

private

Definition at line 1683 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ get_connect_attempts()

int XmppStateMachine::get_connect_attempts ( ) const

inline

Definition at line 151 of file xmpp_state_machine.h.

◆ get_keepalive_count()

int XmppStateMachine::get_keepalive_count ( ) const

inline

Definition at line 155 of file xmpp_state_machine.h.

◆ get_openconfirm_state()

xmsm::XmOpenConfirmState XmppStateMachine::get_openconfirm_state ( )

inline

Definition at line 145 of file xmpp_state_machine.h.

◆ get_state()

xmsm::XmState XmppStateMachine::get_state ( )

inline

Definition at line 143 of file xmpp_state_machine.h.

◆ GetConfiguredHoldTime()

int XmppStateMachine::GetConfiguredHoldTime ( ) const

Definition at line 1209 of file xmpp_state_machine.cc.

◆ GetConnectTime()

int XmppStateMachine::GetConnectTime ( ) const

Definition at line 1592 of file xmpp_state_machine.cc.

◆ HandShakeCbHandler()

SslHandShakeCallbackHandler XmppStateMachine::HandShakeCbHandler ( )

inline

Definition at line 120 of file xmpp_state_machine.h.

◆ hold_time()

int XmppStateMachine::hold_time ( ) const

inline

Definition at line 157 of file xmpp_state_machine.h.

◆ hold_time_msecs()

virtual int XmppStateMachine::hold_time_msecs ( ) const

inlinevirtual

Definition at line 158 of file xmpp_state_machine.h.

◆ hold_timer()

const Timer* XmppStateMachine::hold_timer ( ) const

inline

Definition at line 189 of file xmpp_state_machine.h.

◆ HoldTimerCancelled()

bool XmppStateMachine::HoldTimerCancelled ( )

inline

Definition at line 186 of file xmpp_state_machine.h.

Here is the call graph for this function:

◆ HoldTimerExpired()

bool XmppStateMachine::HoldTimerExpired ( )

Definition at line 1270 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ Initialize()

void XmppStateMachine::Initialize ( )

Definition at line 1144 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ IsActiveChannel()

bool XmppStateMachine::IsActiveChannel ( )

Definition at line 1597 of file xmpp_state_machine.cc.

◆ IsAuthEnabled()

bool XmppStateMachine::IsAuthEnabled ( )

inline

Definition at line 89 of file xmpp_state_machine.h.

◆ keepalive_count_clear()

void XmppStateMachine::keepalive_count_clear ( )

inline

Definition at line 154 of file xmpp_state_machine.h.

◆ keepalive_count_inc()

void XmppStateMachine::keepalive_count_inc ( )

inline

Definition at line 153 of file xmpp_state_machine.h.

◆ last_event()

const std::string XmppStateMachine::last_event ( ) const

inline

Definition at line 179 of file xmpp_state_machine.h.

◆ LastStateChangeAt()

string XmppStateMachine::LastStateChangeAt ( ) const

Definition at line 1574 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ LastStateName()

string XmppStateMachine::LastStateName ( ) const

Definition at line 1570 of file xmpp_state_machine.cc.

◆ logUVE()

bool XmppStateMachine::logUVE ( )

Definition at line 1601 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ OnEvent()

void XmppStateMachine::OnEvent	(	SslSession *	session,
		xmsm::SslHandShakeResponse	resp
	)

Definition at line 1520 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ OnMessage()

void XmppStateMachine::OnMessage	(	XmppSession *	session,
		const XmppStanza::XmppMessage *	msg
	)

Definition at line 1443 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ OnSessionEvent()

void XmppStateMachine::OnSessionEvent	(	TcpSession *	session,
		TcpSession::Event	event
	)

virtual

Definition at line 1286 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ OnStart()

void XmppStateMachine::OnStart ( const xmsm::EvStart & event )

Definition at line 1248 of file xmpp_state_machine.cc.

◆ OpenConfirmStateType()

xmsm::XmOpenConfirmState XmppStateMachine::OpenConfirmStateType ( ) const

Definition at line 1582 of file xmpp_state_machine.cc.

◆ OpenTimerCancelled()

bool XmppStateMachine::OpenTimerCancelled ( )

inline

Definition at line 185 of file xmpp_state_machine.h.

Here is the call graph for this function:

◆ OpenTimerExpired()

bool XmppStateMachine::OpenTimerExpired ( )

private

Definition at line 1259 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ PassiveOpen()

bool XmppStateMachine::PassiveOpen ( XmppSession * session )

Definition at line 1321 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ ProcessEvent()

void XmppStateMachine::ProcessEvent ( const sc::event_base & event )

private

Definition at line 1623 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ ProcessMessage()

void XmppStateMachine::ProcessMessage	(	XmppSession *	session,
		const XmppStanza::XmppMessage *	msg
	)

Definition at line 1449 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ ProcessStreamHeaderMessage()

void XmppStateMachine::ProcessStreamHeaderMessage	(	XmppSession *	session,
		const XmppStanza::XmppMessage *	msg
	)

private

Definition at line 1333 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ RemoveSession()

void XmppStateMachine::RemoveSession ( )

inline

Definition at line 141 of file xmpp_state_machine.h.

◆ ResetSession()

void XmppStateMachine::ResetSession ( )

Definition at line 1068 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ ResurrectOldConnection()

void XmppStateMachine::ResurrectOldConnection	(	XmppConnection *	connection,
		XmppSession *	session
	)

Definition at line 1727 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ SendConnectionInfo() [1/2]

void XmppStateMachine::SendConnectionInfo	(	const std::string &	event,
		const std::string &	nextstate = `""`
	)

◆ SendConnectionInfo() [2/2]

void XmppStateMachine::SendConnectionInfo	(	XmppConnectionInfo *	info,
		const std::string &	event,
		const std::string &	nextstate = `""`
	)

◆ session()

XmppSession* XmppStateMachine::session ( )

inline

Definition at line 140 of file xmpp_state_machine.h.

◆ set_connection()

void XmppStateMachine::set_connection ( const XmppConnection * connection )

inline

Definition at line 130 of file xmpp_state_machine.h.

Here is the call graph for this function:

◆ set_hold_time()

void XmppStateMachine::set_hold_time ( int hold_time )

inline

Definition at line 159 of file xmpp_state_machine.h.

Here is the call graph for this function:

◆ set_last_event()

void XmppStateMachine::set_last_event ( const std::string & event )

inline

Definition at line 171 of file xmpp_state_machine.h.

Here is the call graph for this function:

◆ set_openconfirm_state()

void XmppStateMachine::set_openconfirm_state ( xmsm::XmOpenConfirmState state )

Definition at line 1554 of file xmpp_state_machine.cc.

◆ set_session()

void XmppStateMachine::set_session ( TcpSession * session )

Definition at line 1171 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ set_state()

void XmppStateMachine::set_state ( xmsm::XmState state )

Definition at line 1535 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ SetAdminState()

void XmppStateMachine::SetAdminState ( bool down )

Definition at line 1511 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ SetHandShakeCbHandler()

void XmppStateMachine::SetHandShakeCbHandler ( SslHandShakeCallbackHandler cb )

inline

Definition at line 116 of file xmpp_state_machine.h.

◆ StartConnectTimer()

void XmppStateMachine::StartConnectTimer ( int seconds )

virtual

Definition at line 1182 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ StartHoldTimer()

void XmppStateMachine::StartHoldTimer ( )

virtual

Definition at line 1233 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ StartOpenTimer()

void XmppStateMachine::StartOpenTimer ( int seconds )

virtual

Definition at line 1198 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ StateName()

string XmppStateMachine::StateName ( ) const

Definition at line 1566 of file xmpp_state_machine.cc.

◆ StateType()

xmsm::XmState XmppStateMachine::StateType ( ) const

Definition at line 1578 of file xmpp_state_machine.cc.

◆ SwapXmppConnection()

void XmppStateMachine::SwapXmppConnection ( XmppStateMachine * other )

Definition at line 1776 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ TimerErrorHandler()

void XmppStateMachine::TimerErrorHandler	(	std::string	name,
		std::string	error
	)

Definition at line 1179 of file xmpp_state_machine.cc.

◆ unconsumed_event()

void XmppStateMachine::unconsumed_event ( const sc::event_base & event )

Definition at line 1647 of file xmpp_state_machine.cc.

Here is the call graph for this function:

◆ update_last_event()

void XmppStateMachine::update_last_event ( const std::string & event )

Definition at line 1652 of file xmpp_state_machine.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ XmppStateMachineTest

friend class XmppStateMachineTest

friend

Definition at line 192 of file xmpp_state_machine.h.

Member Data Documentation

◆ attempts_

uint32_t XmppStateMachine::attempts_

private

Definition at line 211 of file xmpp_state_machine.h.

◆ auth_enabled_

bool XmppStateMachine::auth_enabled_

private

Definition at line 216 of file xmpp_state_machine.h.

◆ config_hold_time_

int XmppStateMachine::config_hold_time_

private

Definition at line 209 of file xmpp_state_machine.h.

◆ connect_timer_

Timer* XmppStateMachine::connect_timer_

private

Definition at line 206 of file xmpp_state_machine.h.

◆ connection_

XmppConnection* XmppStateMachine::connection_

private

Definition at line 203 of file xmpp_state_machine.h.

◆ deleted_

bool XmppStateMachine::deleted_

private

Definition at line 213 of file xmpp_state_machine.h.

◆ handshake_cb_

SslHandShakeCallbackHandler XmppStateMachine::handshake_cb_

private

Definition at line 223 of file xmpp_state_machine.h.

◆ hold_time_

int XmppStateMachine::hold_time_

private

Definition at line 210 of file xmpp_state_machine.h.

◆ hold_timer_

Timer* XmppStateMachine::hold_timer_

private

Definition at line 208 of file xmpp_state_machine.h.

◆ in_dequeue_

bool XmppStateMachine::in_dequeue_

private

Definition at line 214 of file xmpp_state_machine.h.

◆ is_active_

bool XmppStateMachine::is_active_

private

Definition at line 215 of file xmpp_state_machine.h.

◆ kConnectInterval

const int XmppStateMachine::kConnectInterval = 30

static

Definition at line 64 of file xmpp_state_machine.h.

◆ keepalive_count_

uint32_t XmppStateMachine::keepalive_count_

private

Definition at line 212 of file xmpp_state_machine.h.

◆ kHoldTime

const int XmppStateMachine::kHoldTime = 90

static

Definition at line 65 of file xmpp_state_machine.h.

◆ kJitter

const int XmppStateMachine::kJitter = 10

static

Definition at line 67 of file xmpp_state_machine.h.

◆ kMaxAttempts

const int XmppStateMachine::kMaxAttempts = 4

static

Definition at line 66 of file xmpp_state_machine.h.

◆ kOpenTime

const int XmppStateMachine::kOpenTime = 15

static

Definition at line 63 of file xmpp_state_machine.h.

◆ last_event_

std::string XmppStateMachine::last_event_

private

Definition at line 221 of file xmpp_state_machine.h.

◆ last_event_at_

uint64_t XmppStateMachine::last_event_at_

private

Definition at line 222 of file xmpp_state_machine.h.

◆ last_state_

xmsm::XmState XmppStateMachine::last_state_

private

Definition at line 218 of file xmpp_state_machine.h.

◆ mutex_

tbb::mutex XmppStateMachine::mutex_

mutableprivate

Definition at line 224 of file xmpp_state_machine.h.

◆ open_timer_

Timer* XmppStateMachine::open_timer_

private

Definition at line 207 of file xmpp_state_machine.h.

◆ openconfirm_state_

xmsm::XmOpenConfirmState XmppStateMachine::openconfirm_state_

private

Definition at line 219 of file xmpp_state_machine.h.

◆ server_

TcpServer* XmppStateMachine::server_

private

Definition at line 205 of file xmpp_state_machine.h.

◆ session_

XmppSession* XmppStateMachine::session_

private

Definition at line 204 of file xmpp_state_machine.h.

◆ state_

xmsm::XmState XmppStateMachine::state_

private

Definition at line 217 of file xmpp_state_machine.h.

◆ state_since_

uint64_t XmppStateMachine::state_since_

private

Definition at line 220 of file xmpp_state_machine.h.

◆ work_queue_

WorkQueue<boost::intrusive_ptr<const sc::event_base> > XmppStateMachine::work_queue_

private

Definition at line 202 of file xmpp_state_machine.h.

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

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ XmppStateMachine()

◆ ~XmppStateMachine()

Member Function Documentation

◆ AssertOnHoldTimeout()

◆ AssignSession()

◆ CancelConnectTimer()

◆ CancelHoldTimer()

◆ CancelOpenTimer()

◆ ChannelType()

◆ Clear()

◆ clear_session()

◆ connect_attempts_clear()

◆ connect_attempts_inc()

◆ connection()

◆ ConnectTimerCancelled()

◆ ConnectTimerExpired()

◆ DeleteSession()

◆ DequeueEvent()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ Enqueue()

◆ get_connect_attempts()

◆ get_keepalive_count()

◆ get_openconfirm_state()

◆ get_state()

◆ GetConfiguredHoldTime()

◆ GetConnectTime()

◆ HandShakeCbHandler()

◆ hold_time()

◆ hold_time_msecs()

◆ hold_timer()

◆ HoldTimerCancelled()

◆ HoldTimerExpired()

◆ Initialize()

◆ IsActiveChannel()

◆ IsAuthEnabled()

◆ keepalive_count_clear()

◆ keepalive_count_inc()

◆ last_event()

◆ LastStateChangeAt()

◆ LastStateName()

◆ logUVE()

◆ OnEvent()

◆ OnMessage()

◆ OnSessionEvent()

◆ OnStart()

◆ OpenConfirmStateType()

◆ OpenTimerCancelled()

◆ OpenTimerExpired()

◆ PassiveOpen()

◆ ProcessEvent()

◆ ProcessMessage()

◆ ProcessStreamHeaderMessage()

◆ RemoveSession()

◆ ResetSession()

◆ ResurrectOldConnection()

◆ SendConnectionInfo() [1/2]

◆ SendConnectionInfo() [2/2]

◆ session()

◆ set_connection()

◆ set_hold_time()

◆ set_last_event()

◆ set_openconfirm_state()

◆ set_session()

◆ set_state()

◆ SetAdminState()

◆ SetHandShakeCbHandler()

◆ StartConnectTimer()

◆ StartHoldTimer()

◆ StartOpenTimer()

◆ StateName()

◆ StateType()

◆ SwapXmppConnection()

◆ TimerErrorHandler()