OpenSDN source code
Classes | Public Member Functions | Private Member Functions | Private Attributes | Friends | List of all members
IFMapUpdateSender Class Reference

#include <ifmap_update_sender.h>

Collaboration diagram for IFMapUpdateSender:
Collaboration graph
[legend]

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::IFMapUpdateSender ( IFMapServer *  server,
IFMapUpdateQueue *  queue 
)

Definition at line 17 of file ifmap_update_sender.cc.

◆ ~IFMapUpdateSender()

IFMapUpdateSender::~IFMapUpdateSender ( )
virtual

Definition at line 23 of file ifmap_update_sender.cc.

Member Function Documentation

◆ CleanupClient()

void IFMapUpdateSender::CleanupClient ( int  index)

Definition at line 93 of file ifmap_update_sender.cc.

Here is the call graph for this function:

◆ GetSendScheduled()

void IFMapUpdateSender::GetSendScheduled ( BitSet *  current)
private

Definition at line 86 of file ifmap_update_sender.cc.

Here is the call graph for this function:

◆ IsClientBlocked()

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:

◆ LogAndCountSentUpdate()

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:

◆ ProcessMarker()

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:

◆ ProcessUpdate()

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:

◆ QueueActive()

void IFMapUpdateSender::QueueActive ( )
virtual

Definition at line 71 of file ifmap_update_sender.cc.

Here is the call graph for this function:

◆ Send()

void IFMapUpdateSender::Send ( IFMapMarker *  imarker)
private

Definition at line 105 of file ifmap_update_sender.cc.

Here is the call graph for this function:

◆ SendActive()

void IFMapUpdateSender::SendActive ( int  index)
virtual

Definition at line 80 of file ifmap_update_sender.cc.

Here is the call graph for this function:

◆ SendUpdate()

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:

◆ SetObjectsPerMessage()

void IFMapUpdateSender::SetObjectsPerMessage ( int  num)
inline

Definition at line 37 of file ifmap_update_sender.h.

Here is the call graph for this function:

◆ SetSendBlocked()

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:

◆ SetServer()

void IFMapUpdateSender::SetServer ( IFMapServer *  srv)
inline

Definition at line 35 of file ifmap_update_sender.h.

◆ StartTask()

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

◆ IFMapUpdateSenderTest

friend class IFMapUpdateSenderTest
friend

Definition at line 47 of file ifmap_update_sender.h.

Member Data Documentation

◆ message_

IFMapMessage* IFMapUpdateSender::message_
private

Definition at line 65 of file ifmap_update_sender.h.

◆ mutex_

tbb::mutex IFMapUpdateSender::mutex_
private

Definition at line 67 of file ifmap_update_sender.h.

◆ queue_

IFMapUpdateQueue* IFMapUpdateSender::queue_
private

Definition at line 64 of file ifmap_update_sender.h.

◆ queue_active_

bool IFMapUpdateSender::queue_active_
private

Definition at line 69 of file ifmap_update_sender.h.

◆ send_blocked_

BitSet IFMapUpdateSender::send_blocked_
private

Definition at line 71 of file ifmap_update_sender.h.

◆ send_scheduled_

BitSet IFMapUpdateSender::send_scheduled_
private

Definition at line 70 of file ifmap_update_sender.h.

◆ server_

IFMapServer* IFMapUpdateSender::server_
private

Definition at line 63 of file ifmap_update_sender.h.

◆ task_scheduled_

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: