Public Member Functions | |
QueueThreadDelay (QueueThread *_transferQueue=NULL) | |
~QueueThreadDelay () | |
Protected Member Functions | |
virtual void | onItemInserted (const SystemEvent &event) |
virtual void | onNextQueueItem (const SystemEvent &event) |
Private Attributes | |
volatile bool | isSleeping |
ptime | sleepStart |
boost::mutex | sleepMutex |
boost::condition_variable | sleepCond |
Definition at line 197 of file SystemQueue.h.
ariba::utility::SystemQueue::QueueThreadDelay::QueueThreadDelay | ( | QueueThread * | _transferQueue = NULL |
) |
Definition at line 227 of file SystemQueue.cpp.
ariba::utility::SystemQueue::QueueThreadDelay::~QueueThreadDelay | ( | ) |
Definition at line 233 of file SystemQueue.cpp.
void ariba::utility::SystemQueue::QueueThreadDelay::onItemInserted | ( | const SystemEvent & | event | ) | [protected, virtual] |
Implements ariba::utility::SystemQueue::QueueThread.
Definition at line 236 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::QueueThread::eventsQueue, isSleeping, sleepCond, and sleepStart.
void ariba::utility::SystemQueue::QueueThreadDelay::onNextQueueItem | ( | const SystemEvent & | event | ) | [protected, virtual] |
Implements ariba::utility::SystemQueue::QueueThread.
Definition at line 272 of file SystemQueue.cpp.
References ariba::utility::SystemQueue::QueueThread::insert(), isSleeping, ariba::utility::SystemEvent::remainingDelay, sleepCond, sleepMutex, sleepStart, and ariba::utility::SystemQueue::QueueThread::transferQueue.
volatile bool ariba::utility::SystemQueue::QueueThreadDelay::isSleeping [private] |
Definition at line 205 of file SystemQueue.h.
Referenced by onItemInserted(), and onNextQueueItem().
ptime ariba::utility::SystemQueue::QueueThreadDelay::sleepStart [private] |
Definition at line 206 of file SystemQueue.h.
Referenced by onItemInserted(), and onNextQueueItem().
boost::mutex ariba::utility::SystemQueue::QueueThreadDelay::sleepMutex [private] |
boost::condition_variable ariba::utility::SystemQueue::QueueThreadDelay::sleepCond [private] |
Definition at line 208 of file SystemQueue.h.
Referenced by onItemInserted(), and onNextQueueItem().