#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) |
Definition at line 60 of file Queue.h.
| enum ibrcommon::Queue::WAIT_MODES |
| ibrcommon::Queue< T >::Queue | ( | size_t | max = 0 |
) | [inline] |
| virtual ibrcommon::Queue< T >::~Queue | ( | ) | [inline, virtual] |
| void ibrcommon::Queue< T >::__pop | ( | ) | [inline, protected] |
Definition at line 254 of file Queue.h.
Referenced by ibrcommon::Queue< Task * >::getnpop(), and ibrcommon::Queue< 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< Task * >::getnpop(), ibrcommon::Queue< T >::Locked::wait(), and ibrcommon::Queue< Task * >::wait().
| void ibrcommon::Queue< T >::abort | ( | ) | throw () [inline] |
Definition at line 163 of file Queue.h.
Referenced by dtn::routing::NeighborRoutingExtension::__cancellation(), dtn::routing::FloodRoutingExtension::__cancellation(), dtn::routing::EpidemicRoutingExtension::__cancellation(), dtn::core::SimpleBundleStorage::__cancellation(), dtn::core::SimpleBundleStorage::componentDown(), dtn::core::EventSwitch::componentDown(), dtn::api::Client::eventConnectionDown(), dtn::routing::NeighborRoutingExtension::stopExtension(), dtn::routing::FloodRoutingExtension::stopExtension(), dtn::routing::EpidemicRoutingExtension::stopExtension(), ibrcommon::Queue< Task * >::~Queue(), and dtn::core::SimpleBundleStorage::~SimpleBundleStorage().
| T& ibrcommon::Queue< T >::back | ( | ) | [inline] |
| const T& ibrcommon::Queue< T >::back | ( | ) | const [inline] |
| bool ibrcommon::Queue< T >::empty | ( | ) | [inline] |
| Queue<T>::Locked ibrcommon::Queue< T >::exclusive | ( | ) | [inline] |
| 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::SimpleBundleStorage::componentRun(), dtn::net::TCPConvergenceLayer::TCPConnection::eventBundleForwarded(), dtn::daemon::ClientHandler::eventBundleForwarded(), dtn::net::TCPConvergenceLayer::TCPConnection::eventBundleRefused(), dtn::daemon::ClientHandler::eventBundleRefused(), dtn::api::Client::getBundle(), dtn::core::EventSwitch::loop(), dtn::routing::NeighborRoutingExtension::run(), dtn::routing::FloodRoutingExtension::run(), and dtn::routing::EpidemicRoutingExtension::run().
| 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::NeighborRoutingExtension::notify(), dtn::routing::FloodRoutingExtension::notify(), dtn::routing::EpidemicRoutingExtension::notify(), dtn::net::operator<<(), dtn::daemon::operator<<(), dtn::core::SimpleBundleStorage::raiseEvent(), dtn::core::EventSwitch::raiseEvent(), dtn::api::Client::received(), dtn::core::SimpleBundleStorage::remove(), dtn::routing::FloodRoutingExtension::run(), dtn::routing::EpidemicRoutingExtension::run(), and dtn::core::SimpleBundleStorage::store().
| size_t ibrcommon::Queue< T >::size | ( | ) | const [inline] |
| void ibrcommon::Queue< T >::wait | ( | WAIT_MODES | mode, | |
| const size_t | timeout = 0 | |||
| ) | throw (QueueUnblockedException) [inline] |
1.7.1