#include <sandesh_state_machine.h>

Inheritance diagram for SandeshStateMachine:

Collaboration diagram for SandeshStateMachine:

[legend]

Classes
struct	EventContainer

Public Member Functions
	SandeshStateMachine (const char prefix, SandeshConnection connection)

	~SandeshStateMachine ()

void	Initialize ()

void	SetAdminState (bool down)

void	SetDeferDequeue (bool defer)

template<class Ev >
void	OnIdle (const Ev &event)

template<class Ev >
void	ReleaseSandesh (const Ev &event)

template<class Ev >
void	DeleteTcpSession (const Ev &event)

template<class Ev >
void	ProcessMessage (const Ev &event)

void	StartIdleHoldTimer ()

void	CancelIdleHoldTimer ()

bool	IdleHoldTimerRunning ()

void	IdleHoldTimerFired ()

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

void	PassiveOpen (SandeshSession *session)

void	SandeshUVESend (SandeshUVE *usnh)

bool	OnSandeshMessage (SandeshSession *session, const std::string &msg)

void	ResourceUpdate (bool rsc)

const std::string &	StateName () const

const std::string &	LastStateName () const

SandeshConnection *	connection ()

void	DeleteSession (SandeshSession *session)

void	set_session (SandeshSession *session)

void	clear_session ()

SandeshSession *	session ()

void	set_state (ssm::SsmState state)

ssm::SsmState	get_state () const

bool	get_resource () const

void	set_resource (bool r)

int	idle_hold_time () const

void	reset_idle_hold_time ()

void	set_idle_hold_time (int idle_hold_time)

void	set_last_event (const std::string &event)

const std::string	last_event () const

void	reset_last_info ()

void	Shutdown (void)

void	unconsumed_event (const sc::event_base &event)

const char *	prefix ()

void	SetGeneratorKey (const std::string &generator)

const std::string &	generator_key () const

void	SetQueueWaterMarkInfo (Sandesh::QueueWaterMarkInfo &wm)

void	ResetQueueWaterMarkInfo ()

bool	GetQueueCount (uint64_t &queue_count) const

bool	GetMessageDropLevel (std::string &drop_level) const

bool	GetStatistics (SandeshStateMachineStats &sm_stats, SandeshGeneratorBasicStats &basic_msg_stats)

bool	GetBasicStatistics (SandeshStateMachineStats sm_stats, SandeshGeneratorBasicStats basic_msg_stats)

bool	GetStatistics (SandeshStateMachineStats &sm_stats, SandeshGeneratorStats &detail_msg_stats)

bool	GetDetailStatistics (SandeshStateMachineStats sm_stats, SandeshGeneratorStats detail_msg_stats)

size_t	GetMaxQueueCount () const

Static Public Attributes
static const int	kIdleHoldTime = 5000

static const int	kQueueSize = 200 * 1024 * 1024

Private Types
typedef WorkQueue< EventContainer >	EventQueue

Private Member Functions
void	TimerErrorHandler (std::string name, std::string error)

bool	IdleHoldTimerExpired ()

template<typename Ev >
void	Enqueue (const Ev &event)

bool	DequeueEvent (EventContainer ec)

bool	LogEvent (const sc::event_base *event)

void	UpdateRxMsgStats (const std::string &msg_name, size_t msg_size)

void	UpdateRxMsgFailStats (const std::string &msg_name, size_t msg_size, SandeshRxDropReason::type dreason)

void	UpdateEventDequeue (const sc::event_base &event)

void	UpdateEventDequeueFail (const sc::event_base &event)

void	UpdateEventEnqueue (const sc::event_base &event)

void	UpdateEventEnqueueFail (const sc::event_base &event)

void	UpdateEventStats (const sc::event_base &event, bool enqueue, bool fail)

void	GetEventStatistics (SandeshStateMachineStats *sm_stats)

void	GetDetailMessageStatistics (SandeshGeneratorStats *detail_msg_stats)

void	GetBasicMessageStatistics (SandeshGeneratorBasicStats *basic_msg_stats)

void	SetSandeshMessageDropLevel (size_t queue_count, SandeshLevel::type level, boost::function< void(void)> cb)

void	SetDeferSessionReader (bool defer_reader)

bool	IsValid () const

	DISALLOW_COPY_AND_ASSIGN (SandeshStateMachine)

Private Attributes
const char *	prefix_

tbb::mutex	smutex_

