|
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] |
constructor
Definition at line 48 of file queuemanager.cpp.
| 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] |
{
"Unable to create QueueManager.",
"Cannot register FastQueue. No memory or registered queue more than once."
}
QueueManager error strings.
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().
1.6.1