BaseLib::IQueueBase Class Reference

#include <IQueueBase.h>

Inheritance diagram for BaseLib::IQueueBase:

Public Member Functions
	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...

Protected Attributes
SharedObjects *	_bl = nullptr
int32_t	_queueCount = 2
std::unique_ptr< std::atomic_bool[]>	_stopProcessingThread
std::atomic< uint32_t >	_droppedEntries {0}
std::atomic< int64_t >	_lastQueueFullError {0}

Constructor & Destructor Documentation

IQueueBase()

BaseLib::IQueueBase::IQueueBase	(	SharedObjects *	baseLib,
		uint32_t	queueCount
	)

~IQueueBase()

virtual BaseLib::IQueueBase::~IQueueBase ( )

inlinevirtual

Member Function Documentation

printQueueFullError()

void BaseLib::IQueueBase::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.

Parameters

out	The output object.
message	The message to print.

Member Data Documentation

_bl

SharedObjects* BaseLib::IQueueBase::_bl = nullptr

protected

_droppedEntries

std::atomic<uint32_t> BaseLib::IQueueBase::_droppedEntries {0}

protected

_lastQueueFullError

std::atomic<int64_t> BaseLib::IQueueBase::_lastQueueFullError {0}

protected

_queueCount

int32_t BaseLib::IQueueBase::_queueCount = 2

protected

_stopProcessingThread

std::unique_ptr<std::atomic_bool[]> BaseLib::IQueueBase::_stopProcessingThread

protected

---

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

• IQueueBase.h
• IQueueBase.cpp