#include <ifmap_update_sender.h>

Collaboration diagram for IFMapUpdateSender:

Classes
class	SendTask

Public Member Functions
	IFMapUpdateSender (IFMapServer server, IFMapUpdateQueue queue)

virtual	~IFMapUpdateSender ()

virtual void	QueueActive ()

virtual void	SendActive (int index)

void	CleanupClient (int index)

void	SetServer (IFMapServer *srv)

void	SetObjectsPerMessage (int num)

bool	IsClientBlocked (int client_index)

Private Member Functions
void	StartTask ()

void	Send (IFMapMarker *imarker)

void	SendUpdate (BitSet send_set, BitSet *blocked_set)

IFMapMarker *	ProcessMarker (IFMapMarker marker, IFMapMarker next_marker, bool *done)

void	ProcessUpdate (IFMapUpdate *update, const BitSet &base_send_set)

void	GetSendScheduled (BitSet *current)

void	LogAndCountSentUpdate (IFMapUpdate *update, const BitSet &base_send_set)

void	SetSendBlocked (int client_index)

Private Attributes
IFMapServer *	server_

IFMapUpdateQueue *	queue_

IFMapMessage *	message_

tbb::mutex	mutex_

bool	task_scheduled_

bool	queue_active_

BitSet	send_scheduled_

BitSet	send_blocked_

Friends
class	IFMapUpdateSenderTest

Detailed Description

Definition at line 19 of file ifmap_update_sender.h.

Constructor & Destructor Documentation

IFMapUpdateSender::IFMapUpdateSender	(	IFMapServer *	server,
		IFMapUpdateQueue *	queue
	)

Definition at line 17 of file ifmap_update_sender.cc.

IFMapUpdateSender::~IFMapUpdateSender ( )

virtual

Definition at line 23 of file ifmap_update_sender.cc.

Member Function Documentation

void IFMapUpdateSender::CleanupClient ( int index )

Definition at line 93 of file ifmap_update_sender.cc.

Here is the call graph for this function:

void IFMapUpdateSender::GetSendScheduled ( BitSet * current )

private

Definition at line 86 of file ifmap_update_sender.cc.

Here is the call graph for this function:

bool IFMapUpdateSender::IsClientBlocked ( int client_index )

inline

Definition at line 41 of file ifmap_update_sender.h.

Here is the call graph for this function:

void IFMapUpdateSender::LogAndCountSentUpdate	(	IFMapUpdate *	update,
		const BitSet &	base_send_set
	)

private

Definition at line 326 of file ifmap_update_sender.cc.

Here is the call graph for this function:

IFMapMarker * IFMapUpdateSender::ProcessMarker	(	IFMapMarker *	marker,
		IFMapMarker *	next_marker,
		bool *	done
	)

private

Definition at line 279 of file ifmap_update_sender.cc.

Here is the call graph for this function:

void IFMapUpdateSender::ProcessUpdate	(	IFMapUpdate *	update,
		const BitSet &	base_send_set
	)

private

Definition at line 229 of file ifmap_update_sender.cc.

Here is the call graph for this function:

void IFMapUpdateSender::QueueActive ( )

virtual

Definition at line 71 of file ifmap_update_sender.cc.

Here is the call graph for this function:

void IFMapUpdateSender::Send ( IFMapMarker * imarker )

private

Definition at line 105 of file ifmap_update_sender.cc.

Here is the call graph for this function:

void IFMapUpdateSender::SendActive ( int index )

virtual

Definition at line 80 of file ifmap_update_sender.cc.

Here is the call graph for this function:

void IFMapUpdateSender::SendUpdate	(	BitSet	send_set,
		BitSet *	blocked_set
	)

private

Definition at line 247 of file ifmap_update_sender.cc.

Here is the call graph for this function:

void IFMapUpdateSender::SetObjectsPerMessage ( int num )

inline

Definition at line 37 of file ifmap_update_sender.h.

Here is the call graph for this function:

void IFMapUpdateSender::SetSendBlocked ( int client_index )

inlineprivate

Definition at line 73 of file ifmap_update_sender.h.

Here is the call graph for this function:

void IFMapUpdateSender::SetServer ( IFMapServer * srv )

inline

Definition at line 35 of file ifmap_update_sender.h.

void IFMapUpdateSender::StartTask ( )

private

Definition at line 61 of file ifmap_update_sender.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

friend class IFMapUpdateSenderTest

friend

Definition at line 46 of file ifmap_update_sender.h.

Member Data Documentation

IFMapMessage* IFMapUpdateSender::message_

private

Definition at line 65 of file ifmap_update_sender.h.

tbb::mutex IFMapUpdateSender::mutex_

private

Definition at line 67 of file ifmap_update_sender.h.

IFMapUpdateQueue* IFMapUpdateSender::queue_

private

Definition at line 64 of file ifmap_update_sender.h.

bool IFMapUpdateSender::queue_active_

private

Definition at line 69 of file ifmap_update_sender.h.

BitSet IFMapUpdateSender::send_blocked_

private

Definition at line 71 of file ifmap_update_sender.h.

BitSet IFMapUpdateSender::send_scheduled_

private

Definition at line 70 of file ifmap_update_sender.h.

IFMapServer* IFMapUpdateSender::server_

private

Definition at line 63 of file ifmap_update_sender.h.

bool IFMapUpdateSender::task_scheduled_

private

Definition at line 68 of file ifmap_update_sender.h.

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

Classes

Public Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation