![]() |
Classes | |
class | protlib::QueueManagerError |
QueueManager errors. More... | |
class | protlib::QueueManager |
Namespaces | |
namespace | protlib |
Functions | |
protlib::QueueManagerError::QueueManagerError (error_t e) | |
constructor | |
virtual const char * | protlib::QueueManagerError::getstr () const |
static QueueManager * | protlib::QueueManager::instance () |
return QueueManager singleton instance | |
static void | protlib::QueueManager::clear () |
clear QueueManager | |
void | protlib::QueueManager::register_queue (FastQueue *fq, message::qaddr_t s) |
register a queue | |
void | protlib::QueueManager::unregister_queue (message::qaddr_t s) |
deregister a queue | |
FastQueue * | protlib::QueueManager::get_queue (message::qaddr_t s) const |
get queue | |
protlib::QueueManager::QueueManager () | |
constructor | |
protlib::QueueManager::~QueueManager () | |
Destruktor. | |
Variables | |
static const char *const | protlib::QueueManagerError::errstr [] |
QueueManager error strings. | |
static QueueManager * | protlib::QueueManager::inst = NULL |
QueueManager instance. |
void protlib::QueueManager::clear | ( | ) | [static, inherited] |
clear QueueManager
Delete the QueueManager singleton object.
After a call to clear references to that object become invalid and must be updated by a call to instance().
Definition at line 80 of file queuemanager.cpp.
References DLog, and protlib::QueueManager::inst.
FastQueue * protlib::QueueManager::get_queue | ( | message::qaddr_t | s | ) | const [inherited] |
get queue
Definition at line 155 of file queuemanager.cpp.
References protlib::QueueManager::mutex, and protlib::QueueManager::queue_arr.
Referenced by protlib::message::get_source_queue(), protlib::TimerModule::process_queue(), ariba::transport::tcpip::receiverThread(), protlib::message::send(), protlib::message::send_back(), and protlib::message::send_to().
const char * protlib::QueueManagerError::getstr | ( | ) | const [virtual, inherited] |
Deprecated: Use what() instead.
Reimplemented from protlib::ProtLibException.
Definition at line 50 of file queuemanager.cpp.
References protlib::QueueManagerError::err, and protlib::QueueManagerError::errstr.
Referenced by protlib::QueueManagerError::what().
QueueManager * protlib::QueueManager::instance | ( | ) | [static, inherited] |
return QueueManager singleton instance
Return QueueManager singleton.
Definition at line 60 of file queuemanager.cpp.
References protlib::log::DEBUG_LOG, protlib::QueueManagerError::ERROR_NO_QUEUE_MANAGER, protlib::log::INFO_LOG, protlib::QueueManager::inst, Log, protlib::log::LOG_NORMAL, and protlib::QueueManager::QueueManager().
Referenced by protlib::message::get_source_queue(), protlib::TPoverTCP::main_loop(), protlib::TimerModule::process_queue(), ariba::transport::tcpip::receiverThread(), protlib::message::send(), protlib::message::send_back(), protlib::message::send_to(), ariba::transport::tcpip::start(), ariba::transport::tcpip::stop(), protlib::TimerModule::TimerModule(), protlib::TimerModule::~TimerModule(), and protlib::TPoverTCP::~TPoverTCP().
protlib::QueueManager::QueueManager | ( | ) | [private, inherited] |
constructor
Constructor.
Definition at line 172 of file queuemanager.cpp.
References protlib::QueueManager::mutex, PTHREAD_MUTEX_ERRORCHECK, PTHREAD_MUTEX_NORMAL, and pthread_mutexattr_settype.
Referenced by protlib::QueueManager::instance().
protlib::QueueManagerError::QueueManagerError | ( | error_t | e | ) | [inherited] |
void protlib::QueueManager::register_queue | ( | FastQueue * | fq, | |
message::qaddr_t | s | |||
) | [inherited] |
register a queue
Register a queue.
This registers a FastQueue for the given message source ID with the QueueManager.
The registered queue (and all its entries) is deleted as soon as the QueueManager is deleted. Because of this, a queue may only be registered once.
fq | pointer to an already allocated fastqueue | |
s | message source ID |
Definition at line 106 of file queuemanager.cpp.
References protlib::log::DEBUG_LOG, protlib::log::ERROR_LOG, protlib::QueueManagerError::ERROR_REGISTER, Log, protlib::log::LOG_CRIT, protlib::log::LOG_NORMAL, protlib::QueueManager::mutex, and protlib::QueueManager::queue_arr.
Referenced by protlib::TPoverTCP::main_loop(), ariba::transport::tcpip::start(), and protlib::TimerModule::TimerModule().
void protlib::QueueManager::unregister_queue | ( | message::qaddr_t | s | ) | [inherited] |
deregister a queue
Definition at line 140 of file queuemanager.cpp.
References protlib::QueueManager::mutex, and protlib::QueueManager::queue_arr.
Referenced by ariba::transport::tcpip::stop(), protlib::TimerModule::~TimerModule(), and protlib::TPoverTCP::~TPoverTCP().
protlib::QueueManager::~QueueManager | ( | ) | [private, inherited] |
Destruktor.
Destructor.
Delete this object and all FastQueue objects that are still registered.
Definition at line 194 of file queuemanager.cpp.
References protlib::QueueManager::mutex, protlib::QueueManager::queue_arr, and WLog.
const char *const protlib::QueueManagerError::errstr [static, private, inherited] |
Initial value:
{ "Unable to create QueueManager.", "Cannot register FastQueue. No memory or registered queue more than once." }
Definition at line 67 of file queuemanager.h.
Referenced by protlib::QueueManagerError::getstr().
QueueManager * protlib::QueueManager::inst = NULL [static, private, inherited] |
QueueManager instance.
Definition at line 100 of file queuemanager.h.
Referenced by protlib::QueueManager::clear(), and protlib::QueueManager::instance().