Public Member Functions | |
QueueThread (QueueThread *_transferQueue=NULL) | |
virtual | ~QueueThread () |
void | run () |
void | cancel () |
bool | isEmpty () |
void | insert (const SystemEvent &event, uint32_t delay) |
void | enter () |
void | leave () |
Protected Member Functions | |
virtual void | onItemInserted (const SystemEvent &event)=0 |
virtual void | onNextQueueItem (const SystemEvent &event)=0 |
Protected Attributes | |
QueueThread * | transferQueue |
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 |
Definition at line 174 of file SystemQueue.h.
ariba::utility::SystemQueue::SystemQueue::QueueThread::QueueThread | ( | QueueThread * | _transferQueue = NULL |
) |
Definition at line 126 of file SystemQueue.cpp.
ariba::utility::SystemQueue::SystemQueue::QueueThread::~QueueThread | ( | ) | [virtual] |
Definition at line 130 of file SystemQueue.cpp.
void ariba::utility::SystemQueue::SystemQueue::QueueThread::cancel | ( | ) |
Definition at line 140 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::SystemQueue::QueueThread::eventsQueue, ariba::utility::SystemQueue::SystemQueue::QueueThread::itemsAvailable, logging_debug, ariba::utility::SystemQueue::SystemQueue::QueueThread::queueMutex, ariba::utility::SystemQueue::SystemQueue::QueueThread::queueThread, and ariba::utility::SystemQueue::SystemQueue::QueueThread::running.
Referenced by ariba::utility::SystemQueue::cancel().
void ariba::utility::SystemQueue::SystemQueue::QueueThread::enter | ( | ) |
Definition at line 238 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::SystemQueue::QueueThread::queueMutex.
Referenced by ariba::utility::SystemQueue::enterMethod().
void ariba::utility::SystemQueue::SystemQueue::QueueThread::insert | ( | const SystemEvent & | event, | |
uint32_t | delay | |||
) |
Definition at line 176 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::SystemQueue::QueueThread::eventsQueue, ariba::utility::SystemQueue::SystemQueue::QueueThread::itemsAvailable, ariba::utility::SystemQueue::SystemQueue::QueueThread::onItemInserted(), and ariba::utility::SystemQueue::SystemQueue::QueueThread::queueMutex.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThreadDelay::onNextQueueItem(), and ariba::utility::SystemQueue::scheduleEvent().
bool ariba::utility::SystemQueue::SystemQueue::QueueThread::isEmpty | ( | ) |
Definition at line 171 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::SystemQueue::QueueThread::eventsQueue, and ariba::utility::SystemQueue::SystemQueue::QueueThread::queueMutex.
Referenced by ariba::utility::SystemQueue::isEmpty().
void ariba::utility::SystemQueue::SystemQueue::QueueThread::leave | ( | ) |
Definition at line 242 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::SystemQueue::QueueThread::queueMutex.
Referenced by ariba::utility::SystemQueue::leaveMethod().
virtual void ariba::utility::SystemQueue::SystemQueue::QueueThread::onItemInserted | ( | const SystemEvent & | event | ) | [protected, pure virtual] |
virtual void ariba::utility::SystemQueue::SystemQueue::QueueThread::onNextQueueItem | ( | const SystemEvent & | event | ) | [protected, pure virtual] |
void ariba::utility::SystemQueue::SystemQueue::QueueThread::run | ( | ) |
Definition at line 133 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::SystemQueue::QueueThread::queueThread, ariba::utility::SystemQueue::SystemQueue::QueueThread::running, and ariba::utility::SystemQueue::SystemQueue::QueueThread::threadFunc().
Referenced by ariba::utility::SystemQueue::run().
void ariba::utility::SystemQueue::SystemQueue::QueueThread::threadFunc | ( | QueueThread * | obj | ) | [static, private] |
Definition at line 194 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::SystemQueue::QueueThread::eventsQueue, ariba::utility::SystemQueue::SystemQueue::QueueThread::itemsAvailable, logging_debug, ariba::utility::SystemQueue::SystemQueue::QueueThread::onNextQueueItem(), ariba::utility::SystemQueue::SystemQueue::QueueThread::queueMutex, and ariba::utility::SystemQueue::SystemQueue::QueueThread::running.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThread::run().
EventQueue ariba::utility::SystemQueue::SystemQueue::QueueThread::eventsQueue [protected] |
Definition at line 189 of file SystemQueue.h.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThread::cancel(), ariba::utility::SystemQueue::SystemQueue::QueueThread::insert(), ariba::utility::SystemQueue::SystemQueue::QueueThread::isEmpty(), ariba::utility::SystemQueue::SystemQueue::QueueThreadDelay::onItemInserted(), and ariba::utility::SystemQueue::SystemQueue::QueueThread::threadFunc().
boost::condition_variable ariba::utility::SystemQueue::SystemQueue::QueueThread::itemsAvailable [private] |
Definition at line 194 of file SystemQueue.h.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThread::cancel(), ariba::utility::SystemQueue::SystemQueue::QueueThread::insert(), and ariba::utility::SystemQueue::SystemQueue::QueueThread::threadFunc().
boost::mutex ariba::utility::SystemQueue::SystemQueue::QueueThread::queueMutex [protected] |
Definition at line 190 of file SystemQueue.h.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThread::cancel(), ariba::utility::SystemQueue::SystemQueue::QueueThread::enter(), ariba::utility::SystemQueue::SystemQueue::QueueThread::insert(), ariba::utility::SystemQueue::SystemQueue::QueueThread::isEmpty(), ariba::utility::SystemQueue::SystemQueue::QueueThread::leave(), and ariba::utility::SystemQueue::SystemQueue::QueueThread::threadFunc().
boost::thread* ariba::utility::SystemQueue::SystemQueue::QueueThread::queueThread [private] |
Definition at line 192 of file SystemQueue.h.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThread::cancel(), and ariba::utility::SystemQueue::SystemQueue::QueueThread::run().
volatile bool ariba::utility::SystemQueue::SystemQueue::QueueThread::running [private] |
Definition at line 195 of file SystemQueue.h.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThread::cancel(), ariba::utility::SystemQueue::SystemQueue::QueueThread::run(), and ariba::utility::SystemQueue::SystemQueue::QueueThread::threadFunc().
QueueThread* ariba::utility::SystemQueue::SystemQueue::QueueThread::transferQueue [protected] |
Definition at line 188 of file SystemQueue.h.
Referenced by ariba::utility::SystemQueue::SystemQueue::QueueThreadDelay::onNextQueueItem().