This is the default implementation of the ros::CallbackQueueInterface. More...

#include <callback_queue.h>

Inheritance diagram for ros::CallbackQueue:

Classes
struct	CallbackInfo

struct	IDInfo

struct	TLS

Public Types
enum	CallOneResult { Called, TryAgain, Disabled, Empty }

Public Member Functions
virtual void	addCallback (const CallbackInterfacePtr &callback, uint64_t removal_id=0)
	Add a callback, with an optional owner id. The owner id can be used to remove a set of callbacks from this queue. More...

void	callAvailable ()
	Invoke all callbacks currently in the queue. If a callback was not ready to be called, pushes it back onto the queue. More...

void	callAvailable (ros::WallDuration timeout)
	Invoke all callbacks currently in the queue. If a callback was not ready to be called, pushes it back onto the queue. This version includes a timeout which lets you specify the amount of time to wait for a callback to be available before returning. More...

	CallbackQueue (bool enabled=true)

CallOneResult	callOne ()
	Pop a single callback off the front of the queue and invoke it. If the callback was not ready to be called, pushes it back onto the queue. More...

CallOneResult	callOne (ros::WallDuration timeout)
	Pop a single callback off the front of the queue and invoke it. If the callback was not ready to be called, pushes it back onto the queue. This version includes a timeout which lets you specify the amount of time to wait for a callback to be available before returning. More...

void	clear ()
	Removes all callbacks from the queue. Does not wait for calls currently in progress to finish. More...

void	disable ()
	Disable the queue, meaning any calls to addCallback() will have no effect. More...

bool	empty ()
	returns whether or not the queue is empty More...

void	enable ()
	Enable the queue (queue is enabled by default) More...

bool	isEmpty ()
	returns whether or not the queue is empty More...

bool	isEnabled ()
	Returns whether or not this queue is enabled. More...

virtual void	removeByID (uint64_t removal_id)
	Remove all callbacks associated with an owner id. More...

virtual	~CallbackQueue ()

Public Member Functions inherited from ros::CallbackQueueInterface
virtual	~CallbackQueueInterface ()

Protected Types
typedef std::deque< CallbackInfo >	D_CallbackInfo

typedef boost::shared_ptr< IDInfo >	IDInfoPtr

typedef std::list< CallbackInfo >	L_CallbackInfo

typedef std::map< uint64_t, IDInfoPtr >	M_IDInfo

Protected Member Functions
CallOneResult	callOneCB (TLS *tls)

IDInfoPtr	getIDInfo (uint64_t id)

void	setupTLS ()

Protected Attributes
D_CallbackInfo	callbacks_

size_t	calling_

ros::internal::condition_variable_monotonic	condition_

bool	enabled_

M_IDInfo	id_info_

boost::mutex	id_info_mutex_

boost::mutex	mutex_

boost::thread_specific_ptr< TLS >	tls_

Detailed Description

This is the default implementation of the ros::CallbackQueueInterface.

Definition at line 57 of file callback_queue.h.

Member Typedef Documentation

◆ D_CallbackInfo

typedef std::deque<CallbackInfo> ros::CallbackQueue::D_CallbackInfo

protected

Definition at line 162 of file callback_queue.h.

◆ IDInfoPtr

typedef boost::shared_ptr<IDInfo> ros::CallbackQueue::IDInfoPtr

protected

Definition at line 146 of file callback_queue.h.

◆ L_CallbackInfo

typedef std::list<CallbackInfo> ros::CallbackQueue::L_CallbackInfo

protected

Definition at line 161 of file callback_queue.h.

◆ M_IDInfo

typedef std::map<uint64_t, IDInfoPtr> ros::CallbackQueue::M_IDInfo

protected

Definition at line 147 of file callback_queue.h.

Member Enumeration Documentation

◆ CallOneResult

enum ros::CallbackQueue::CallOneResult

Enumerator
Called
TryAgain
Disabled
Empty

Definition at line 66 of file callback_queue.h.

Constructor & Destructor Documentation

◆ CallbackQueue()

ros::CallbackQueue::CallbackQueue ( bool enabled = true )

Definition at line 42 of file callback_queue.cpp.

◆ ~CallbackQueue()

ros::CallbackQueue::~CallbackQueue ( )

virtual

Definition at line 48 of file callback_queue.cpp.

Member Function Documentation

◆ addCallback()

void ros::CallbackQueue::addCallback	(	const CallbackInterfacePtr &	callback,
		uint64_t	owner_id = `0`
	)

virtual

Add a callback, with an optional owner id. The owner id can be used to remove a set of callbacks from this queue.

Implements ros::CallbackQueueInterface.

Definition at line 98 of file callback_queue.cpp.

◆ callAvailable() [1/2]

void ros::CallbackQueue::callAvailable ( )

inline

Invoke all callbacks currently in the queue. If a callback was not ready to be called, pushes it back onto the queue.

Definition at line 96 of file callback_queue.h.

◆ callAvailable() [2/2]

void ros::CallbackQueue::callAvailable ( ros::WallDuration timeout )

