38 #include <condition_variable> virtual ~IQueueBase()
Definition: IQueueBase.h:48
This is the base library main class.
Definition: BaseLib.h:95
Definition: IQueueBase.h:45
Definition: BaseLib.cpp:34
Class to print output of different kinds to the standard and error output.
Definition: Output.h:54
IQueueBase(SharedObjects *baseLib, uint32_t queueCount)
Definition: IQueueBase.cpp:36
int32_t _queueCount
Definition: IQueueBase.h:59
std::atomic< int64_t > _lastQueueFullError
Definition: IQueueBase.h:63
std::atomic< uint32_t > _droppedEntries
Definition: IQueueBase.h:62
std::unique_ptr< std::atomic_bool[]> _stopProcessingThread
Definition: IQueueBase.h:60
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...
Definition: IQueueBase.cpp:42
SharedObjects * _bl
Definition: IQueueBase.h:58