#include <ITimedQueue.h>
|
| ITimedQueue (SharedObjects *baseLib, uint32_t queueCount) |
|
virtual | ~ITimedQueue () |
|
void | startQueue (int32_t index, int32_t threadPriority, int32_t threadPolicy) |
|
void | stopQueue (int32_t index) |
|
bool | enqueue (int32_t index, std::shared_ptr< ITimedQueueEntry > &entry, int64_t &id) |
|
void | removeQueueEntry (int32_t index, int64_t id) |
|
virtual void | processQueueEntry (int32_t index, int64_t id, std::shared_ptr< ITimedQueueEntry > &entry)=0 |
|
| IQueueBase (SharedObjects *baseLib, uint32_t queueCount) |
|
virtual | ~IQueueBase () |
|
void | printQueueFullError (BaseLib::Output &out, const std::string &message) |
| Prints a rate limited (1 output per 10 seconds) error message and keeps count of error messages. More...
|
|
§ ITimedQueue()
BaseLib::ITimedQueue::ITimedQueue |
( |
SharedObjects * |
baseLib, |
|
|
uint32_t |
queueCount |
|
) |
| |
§ ~ITimedQueue()
BaseLib::ITimedQueue::~ITimedQueue |
( |
| ) |
|
|
virtual |
§ enqueue()
bool BaseLib::ITimedQueue::enqueue |
( |
int32_t |
index, |
|
|
std::shared_ptr< ITimedQueueEntry > & |
entry, |
|
|
int64_t & |
id |
|
) |
| |
§ processQueueEntry()
virtual void BaseLib::ITimedQueue::processQueueEntry |
( |
int32_t |
index, |
|
|
int64_t |
id, |
|
|
std::shared_ptr< ITimedQueueEntry > & |
entry |
|
) |
| |
|
pure virtual |
§ removeQueueEntry()
void BaseLib::ITimedQueue::removeQueueEntry |
( |
int32_t |
index, |
|
|
int64_t |
id |
|
) |
| |
§ startQueue()
void BaseLib::ITimedQueue::startQueue |
( |
int32_t |
index, |
|
|
int32_t |
threadPriority, |
|
|
int32_t |
threadPolicy |
|
) |
| |
§ stopQueue()
void BaseLib::ITimedQueue::stopQueue |
( |
int32_t |
index | ) |
|
The documentation for this class was generated from the following files: