ariba::utility::SystemQueue::QueueThread Class Reference

Inheritance diagram for ariba::utility::SystemQueue::QueueThread:

Inheritance graph
[legend]
Collaboration diagram for ariba::utility::SystemQueue::QueueThread:

Collaboration graph
[legend]

List of all members.

Public Member Functions

 QueueThread (QueueThread *_transferQueue=NULL)
virtual ~QueueThread ()
void run ()
void cancel ()
bool isEmpty ()
void insert (const SystemEvent &event, uint32_t delay)

Protected Member Functions

virtual void onItemInserted (const SystemEvent &event)=0
virtual void onNextQueueItem (const SystemEvent &event)=0

Protected Attributes

QueueThreadtransferQueue
EventQueue eventsQueue
boost::mutex queueMutex

Static Private Member Functions

static void threadFunc (QueueThread *obj)

Private Attributes

boost::thread * queueThread
boost::condition_variable itemsAvailable
volatile bool running


Detailed Description

Definition at line 162 of file SystemQueue.h.


Constructor & Destructor Documentation

ariba::utility::SystemQueue::QueueThread::QueueThread ( QueueThread _transferQueue = NULL  ) 

Definition at line 116 of file SystemQueue.cpp.

ariba::utility::SystemQueue::QueueThread::~QueueThread (  )  [virtual]

Definition at line 120 of file SystemQueue.cpp.


Member Function Documentation

void ariba::utility::SystemQueue::QueueThread::run (  ) 

Definition at line 123 of file SystemQueue.cpp.

References queueThread, running, and threadFunc().

Referenced by ariba::utility::SystemQueue::run().

void ariba::utility::SystemQueue::QueueThread::cancel (  ) 

Definition at line 129 of file SystemQueue.cpp.

References eventsQueue, itemsAvailable, queueThread, and running.

Referenced by ariba::utility::SystemQueue::cancel().

bool ariba::utility::SystemQueue::QueueThread::isEmpty (  ) 

Definition at line 147 of file SystemQueue.cpp.

References eventsQueue, and queueMutex.

Referenced by ariba::utility::SystemQueue::isEmpty().

void ariba::utility::SystemQueue::QueueThread::insert ( const SystemEvent event,
uint32_t  delay 
)

virtual void ariba::utility::SystemQueue::QueueThread::onItemInserted ( const SystemEvent event  )  [protected, pure virtual]

virtual void ariba::utility::SystemQueue::QueueThread::onNextQueueItem ( const SystemEvent event  )  [protected, pure virtual]

void ariba::utility::SystemQueue::QueueThread::threadFunc ( QueueThread obj  )  [static, private]

Definition at line 166 of file SystemQueue.cpp.

References eventsQueue, itemsAvailable, onNextQueueItem(), queueMutex, and running.

Referenced by run().


Member Data Documentation

Definition at line 176 of file SystemQueue.h.

Referenced by insert(), isEmpty(), and threadFunc().

Definition at line 178 of file SystemQueue.h.

Referenced by cancel(), and run().

boost::condition_variable ariba::utility::SystemQueue::QueueThread::itemsAvailable [private]

Definition at line 180 of file SystemQueue.h.

Referenced by cancel(), insert(), and threadFunc().

Definition at line 181 of file SystemQueue.h.

Referenced by cancel(), run(), and threadFunc().


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

Generated on Wed May 27 18:24:10 2009 for Ariba by  doxygen 1.5.6