EventQueue	work_queue_

SandeshConnection *	connection_

SandeshSession *	session_

Timer *	idle_hold_timer_

int	idle_hold_time_

bool	deleted_

tbb::atomic< ssm::SsmState >	state_

bool	resource_

ssm::SsmState	last_state_

uint64_t	state_since_

std::string	last_event_

uint64_t	last_event_at_

std::string	generator_key_

SandeshEventStatistics	event_stats_

SandeshMessageStatistics	message_stats_

SandeshMessageBuilder *	builder_

SandeshLevel::type	message_drop_level_

Friends
class	SandeshServerStateMachineTest

class	SandeshClientStateMachineTest

class	WorkQueue< EventContainer >

bool	GetEvSandeshMessageRecvSize (EventContainer ec, size_t msg_size)

Detailed Description

Definition at line 57 of file sandesh_state_machine.h.

Member Typedef Documentation

◆ EventQueue

typedef WorkQueue<EventContainer> SandeshStateMachine::EventQueue

private

Definition at line 204 of file sandesh_state_machine.h.

Constructor & Destructor Documentation

◆ SandeshStateMachine()

SandeshStateMachine::SandeshStateMachine	(	const char *	prefix,
		SandeshConnection *	connection
	)

Definition at line 381 of file sandesh_state_machine.cc.

◆ ~SandeshStateMachine()

SandeshStateMachine::~SandeshStateMachine ( )

Definition at line 403 of file sandesh_state_machine.cc.

Here is the call graph for this function:

Member Function Documentation

◆ CancelIdleHoldTimer()

void SandeshStateMachine::CancelIdleHoldTimer ( )

Definition at line 509 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ clear_session()

void SandeshStateMachine::clear_session ( )

Definition at line 447 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ connection()

SandeshConnection* SandeshStateMachine::connection ( )

inline

Definition at line 102 of file sandesh_state_machine.h.

◆ DeleteSession()

void SandeshStateMachine::DeleteSession ( SandeshSession * session )

Definition at line 467 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ DeleteTcpSession()

template<class Ev >

void SandeshStateMachine::DeleteTcpSession ( const Ev & event )

Definition at line 491 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ DequeueEvent()

bool SandeshStateMachine::DequeueEvent ( SandeshStateMachine::EventContainer ec )

private

Definition at line 790 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

SandeshStateMachine::DISALLOW_COPY_AND_ASSIGN ( SandeshStateMachine )

private

◆ Enqueue()

template<typename Ev >

void SandeshStateMachine::Enqueue ( const Ev & event )

private

Definition at line 842 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ generator_key()

const std::string& SandeshStateMachine::generator_key ( ) const

inline

Definition at line 147 of file sandesh_state_machine.h.

◆ get_resource()

bool SandeshStateMachine::get_resource ( ) const

inline

Definition at line 116 of file sandesh_state_machine.h.

◆ get_state()

ssm::SsmState SandeshStateMachine::get_state ( ) const

inline

Definition at line 114 of file sandesh_state_machine.h.

◆ GetBasicMessageStatistics()

void SandeshStateMachine::GetBasicMessageStatistics ( SandeshGeneratorBasicStats * basic_msg_stats )

private

Definition at line 575 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetBasicStatistics()

bool SandeshStateMachine::GetBasicStatistics	(	SandeshStateMachineStats *	sm_stats,
		SandeshGeneratorBasicStats *	basic_msg_stats
	)

Definition at line 609 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetDetailMessageStatistics()

void SandeshStateMachine::GetDetailMessageStatistics ( SandeshGeneratorStats * detail_msg_stats )

private

Definition at line 563 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetDetailStatistics()

bool SandeshStateMachine::GetDetailStatistics	(	SandeshStateMachineStats *	sm_stats,
		SandeshGeneratorStats *	detail_msg_stats
	)

Definition at line 591 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetEventStatistics()

void SandeshStateMachine::GetEventStatistics ( SandeshStateMachineStats * sm_stats )

private

Definition at line 548 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetMaxQueueCount()

size_t SandeshStateMachine::GetMaxQueueCount ( ) const

inline

Definition at line 162 of file sandesh_state_machine.h.

Here is the call graph for this function:

◆ GetMessageDropLevel()

bool SandeshStateMachine::GetMessageDropLevel ( std::string & drop_level ) const

Definition at line 539 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetQueueCount()

bool SandeshStateMachine::GetQueueCount ( uint64_t & queue_count ) const

Definition at line 531 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetStatistics() [1/2]

bool SandeshStateMachine::GetStatistics	(	SandeshStateMachineStats &	sm_stats,
		SandeshGeneratorBasicStats &	basic_msg_stats
	)

Definition at line 622 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ GetStatistics() [2/2]

bool SandeshStateMachine::GetStatistics	(	SandeshStateMachineStats &	sm_stats,
		SandeshGeneratorStats &	detail_msg_stats
	)

Definition at line 604 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ idle_hold_time()

int SandeshStateMachine::idle_hold_time ( ) const

inline

Definition at line 119 of file sandesh_state_machine.h.

◆ IdleHoldTimerExpired()

bool SandeshStateMachine::IdleHoldTimerExpired ( )

private

Definition at line 627 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ IdleHoldTimerFired()

void SandeshStateMachine::IdleHoldTimerFired ( )

Definition at line 520 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ IdleHoldTimerRunning()

bool SandeshStateMachine::IdleHoldTimerRunning ( )

Definition at line 513 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ Initialize()

void SandeshStateMachine::Initialize ( )

Definition at line 427 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ IsValid()

bool SandeshStateMachine::IsValid ( ) const

private

Definition at line 587 of file sandesh_state_machine.cc.

◆ last_event()

const std::string SandeshStateMachine::last_event ( ) const

inline

Definition at line 130 of file sandesh_state_machine.h.

◆ LastStateName()

const string & SandeshStateMachine::LastStateName ( ) const

Definition at line 750 of file sandesh_state_machine.cc.

◆ LogEvent()

bool SandeshStateMachine::LogEvent ( const sc::event_base * event )

private

Definition at line 754 of file sandesh_state_machine.cc.

◆ OnIdle()

template<class Ev >

void SandeshStateMachine::OnIdle ( const Ev & event )

Definition at line 481 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ OnSandeshMessage()

bool SandeshStateMachine::OnSandeshMessage	(	SandeshSession *	session,
		const std::string &	msg
	)

Definition at line 671 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ OnSessionEvent()

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

Definition at line 632 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ PassiveOpen()

void SandeshStateMachine::PassiveOpen ( SandeshSession * session )

Definition at line 652 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ prefix()

const char* SandeshStateMachine::prefix ( )

inline

Definition at line 142 of file sandesh_state_machine.h.

◆ ProcessMessage()

template<class Ev >

void SandeshStateMachine::ProcessMessage ( const Ev & event )

◆ ReleaseSandesh()

template<class Ev >

void SandeshStateMachine::ReleaseSandesh ( const Ev & event )

◆ reset_idle_hold_time()

void SandeshStateMachine::reset_idle_hold_time ( )

inline

Definition at line 120 of file sandesh_state_machine.h.

◆ reset_last_info()

void SandeshStateMachine::reset_last_info ( )

inline

Definition at line 134 of file sandesh_state_machine.h.

◆ ResetQueueWaterMarkInfo()

void SandeshStateMachine::ResetQueueWaterMarkInfo ( )

Definition at line 909 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ ResourceUpdate()

void SandeshStateMachine::ResourceUpdate ( bool rsc )

Definition at line 735 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ SandeshUVESend()

void SandeshStateMachine::SandeshUVESend ( SandeshUVE * usnh )

◆ session()

SandeshSession * SandeshStateMachine::session ( )

Definition at line 476 of file sandesh_state_machine.cc.

◆ set_idle_hold_time()

void SandeshStateMachine::set_idle_hold_time ( int idle_hold_time )

inline

Definition at line 121 of file sandesh_state_machine.h.

Here is the call graph for this function:

◆ set_last_event()

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

inline

Definition at line 125 of file sandesh_state_machine.h.

Here is the call graph for this function:

◆ set_resource()

void SandeshStateMachine::set_resource ( bool r )

inline

Definition at line 117 of file sandesh_state_machine.h.

◆ set_session()

void SandeshStateMachine::set_session ( SandeshSession * session )

Definition at line 459 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ set_state()

void SandeshStateMachine::set_state ( ssm::SsmState state )

inline

Definition at line 109 of file sandesh_state_machine.h.

Here is the call graph for this function:

◆ SetAdminState()

void SandeshStateMachine::SetAdminState ( bool down )

Definition at line 435 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ SetDeferDequeue()