Invoke all callbacks currently in the queue. If a callback was not ready to be called, pushes it back onto the queue. This version includes a timeout which lets you specify the amount of time to wait for a callback to be available before returning.

Parameters

timeout The amount of time to wait for at least one callback to be available. If there is already at least one callback available, this parameter does nothing.

Definition at line 318 of file callback_queue.cpp.

◆ callOne() [1/2]

CallOneResult ros::CallbackQueue::callOne ( )

inline

Pop a single callback off the front of the queue and invoke it. If the callback was not ready to be called, pushes it back onto the queue.

Definition at line 78 of file callback_queue.h.

◆ callOne() [2/2]

CallbackQueue::CallOneResult ros::CallbackQueue::callOne ( ros::WallDuration timeout )

Pop a single callback off the front of the queue and invoke it. If the callback was not ready to be called, pushes it back onto the queue. This version includes a timeout which lets you specify the amount of time to wait for a callback to be available before returning.

Parameters

timeout The amount of time to wait for a callback to be available. If there is already a callback available, this parameter does nothing.

Definition at line 233 of file callback_queue.cpp.

◆ callOneCB()

CallbackQueue::CallOneResult ros::CallbackQueue::callOneCB ( TLS * tls )

protected

Definition at line 373 of file callback_queue.cpp.

◆ clear()

void ros::CallbackQueue::clear ( )

Removes all callbacks from the queue. Does not wait for calls currently in progress to finish.

Definition at line 69 of file callback_queue.cpp.

◆ disable()

void ros::CallbackQueue::disable ( )

Disable the queue, meaning any calls to addCallback() will have no effect.

Definition at line 61 of file callback_queue.cpp.

◆ empty()

bool ros::CallbackQueue::empty ( )

inline

returns whether or not the queue is empty

Definition at line 112 of file callback_queue.h.

◆ enable()

void ros::CallbackQueue::enable ( )

Enable the queue (queue is enabled by default)

Definition at line 53 of file callback_queue.cpp.

◆ getIDInfo()

CallbackQueue::IDInfoPtr ros::CallbackQueue::getIDInfo ( uint64_t id )

protected

Definition at line 133 of file callback_queue.cpp.

◆ isEmpty()

bool ros::CallbackQueue::isEmpty ( )

returns whether or not the queue is empty

Definition at line 76 of file callback_queue.cpp.

◆ isEnabled()

bool ros::CallbackQueue::isEnabled ( )

Returns whether or not this queue is enabled.

Definition at line 83 of file callback_queue.cpp.

◆ removeByID()

void ros::CallbackQueue::removeByID ( uint64_t owner_id )

virtual

Remove all callbacks associated with an owner id.

Implements ros::CallbackQueueInterface.

Definition at line 145 of file callback_queue.cpp.

◆ setupTLS()

void ros::CallbackQueue::setupTLS ( )

protected

Definition at line 90 of file callback_queue.cpp.

Member Data Documentation

◆ callbacks_

D_CallbackInfo ros::CallbackQueue::callbacks_

protected

Definition at line 163 of file callback_queue.h.

◆ calling_

size_t ros::CallbackQueue::calling_

protected

Definition at line 164 of file callback_queue.h.

◆ condition_

ros::internal::condition_variable_monotonic ros::CallbackQueue::condition_

protected

Definition at line 166 of file callback_queue.h.

◆ enabled_

bool ros::CallbackQueue::enabled_

protected

Definition at line 183 of file callback_queue.h.

◆ id_info_

M_IDInfo ros::CallbackQueue::id_info_

protected

Definition at line 169 of file callback_queue.h.

◆ id_info_mutex_

boost::mutex ros::CallbackQueue::id_info_mutex_

protected

Definition at line 168 of file callback_queue.h.

◆ mutex_

boost::mutex ros::CallbackQueue::mutex_

protected

Definition at line 165 of file callback_queue.h.

◆ tls_

boost::thread_specific_ptr<TLS> ros::CallbackQueue::tls_

protected

Definition at line 181 of file callback_queue.h.

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

Classes

Public Types

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Detailed Description

Member Typedef Documentation

◆ D_CallbackInfo

◆ IDInfoPtr

◆ L_CallbackInfo

◆ M_IDInfo

Member Enumeration Documentation

◆ CallOneResult

Constructor & Destructor Documentation

◆ CallbackQueue()

◆ ~CallbackQueue()

Member Function Documentation

◆ addCallback()

◆ callAvailable() [1/2]

◆ callAvailable() [2/2]

◆ callOne() [1/2]

◆ callOne() [2/2]

◆ callOneCB()

◆ clear()

◆ disable()

◆ empty()

◆ enable()

◆ getIDInfo()

◆ isEmpty()

◆ isEnabled()

◆ removeByID()

◆ setupTLS()

Member Data Documentation

◆ callbacks_

◆ calling_

◆ condition_

◆ enabled_

◆ id_info_

◆ id_info_mutex_

◆ mutex_

◆ tls_