#include <Queue.h>

Collaboration diagram for ibrcommon::Queue< T >:

Classes
class	Locked

Public Types
enum	WAIT_MODES { QUEUE_NOT_EMPTY = 0, QUEUE_EMPTY = 1 }

Public Member Functions
	Queue (unsigned int 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	get (bool blocking=false, size_t timeout=0) throw (QueueUnblockedException)

T	getnpop (bool blocking=false, size_t timeout=0) throw (QueueUnblockedException)

void	abort () throw ()

void	reset () 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

template<class T>
class ibrcommon::Queue< T >

Definition at line 74 of file Queue.h.

Member Enumeration Documentation

template<class T>

enum ibrcommon::Queue::WAIT_MODES

Enumerator
QUEUE_NOT_EMPTY
QUEUE_EMPTY

Definition at line 217 of file Queue.h.

Constructor & Destructor Documentation

template<class T>

ibrcommon::Queue< T >::Queue ( unsigned int max = 0)

inline

Definition at line 82 of file Queue.h.

template<class T>

virtual ibrcommon::Queue< T >::~Queue ( )

inlinevirtual

Definition at line 85 of file Queue.h.

Member Function Documentation

template<class T>

void ibrcommon::Queue< T >::__pop ( )

inlineprotected

Definition at line 310 of file Queue.h.

Referenced by ibrcommon::Queue< dtn::net::BundleTransfer >::getnpop(), and ibrcommon::Queue< dtn::net::BundleTransfer >::pop().

template<class T>

void ibrcommon::Queue< T >::__push ( const T & x)

inlineprotected

Definition at line 304 of file Queue.h.

template<class T>

void ibrcommon::Queue< T >::__wait	(	const WAIT_MODES	mode)
throw	(	QueueUnblockedException
	)

inlineprotected

Definition at line 320 of file Queue.h.

Referenced by ibrcommon::Queue< dtn::net::BundleTransfer >::get(), ibrcommon::Queue< dtn::net::BundleTransfer >::getnpop(), and ibrcommon::Queue< dtn::net::BundleTransfer >::wait().

template<class T>

void ibrcommon::Queue< T >::__wait	(	const WAIT_MODES	mode,
		const size_t	timeout
	)
throw	(	QueueUnblockedException
	)

inlineprotected

Definition at line 358 of file Queue.h.

template<class T>

void ibrcommon::Queue< T >::abort	(	)
throw	(
	)

inline

Definition at line 206 of file Queue.h.

Referenced by dtn::net::LOWPANConnectionSender::__cancellation(), ibrcommon::SignalHandler::__cancellation(), dtn::core::FragmentManager::__cancellation(), dtn::routing::ProphetRoutingExtension::__cancellation(), dtn::storage::DataStorage::__cancellation(), dtn::net::EMailSmtpService::__cancellation(), dtn::storage::SQLiteBundleStorage::__cancellation(), dtn::api::Client::abort(), dtn::api::Registration::abort(), dtn::api::Client::eventConnectionDown(), dtn::storage::DataStorage::~DataStorage(), and ibrcommon::Queue< dtn::net::BundleTransfer >::~Queue().

template<class T>

T& ibrcommon::Queue< T >::back ( )

inline

Definition at line 117 of file Queue.h.

template<class T>

const T& ibrcommon::Queue< T >::back ( ) const

inline

Definition at line 123 of file Queue.h.

template<class T>

bool ibrcommon::Queue< T >::empty ( )

inline

Definition at line 91 of file Queue.h.

template<class T>

Queue<T>::Locked ibrcommon::Queue< T >::exclusive ( )

inline

Definition at line 298 of file Queue.h.

Referenced by dtn::net::TCPConnection::clearQueue(), dtn::net::TCPConnection::eventBundleForwarded(), and dtn::net::TCPConnection::eventBundleRefused().

template<class T>

T& ibrcommon::Queue< T >::front ( )

inline

Definition at line 104 of file Queue.h.

template<class T>

const T& ibrcommon::Queue< T >::front ( ) const

inline

Definition at line 110 of file Queue.h.

template<class T>

T ibrcommon::Queue< T >::get	(	bool	blocking = `false`,
		size_t	timeout = `0`
	)
throw	(	QueueUnblockedException
	)

inline

Definition at line 146 of file Queue.h.

Referenced by dtn::storage::DataStorage::run().

template<class T>

T ibrcommon::Queue< T >::getnpop	(	bool	blocking = `false`,
		size_t	timeout = `0`
	)
throw	(	QueueUnblockedException
	)

inline

Definition at line 175 of file Queue.h.

Referenced by dtn::core::FragmentManager::componentRun(), dtn::net::DatagramConvergenceLayer::componentRun(), dtn::storage::SQLiteBundleStorage::componentRun(), dtn::api::BinaryStreamClient::eventBundleForwarded(), dtn::api::BinaryStreamClient::eventBundleRefused(), dtn::net::LOWPANConnectionSender::run(), ibrcommon::SignalHandler::run(), dtn::api::ExtendedApiHandler::run(), dtn::net::EMailSmtpService::run(), dtn::api::Registration::wait(), and dtn::storage::DataStorage::~DataStorage().

template<class T>

void ibrcommon::Queue< T >::pop ( )

inline

Definition at line 140 of file Queue.h.

Referenced by dtn::storage::DataStorage::run().

template<class T>

void ibrcommon::Queue< T >::push ( const T & x)

inline

Definition at line 130 of file Queue.h.

Referenced by dtn::net::DatagramConvergenceLayer::componentDown(), dtn::net::DatagramConvergenceLayer::connectionDown(), dtn::api::Registration::notify(), dtn::net::LOWPANConnectionSender::queue(), dtn::net::DatagramConvergenceLayer::queue(), dtn::net::EMailSmtpService::queueTask(), dtn::net::DatagramConvergenceLayer::receive(), dtn::api::NativeSession::receive(), dtn::api::Client::received(), dtn::storage::DataStorage::remove(), dtn::core::FragmentManager::signal(), dtn::storage::DataStorage::store(), and dtn::net::EMailSmtpService::submitNow().

template<class T>

void ibrcommon::Queue< T >::reset	(	)
throw	(
	)

inline

Definition at line 212 of file Queue.h.

Referenced by dtn::routing::ProphetRoutingExtension::componentUp(), and dtn::api::Registration::detach().

template<class T>

size_t ibrcommon::Queue< T >::size ( ) const

inline

Definition at line 98 of file Queue.h.

template<class T>

void ibrcommon::Queue< T >::wait	(	WAIT_MODES	mode,
		const size_t	timeout = `0`
	)
throw	(	QueueUnblockedException
	)

inline

Definition at line 223 of file Queue.h.

Referenced by dtn::storage::DataStorage::wait(), and dtn::storage::SQLiteBundleStorage::wait().

The documentation for this class was generated from the following file:

ibrcommon/ibrcommon/thread/Queue.h

Classes

Public Types

Public Member Functions

Protected Member Functions

Detailed Description

template<class T> class ibrcommon::Queue< T >

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

template<class T>
class ibrcommon::Queue< T >