ibrcommon::Queue< T > Class Template Reference
#include <Queue.h>
Classes | |
| class | Locked |
Public Types | |
| enum | WAIT_MODES { QUEUE_NOT_EMPTY = 0, QUEUE_EMPTY = 1 } |
Public Member Functions | |
| Queue (size_t max=0) | |
| virtual | ~Queue () |
| bool | empty () |
| size_t | size () const |
| T & | front () |
| const T & | front () const |
| T & | back () |
| const T & | back () const |
| void | push (const T &x) |
| void | pop () |
| T | getnpop (bool blocking=false, size_t timeout=0) throw (QueueUnblockedException) |
| void | abort () throw () |
| void | wait (WAIT_MODES mode, const size_t timeout=0) throw (QueueUnblockedException) |
| Queue< T >::Locked | exclusive () |
Protected Member Functions | |
| void | __push (const T &x) |
| void | __pop () |
| void | __wait (const WAIT_MODES mode) throw (QueueUnblockedException) |
| void | __wait (const WAIT_MODES mode, const size_t timeout) throw (QueueUnblockedException) |
Detailed Description
Member Enumeration Documentation
| enum ibrcommon::Queue::WAIT_MODES |
Constructor & Destructor Documentation
| ibrcommon::Queue< T >::Queue | ( | size_t | max = 0 | ) | [inline] |
| virtual ibrcommon::Queue< T >::~Queue | ( | ) | [inline, virtual] |
Member Function Documentation
| void ibrcommon::Queue< T >::__pop | ( | ) | [inline, protected] |
Definition at line 254 of file Queue.h.
Referenced by ibrcommon::Queue< StaticRoutingExtension::Task * >::getnpop(), and ibrcommon::Queue< StaticRoutingExtension::Task * >::pop().
| void ibrcommon::Queue< T >::__push | ( | const T & | x | ) | [inline, protected] |
| void ibrcommon::Queue< T >::__wait | ( | const WAIT_MODES | mode, |
| const size_t | timeout | ||
| ) | throw (QueueUnblockedException) [inline, protected] |
| void ibrcommon::Queue< T >::__wait | ( | const WAIT_MODES | mode | ) | throw (QueueUnblockedException) [inline, protected] |
Definition at line 264 of file Queue.h.
Referenced by ibrcommon::Queue< StaticRoutingExtension::Task * >::getnpop(), ibrcommon::Queue< T >::Locked::wait(), and ibrcommon::Queue< StaticRoutingExtension::Task * >::wait().
| void ibrcommon::Queue< T >::abort | ( | ) | throw () [inline] |
Definition at line 163 of file Queue.h.
Referenced by dtn::routing::StaticRoutingExtension::__cancellation(), dtn::routing::NeighborRoutingExtension::__cancellation(), dtn::routing::FloodRoutingExtension::__cancellation(), dtn::routing::EpidemicRoutingExtension::__cancellation(), dtn::core::SQLiteBundleStorage::__cancellation(), dtn::core::DataStorage::__cancellation(), dtn::core::EventSwitch::componentDown(), dtn::api::Client::eventConnectionDown(), dtn::routing::StaticRoutingExtension::stopExtension(), dtn::routing::NeighborRoutingExtension::stopExtension(), dtn::routing::FloodRoutingExtension::stopExtension(), dtn::routing::EpidemicRoutingExtension::stopExtension(), dtn::core::DataStorage::~DataStorage(), and ibrcommon::Queue< StaticRoutingExtension::Task * >::~Queue().
| T& ibrcommon::Queue< T >::back | ( | ) | [inline] |
| const T& ibrcommon::Queue< T >::back | ( | ) | const [inline] |
| bool ibrcommon::Queue< T >::empty | ( | ) | [inline] |
Definition at line 77 of file Queue.h.
Referenced by ibrcommon::vsocket::select().
| Queue<T>::Locked ibrcommon::Queue< T >::exclusive | ( | ) | [inline] |
Definition at line 242 of file Queue.h.
Referenced by ibrcommon::vsocket::select().
| const T& ibrcommon::Queue< T >::front | ( | ) | const [inline] |
| T& ibrcommon::Queue< T >::front | ( | ) | [inline] |
| T ibrcommon::Queue< T >::getnpop | ( | bool | blocking = false, |
| size_t | timeout = 0 |
||
| ) | throw (QueueUnblockedException) [inline] |
Definition at line 132 of file Queue.h.
Referenced by dtn::core::EventSwitch::componentDown(), dtn::core::SQLiteBundleStorage::componentRun(), dtn::net::TCPConnection::eventBundleForwarded(), dtn::api::ClientHandler::eventBundleForwarded(), dtn::net::TCPConnection::eventBundleRefused(), dtn::api::ClientHandler::eventBundleRefused(), dtn::core::EventSwitch::loop(), dtn::routing::StaticRoutingExtension::run(), dtn::routing::NeighborRoutingExtension::run(), dtn::routing::FloodRoutingExtension::run(), dtn::routing::EpidemicRoutingExtension::run(), dtn::core::DataStorage::run(), and dtn::core::DataStorage::~DataStorage().
| void ibrcommon::Queue< T >::pop | ( | ) | [inline] |
| void ibrcommon::Queue< T >::push | ( | const T & | x | ) | [inline] |
Definition at line 116 of file Queue.h.
Referenced by dtn::routing::StaticRoutingExtension::notify(), dtn::routing::NeighborRoutingExtension::notify(), dtn::routing::FloodRoutingExtension::notify(), dtn::routing::EpidemicRoutingExtension::notify(), dtn::net::operator<<(), dtn::api::operator<<(), dtn::core::SQLiteBundleStorage::raiseEvent(), dtn::core::EventSwitch::raiseEvent(), dtn::api::Client::received(), dtn::core::SQLiteBundleStorage::remove(), dtn::core::DataStorage::remove(), dtn::routing::NeighborRoutingExtension::run(), dtn::routing::FloodRoutingExtension::run(), dtn::routing::EpidemicRoutingExtension::run(), dtn::core::DataStorage::store(), and ibrcommon::vsocket::unbind().
| size_t ibrcommon::Queue< T >::size | ( | ) | const [inline] |
| void ibrcommon::Queue< T >::wait | ( | WAIT_MODES | mode, |
| const size_t | timeout = 0 |
||
| ) | throw (QueueUnblockedException) [inline] |
The documentation for this class was generated from the following file:
- ibrcommon/ibrcommon/thread/Queue.h
