IBR-DTNSuite
0.8
|
#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 | reset () |
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) |
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 267 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 | ) | throw (QueueUnblockedException) [inline, protected] |
Definition at line 277 of file Queue.h.
Referenced by ibrcommon::Queue< StaticRoutingExtension::Task * >::getnpop(), and ibrcommon::Queue< StaticRoutingExtension::Task * >::wait().
void ibrcommon::Queue< T >::__wait | ( | const WAIT_MODES | mode, |
const size_t | timeout | ||
) | throw (QueueUnblockedException) [inline, protected] |
void ibrcommon::Queue< T >::abort | ( | ) | throw () [inline] |
Definition at line 163 of file Queue.h.
Referenced by dtn::net::LOWPANConnectionSender::__cancellation(), dtn::core::FragmentManager::__cancellation(), dtn::routing::NeighborRoutingExtension::__cancellation(), dtn::routing::FloodRoutingExtension::__cancellation(), dtn::routing::StaticRoutingExtension::__cancellation(), dtn::routing::EpidemicRoutingExtension::__cancellation(), dtn::storage::DataStorage::__cancellation(), dtn::storage::SQLiteBundleStorage::__cancellation(), dtn::routing::ProphetRoutingExtension::__cancellation(), dtn::api::Registration::abort(), dtn::api::Client::abort(), dtn::api::Client::eventConnectionDown(), dtn::storage::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 255 of file Queue.h.
Referenced by ibrcommon::vsocket::select().
T& ibrcommon::Queue< T >::front | ( | ) | [inline] |
const T& ibrcommon::Queue< T >::front | ( | ) | const [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::FragmentManager::componentRun(), dtn::storage::SQLiteBundleStorage::componentRun(), dtn::api::BinaryStreamClient::eventBundleForwarded(), dtn::net::TCPConnection::eventBundleForwarded(), dtn::api::BinaryStreamClient::eventBundleRefused(), dtn::net::TCPConnection::eventBundleRefused(), dtn::api::Registration::receive(), dtn::api::Registration::receiveMetaBundle(), dtn::net::LOWPANConnectionSender::run(), dtn::routing::NeighborRoutingExtension::run(), dtn::api::ExtendedApiHandler::run(), dtn::routing::FloodRoutingExtension::run(), dtn::routing::StaticRoutingExtension::run(), dtn::routing::EpidemicRoutingExtension::run(), dtn::storage::DataStorage::run(), dtn::api::Registration::wait(), and dtn::storage::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::api::Registration::notify(), dtn::routing::ProphetRoutingExtension::notify(), dtn::net::operator<<(), dtn::net::LOWPANConnectionSender::queue(), dtn::storage::SQLiteBundleStorage::raiseEvent(), dtn::api::Client::received(), dtn::storage::SQLiteBundleStorage::remove(), dtn::storage::DataStorage::remove(), dtn::routing::NeighborRoutingExtension::run(), dtn::routing::StaticRoutingExtension::run(), dtn::core::FragmentManager::signal(), dtn::storage::DataStorage::store(), ibrcommon::vsocket::unbind(), and dtn::api::Registration::underflow().
void ibrcommon::Queue< T >::reset | ( | ) | [inline] |
Definition at line 169 of file Queue.h.
Referenced by dtn::api::Registration::detach().
size_t ibrcommon::Queue< T >::size | ( | ) | const [inline] |
void ibrcommon::Queue< T >::wait | ( | WAIT_MODES | mode, |
const size_t | timeout = 0 |
||
) | throw (QueueUnblockedException) [inline] |