void SandeshStateMachine::SetDeferDequeue ( bool defer )

Definition at line 948 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ SetDeferSessionReader()

void SandeshStateMachine::SetDeferSessionReader ( bool defer_reader )

private

Definition at line 875 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ SetGeneratorKey()

void SandeshStateMachine::SetGeneratorKey ( const std::string & generator )

inline

Definition at line 144 of file sandesh_state_machine.h.

◆ SetQueueWaterMarkInfo()

void SandeshStateMachine::SetQueueWaterMarkInfo ( Sandesh::QueueWaterMarkInfo & wm )

Definition at line 882 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ SetSandeshMessageDropLevel()

void SandeshStateMachine::SetSandeshMessageDropLevel	(	size_t	queue_count,
		SandeshLevel::type	level,
		boost::function< void(void)>	cb
	)

private

Definition at line 860 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ Shutdown()

void SandeshStateMachine::Shutdown ( void )

Definition at line 431 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ StartIdleHoldTimer()

void SandeshStateMachine::StartIdleHoldTimer ( )

Definition at line 499 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ StateName()

const string & SandeshStateMachine::StateName ( ) const

Definition at line 746 of file sandesh_state_machine.cc.

◆ TimerErrorHandler()

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

private

Definition at line 527 of file sandesh_state_machine.cc.

◆ unconsumed_event()

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

Definition at line 814 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ UpdateEventDequeue()

void SandeshStateMachine::UpdateEventDequeue ( const sc::event_base & event )

private

Definition at line 769 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ UpdateEventDequeueFail()

void SandeshStateMachine::UpdateEventDequeueFail ( const sc::event_base & event )

private

Definition at line 777 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ UpdateEventEnqueue()

void SandeshStateMachine::UpdateEventEnqueue ( const sc::event_base & event )

private

Definition at line 765 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ UpdateEventEnqueueFail()

void SandeshStateMachine::UpdateEventEnqueueFail ( const sc::event_base & event )

private

Definition at line 773 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ UpdateEventStats()

void SandeshStateMachine::UpdateEventStats	(	const sc::event_base &	event,
		bool	enqueue,
		bool	fail
	)

private

Definition at line 781 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ UpdateRxMsgFailStats()

void SandeshStateMachine::UpdateRxMsgFailStats	(	const std::string &	msg_name,
		size_t	msg_size,
		SandeshRxDropReason::type	dreason
	)

private

Definition at line 665 of file sandesh_state_machine.cc.

Here is the call graph for this function:

◆ UpdateRxMsgStats()

void SandeshStateMachine::UpdateRxMsgStats	(	const std::string &	msg_name,
		size_t	msg_size
	)

private

Definition at line 659 of file sandesh_state_machine.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ GetEvSandeshMessageRecvSize

bool GetEvSandeshMessageRecvSize	(	SandeshStateMachine::EventContainer *	ec,
		size_t *	msg_size
	)

friend

Definition at line 914 of file sandesh_state_machine.cc.

◆ SandeshClientStateMachineTest

friend class SandeshClientStateMachineTest

friend

Definition at line 166 of file sandesh_state_machine.h.

◆ SandeshServerStateMachineTest

friend class SandeshServerStateMachineTest

friend

Definition at line 165 of file sandesh_state_machine.h.

◆ WorkQueue< EventContainer >

friend class WorkQueue< EventContainer >

friend

Definition at line 166 of file sandesh_state_machine.h.

Member Data Documentation

◆ builder_

SandeshMessageBuilder* SandeshStateMachine::builder_

private

Definition at line 221 of file sandesh_state_machine.h.

◆ connection_

SandeshConnection* SandeshStateMachine::connection_

private

Definition at line 206 of file sandesh_state_machine.h.

◆ deleted_

bool SandeshStateMachine::deleted_

private

Definition at line 210 of file sandesh_state_machine.h.

◆ event_stats_

SandeshEventStatistics SandeshStateMachine::event_stats_

private

Definition at line 219 of file sandesh_state_machine.h.

◆ generator_key_

std::string SandeshStateMachine::generator_key_

private

Definition at line 218 of file sandesh_state_machine.h.

◆ idle_hold_time_

int SandeshStateMachine::idle_hold_time_

private

Definition at line 209 of file sandesh_state_machine.h.

◆ idle_hold_timer_

Timer* SandeshStateMachine::idle_hold_timer_

private

Definition at line 208 of file sandesh_state_machine.h.

◆ kIdleHoldTime

const int SandeshStateMachine::kIdleHoldTime = 5000

static

Definition at line 60 of file sandesh_state_machine.h.

◆ kQueueSize

const int SandeshStateMachine::kQueueSize = 200 * 1024 * 1024

static

Definition at line 61 of file sandesh_state_machine.h.

◆ last_event_

std::string SandeshStateMachine::last_event_

private

Definition at line 215 of file sandesh_state_machine.h.

◆ last_event_at_

uint64_t SandeshStateMachine::last_event_at_

private

Definition at line 216 of file sandesh_state_machine.h.

◆ last_state_

ssm::SsmState SandeshStateMachine::last_state_

private

Definition at line 213 of file sandesh_state_machine.h.

◆ message_drop_level_

SandeshLevel::type SandeshStateMachine::message_drop_level_

private

Definition at line 222 of file sandesh_state_machine.h.

◆ message_stats_

SandeshMessageStatistics SandeshStateMachine::message_stats_

private

Definition at line 220 of file sandesh_state_machine.h.

◆ prefix_

const char* SandeshStateMachine::prefix_

private

Definition at line 202 of file sandesh_state_machine.h.

◆ resource_

bool SandeshStateMachine::resource_

private

Definition at line 212 of file sandesh_state_machine.h.

◆ session_

SandeshSession* SandeshStateMachine::session_

private

Definition at line 207 of file sandesh_state_machine.h.

◆ smutex_

tbb::mutex SandeshStateMachine::smutex_

mutableprivate

Definition at line 203 of file sandesh_state_machine.h.

◆ state_

tbb::atomic<ssm::SsmState> SandeshStateMachine::state_

private

Definition at line 211 of file sandesh_state_machine.h.

◆ state_since_

uint64_t SandeshStateMachine::state_since_

private

Definition at line 214 of file sandesh_state_machine.h.

◆ work_queue_

EventQueue SandeshStateMachine::work_queue_

private

Definition at line 205 of file sandesh_state_machine.h.

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

Classes

Public Member Functions

Static Public Attributes

Private Types

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ EventQueue

Constructor & Destructor Documentation

◆ SandeshStateMachine()

◆ ~SandeshStateMachine()

Member Function Documentation

◆ CancelIdleHoldTimer()

◆ clear_session()

◆ connection()

◆ DeleteSession()

◆ DeleteTcpSession()

◆ DequeueEvent()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ Enqueue()

◆ generator_key()

◆ get_resource()

◆ get_state()

◆ GetBasicMessageStatistics()

◆ GetBasicStatistics()

◆ GetDetailMessageStatistics()

◆ GetDetailStatistics()

◆ GetEventStatistics()

◆ GetMaxQueueCount()

◆ GetMessageDropLevel()

◆ GetQueueCount()

◆ GetStatistics() [1/2]

◆ GetStatistics() [2/2]

◆ idle_hold_time()

◆ IdleHoldTimerExpired()

◆ IdleHoldTimerFired()

◆ IdleHoldTimerRunning()

◆ Initialize()

◆ IsValid()

◆ last_event()

◆ LastStateName()

◆ LogEvent()

◆ OnIdle()

◆ OnSandeshMessage()

◆ OnSessionEvent()

◆ PassiveOpen()

◆ prefix()

◆ ProcessMessage()

◆ ReleaseSandesh()

◆ reset_idle_hold_time()

◆ reset_last_info()

◆ ResetQueueWaterMarkInfo()

◆ ResourceUpdate()

◆ SandeshUVESend()

◆ session()

◆ set_idle_hold_time()

◆ set_last_event()

◆ set_resource()

◆ set_session()

◆ set_state()

◆ SetAdminState()

◆ SetDeferDequeue()

◆ SetDeferSessionReader()

◆ SetGeneratorKey()

◆ SetQueueWaterMarkInfo()

◆ SetSandeshMessageDropLevel()

◆ Shutdown()

◆ StartIdleHoldTimer()

◆ StateName()

◆ TimerErrorHandler()

◆ unconsumed_event()

◆ UpdateEventDequeue()

◆ UpdateEventDequeueFail()

◆ UpdateEventEnqueue()

◆ UpdateEventEnqueueFail()

◆ UpdateEventStats()

◆ UpdateRxMsgFailStats()

◆ UpdateRxMsgStats()