#include <priority_mux.h>

Inheritance diagram for cras::PriorityMuxNodelet:

[legend]

Protected Member Functions
virtual void	cb (const ::ros::MessageEvent<::topic_tools::ShapeShifter const > &event, const ::std::string &inTopic)

virtual void	lockCb (const ::std::string &topic, const ::std_msgs::BoolConstPtr &msg)

void	onInit () override

void	onLockTimeout (const ::std::string &topic, const ::ros::TimerEvent &)

void	onPriorityTimeout (const ::ros::TimerEvent &)

void	onSelectedTopicTimeout (const ::std::string &outTopic, const ::ros::TimerEvent &)

void	publishPriorityChange (int newPriority, const ::ros::Duration &timeout)

void	publishSelectedTopicChange (const ::std::string &outTopic, const ::std::string &newTopic, const ::ros::Duration &timeout)

virtual void	updatePriorities (int newPriority, const ::std::string &newTopic)

Protected Member Functions inherited from nodelet::Nodelet
ros::CallbackQueueInterface &	getMTCallbackQueue () const

ros::NodeHandle &	getMTNodeHandle () const

ros::NodeHandle &	getMTPrivateNodeHandle () const

const V_string &	getMyArgv () const

const std::string &	getName () const

ros::NodeHandle &	getNodeHandle () const

ros::NodeHandle &	getPrivateNodeHandle () const

const M_string &	getRemappingArgs () const

ros::CallbackQueueInterface &	getSTCallbackQueue () const

std::string	getSuffixedName (const std::string &suffix) const

Protected Member Functions inherited from NodeletWithDiagnostics< ::nodelet::Nodelet >
::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, ::ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, ::ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, ::ros::NodeHandle diagNh, const ::std::string &diagNamespace, ::ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, const ::std::string &diagNamespace, const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, const ::std::string &diagNamespace, ::ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (const ::std::string &diagNamespace, const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, ::ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (const ::std::string &diagNamespace, ::ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, ::ros::NodeHandle diagNh, const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, ::ros::NodeHandle diagNh, const ::std::string &diagNamespace, const ::std::string &topic, size_t queueSize, bool latch=false)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, ::ros::NodeHandle diagNh, ros::AdvertiseOptions &options)

::std::unique_ptr<::cras::DiagnosedPublisher< Message > >	advertiseDiagnosed (::ros::NodeHandle publisherNh, const ::std::string &topic, size_t queueSize, bool latch=false)

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(::ros::NodeHandle subscriberNh,), CRAS_SINGLE_ARG(subscriberNh, this->getDefaultDiagNh(subscriberNh, diagNamespace),), CRAS_SINGLE_ARG(const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >> &defaultDiagParams, const ::std::string &diagNamespace,), CRAS_SINGLE_ARG(defaultDiagParams, diagNamespace,))

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(), CRAS_SINGLE_ARG(this->getNodeHandle(),), CRAS_SINGLE_ARG(const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >> &defaultDiagParams, const ::std::string &diagNamespace,), CRAS_SINGLE_ARG(defaultDiagParams, diagNamespace,))

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh,), CRAS_SINGLE_ARG(subscriberNh, diagNh,), CRAS_SINGLE_ARG(const ::std::string &diagNamespace,), CRAS_SINGLE_ARG(::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >>(), diagNamespace,))

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(::ros::NodeHandle subscriberNh,), CRAS_SINGLE_ARG(subscriberNh, this->getDefaultDiagNh(subscriberNh, diagNamespace),), CRAS_SINGLE_ARG(const ::std::string &diagNamespace,), CRAS_SINGLE_ARG(::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >>(), diagNamespace,))

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(), CRAS_SINGLE_ARG(this->getNodeHandle(),), CRAS_SINGLE_ARG(const ::std::string &diagNamespace,), CRAS_SINGLE_ARG(::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >>(), diagNamespace,))

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh,), CRAS_SINGLE_ARG(subscriberNh, diagNh,), CRAS_SINGLE_ARG(), CRAS_SINGLE_ARG("",))

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(::ros::NodeHandle subscriberNh,), CRAS_SINGLE_ARG(subscriberNh, this->getDefaultDiagNh(subscriberNh, ""),), CRAS_SINGLE_ARG(), CRAS_SINGLE_ARG("",))

	CRAS_NODELET_DIAG_GENERATE_OVERLOADS (CRAS_SINGLE_ARG(), CRAS_SINGLE_ARG(this->getNodeHandle(),), CRAS_SINGLE_ARG(), CRAS_SINGLE_ARG("",))

::std::unique_ptr<::cras::DiagnosedPublisher< T > >	createDiagnosedPublisher (::ros::NodeHandle nh, const ::std::string &topic, size_t queueSize, const ::std::string &paramNamespace, const ::ros::Rate &defaultRate, const ::ros::Rate &defaultMinRate, const ::ros::Rate &defaultMaxRate)

::std::unique_ptr<::cras::DiagnosedPublisher< T > >	createDiagnosedPublisher (::ros::NodeHandle nh, const ::std::string &topic, size_t queueSize, const ::std::string &paramNamespace, const ::ros::Rate &defaultRate)

::std::unique_ptr<::cras::DiagnosedPublisher< T > >	createDiagnosedPublisher (::ros::NodeHandle nh, const ::std::string &topic, size_t queueSize, const ::std::string &paramNamespace)

::ros::NodeHandle	getDefaultDiagNh (const ::ros::NodeHandle &pubSubNh, const ::std::string &diagNamespace)

::cras::BoundParamHelperPtr	getDiagParams (const ::ros::NodeHandle &nh, const ::std::string &diagNamespace, const ::std::string &topic)

::cras::DiagnosticUpdater &	getDiagUpdater (bool forceNew=false) const

void	startDiagTimer () const

void	startDiagTimer (const ::ros::NodeHandle &nh) const

void	stopDiagTimer () const

::std::unique_ptr<::cras::DiagnosedSubscriber<::cras::BaseMessage< C > > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< C >> &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, uint32_t queue_size, const ::boost::function< void(C)> &cb, ::ros::VoidConstPtr obj={}, ::ros::TransportHints hints={})

::std::unique_ptr<::cras::DiagnosedSubscriber<::cras::BaseMessage< M > > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >> &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, uint32_t queue_size, void(T::*cb)(M) const, const ::boost::shared_ptr< T > &obj, ::ros::TransportHints hints={})

::std::unique_ptr<::cras::DiagnosedSubscriber<::cras::BaseMessage< M > > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >> &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, uint32_t queue_size, void(T::cb)(M) const, T obj, ::ros::TransportHints hints={})

::std::unique_ptr<::cras::DiagnosedSubscriber<::cras::BaseMessage< M > > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >> &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, uint32_t queue_size, void(T::cb)(M), T obj, ::ros::TransportHints hints={})

::std::unique_ptr<::cras::DiagnosedSubscriber< Message > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, uint32_t queue_size, const ::boost::function< void(const ::boost::shared_ptr< Message > &)> &cb, ::ros::TransportHints hints={})

::std::unique_ptr<::cras::DiagnosedSubscriber< Message > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam< Message > &defaultDiagParams, const ::std::string &diagNamespace, ::ros::SubscribeOptions &options)

::std::unique_ptr<::cras::DiagnosedSubscriber<::cras::BaseMessage< M > > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >> &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, uint32_t queue_size, void(T::*cb)(M), const ::boost::shared_ptr< T > &obj, ::ros::TransportHints hints={})

::std::unique_ptr<::cras::DiagnosedSubscriber<::cras::BaseMessage< M > > >	subscribeDiagnosed (::ros::NodeHandle subscriberNh, ::ros::NodeHandle diagNh, const ::cras::SimpleTopicStatusParam<::cras::BaseMessage< M >> &defaultDiagParams, const ::std::string &diagNamespace, const ::std::string &topic, uint32_t queue_size, void(*cb)(M), ::ros::TransportHints hints={})

Protected Member Functions inherited from ThreadNameUpdatingNodelet< ::nodelet::Nodelet >
void	updateThreadName () const

Protected Member Functions inherited from NodeletParamHelper< ::nodelet::Nodelet >
ResultType	getParam (const ::ros::NodeHandle &node, const ::std::string &name, const ::cras::optional< ResultType > &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={})

ResultType	getParam (const ::ros::NodeHandle &node, const ::std::string &name, const ResultType &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={})

inline ::std::string	getParam (const ::ros::NodeHandle &node, const ::std::string &name, const char *defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={})

inline ::std::string	getParam (const ::ros::NodeHandle &node, const ::std::string &name, const ::cras::optional< const char *> &defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={})

inline ::cras::GetParamResult<::std::string >	getParamVerbose (const ::ros::NodeHandle &node, const ::std::string &name, const char *defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={})

inline ::cras::GetParamResult< ResultType >	getParamVerbose (const ::ros::NodeHandle &node, const ::std::string &name, const ::cras::optional< ResultType > &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={})

inline ::cras::GetParamResult<::std::string >	getParamVerbose (const ::ros::NodeHandle &node, const ::std::string &name, const ::cras::optional< const char *> &defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={})

inline ::cras::GetParamResult< ResultType >	getParamVerbose (const ::ros::NodeHandle &node, const ::std::string &name, const ResultType &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={})

::cras::BoundParamHelperPtr	params (const ::ros::NodeHandle &node, const ::std::string &ns="") const

::cras::BoundParamHelperPtr	paramsForNodeHandle (const ::ros::NodeHandle &node) const

::cras::BoundParamHelperPtr	privateParams (const ::std::string &ns="") const

::cras::BoundParamHelperPtr	publicParams (const ::std::string &ns="") const

Protected Attributes
::ros::Publisher	activePriorityPub

int	lastActivePriority {0}

::std::map<::std::pair< int, ::std::string >, ::ros::Time >	lastLockStamps

::std::map<::std::pair< int, ::std::string >, ::ros::Time >	lastReceiveStamps

::std::unordered_map<::std::string, ::std::string >	lastSelectedTopics

::std::unordered_map<::std::string, ::cras::priority_mux::LockConfig >	lockConfigs

::std::unordered_map<::std::string, ::ros::Publisher >	lockedPublishers

::std::unordered_map<::std::string, ::ros::Timer >	lockTimeoutTimers

size_t	outQueueSize {10u}

::ros::Timer	priorityBackToNoneTimer

int	priorityNone {0}

::std::unordered_map<::std::string, ::ros::Publisher >	publishers

::std::unordered_map<::std::string, ::ros::Timer >	selectedBackToNoneTimers

::std::unordered_map<::std::string, ::ros::Publisher >	selectedPublishers

::std::list<::ros::Subscriber >	subscribers

::std::unordered_map<::std::string, ::cras::priority_mux::TopicConfig >	topicConfigs

Protected Attributes inherited from cras::HasLogger
::cras::LogHelperPtr	log

Protected Attributes inherited from cras::InterruptibleSleepInterface
::ros::WallDuration	pollDuration

Additional Inherited Members
Public Member Functions inherited from cras::Nodelet
	~Nodelet () override=default

Public Member Functions inherited from NodeletBase<::nodelet::Nodelet >
	~NodeletBase () override=default

Public Member Functions inherited from nodelet::Nodelet
void	init (const std::string &name, const M_string &remapping_args, const V_string &my_argv, ros::CallbackQueueInterface st_queue=NULL, ros::CallbackQueueInterface mt_queue=NULL)

	Nodelet ()

Public Member Functions inherited from NodeletWithDiagnostics< ::nodelet::Nodelet >
	NodeletWithDiagnostics ()

virtual	~NodeletWithDiagnostics ()

Public Member Functions inherited from NodeletWithSharedTfBuffer< ::nodelet::Nodelet >
::cras::NodeletAwareTFBuffer &	getBuffer () const override

	NodeletWithSharedTfBuffer ()

void	setBuffer (const ::std::shared_ptr<::tf2_ros::Buffer > &buffer) override

bool	usesSharedBuffer () const override

virtual	~NodeletWithSharedTfBuffer ()

Public Member Functions inherited from ThreadNameUpdatingNodelet< ::nodelet::Nodelet >
	~ThreadNameUpdatingNodelet () override

Public Member Functions inherited from NodeletParamHelper< ::nodelet::Nodelet >
	NodeletParamHelper ()

	~NodeletParamHelper () override

Public Member Functions inherited from cras::ParamHelper
::cras::LogHelperPtr	getLogger () const

ResultType	getParam (const ::cras::GetParamAdapter &param, const ::std::string &name, const ::cras::optional< ResultType > &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={}) const

inline ::std::string	getParam (const ::cras::GetParamAdapter &param, const ::std::string &name, const ::cras::optional< const char * > &defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={}) const

inline ::std::string	getParam (const ::cras::GetParamAdapter &param, const ::std::string &name, const char *defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={}) const

ResultType	getParam (const ::cras::GetParamAdapter &param, const ::std::string &name, const ResultType &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={}) const

inline ::cras::GetParamResult<::std::string >	getParamVerbose (const ::cras::GetParamAdapter &param, const ::std::string &name, const ::cras::optional< const char * > &defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={}) const

inline ::cras::GetParamResult< ResultType >	getParamVerbose (const ::cras::GetParamAdapter &param, const ::std::string &name, const ResultType &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={}) const

inline ::cras::GetParamResult<::std::string >	getParamVerbose (const ::cras::GetParamAdapter &param, const ::std::string &name, const char *defaultValue, const ::std::string &unit="", const ::cras::GetParamOptions<::std::string > &options={}) const

inline ::cras::GetParamResult< ResultType >	getParamVerbose (const ::cras::GetParamAdapter &param, const ::std::string &name, const ::cras::optional< ResultType > &defaultValue=ResultType(), const ::std::string &unit="", const ::cras::GetParamOptions< ResultType, ParamServerType > &options={}) const

	ParamHelper (const ::cras::LogHelperPtr &log)

void	setLogger (const ::cras::LogHelperPtr &logger)

virtual	~ParamHelper ()=default

Public Member Functions inherited from cras::HasLogger
::cras::LogHelperConstPtr	getCrasLogger () const

	HasLogger (const ::cras::LogHelperPtr &log)

void	setCrasLogger (const ::cras::LogHelperPtr &log)

Public Member Functions inherited from StatefulNodelet< ::nodelet::Nodelet >
bool	ok () const override

void	requestStop () override

void	shutdown ()

virtual	~StatefulNodelet ()

Public Member Functions inherited from cras::InterruptibleSleepInterface
	InterruptibleSleepInterface ()

virtual bool	sleep (const ::ros::Duration &duration) const

virtual	~InterruptibleSleepInterface ()

Detailed Description

Definition at line 51 of file priority_mux.h.

Member Function Documentation

◆ cb()

void cras::PriorityMuxNodelet::cb	(	const ::ros::MessageEvent<::topic_tools::ShapeShifter const > &	event,
		const ::std::string &	inTopic
	)

protectedvirtual

Definition at line 209 of file priority_mux.cpp.

◆ lockCb()

void cras::PriorityMuxNodelet::lockCb	(	const ::std::string &	topic,
		const ::std_msgs::BoolConstPtr &	msg
	)

protectedvirtual

Definition at line 273 of file priority_mux.cpp.

◆ onInit()

void cras::PriorityMuxNodelet::onInit ( )

overrideprotectedvirtual

Implements nodelet::Nodelet.

Definition at line 28 of file priority_mux.cpp.

◆ onLockTimeout()

void cras::PriorityMuxNodelet::onLockTimeout	(	const ::std::string &	topic,
		const ::ros::TimerEvent &
	)

protected

Definition at line 391 of file priority_mux.cpp.

◆ onPriorityTimeout()

void cras::PriorityMuxNodelet::onPriorityTimeout ( const ::ros::TimerEvent & )

protected

Definition at line 373 of file priority_mux.cpp.

◆ onSelectedTopicTimeout()

void cras::PriorityMuxNodelet::onSelectedTopicTimeout	(	const ::std::string &	outTopic,
		const ::ros::TimerEvent &
	)

protected

Definition at line 382 of file priority_mux.cpp.

◆ publishPriorityChange()

void cras::PriorityMuxNodelet::publishPriorityChange	(	int	newPriority,
		const ::ros::Duration &	timeout
	)

protected

Definition at line 348 of file priority_mux.cpp.

◆ publishSelectedTopicChange()

void cras::PriorityMuxNodelet::publishSelectedTopicChange	(	const ::std::string &	outTopic,
		const ::std::string &	newTopic,
		const ::ros::Duration &	timeout
	)

protected

Definition at line 360 of file priority_mux.cpp.

◆ updatePriorities()

void cras::PriorityMuxNodelet::updatePriorities	(	int	newPriority,
		const ::std::string &	newTopic
	)

protectedvirtual

Definition at line 316 of file priority_mux.cpp.

Member Data Documentation

◆ activePriorityPub

::ros::Publisher cras::PriorityMuxNodelet::activePriorityPub

protected

Definition at line 69 of file priority_mux.h.

◆ lastActivePriority

int cras::PriorityMuxNodelet::lastActivePriority {0}

protected

Definition at line 85 of file priority_mux.h.

◆ lastLockStamps

::std::map<::std::pair<int, ::std::string>, ::ros::Time> cras::PriorityMuxNodelet::lastLockStamps

protected

Definition at line 81 of file priority_mux.h.

◆ lastReceiveStamps

::std::map<::std::pair<int, ::std::string>, ::ros::Time> cras::PriorityMuxNodelet::lastReceiveStamps

protected

Definition at line 80 of file priority_mux.h.

◆ lastSelectedTopics

::std::unordered_map<::std::string, ::std::string> cras::PriorityMuxNodelet::lastSelectedTopics

protected

Definition at line 86 of file priority_mux.h.

◆ lockConfigs

::std::unordered_map<::std::string, ::cras::priority_mux::LockConfig> cras::PriorityMuxNodelet::lockConfigs

protected

Definition at line 78 of file priority_mux.h.

◆ lockedPublishers

::std::unordered_map<::std::string, ::ros::Publisher> cras::PriorityMuxNodelet::lockedPublishers

protected

Definition at line 71 of file priority_mux.h.

◆ lockTimeoutTimers

::std::unordered_map<::std::string, ::ros::Timer> cras::PriorityMuxNodelet::lockTimeoutTimers

protected

Definition at line 75 of file priority_mux.h.

◆ outQueueSize

size_t cras::PriorityMuxNodelet::outQueueSize {10u}

protected

Definition at line 83 of file priority_mux.h.

◆ priorityBackToNoneTimer

::ros::Timer cras::PriorityMuxNodelet::priorityBackToNoneTimer

protected

Definition at line 73 of file priority_mux.h.

◆ priorityNone

int cras::PriorityMuxNodelet::priorityNone {0}

protected

Definition at line 84 of file priority_mux.h.

◆ publishers

::std::unordered_map<::std::string, ::ros::Publisher> cras::PriorityMuxNodelet::publishers

protected

Definition at line 68 of file priority_mux.h.

◆ selectedBackToNoneTimers

::std::unordered_map<::std::string, ::ros::Timer> cras::PriorityMuxNodelet::selectedBackToNoneTimers

protected

Definition at line 74 of file priority_mux.h.

◆ selectedPublishers

::std::unordered_map<::std::string, ::ros::Publisher> cras::PriorityMuxNodelet::selectedPublishers

protected

Definition at line 70 of file priority_mux.h.

◆ subscribers

::std::list<::ros::Subscriber> cras::PriorityMuxNodelet::subscribers

protected

Definition at line 67 of file priority_mux.h.

◆ topicConfigs

::std::unordered_map<::std::string, ::cras::priority_mux::TopicConfig> cras::PriorityMuxNodelet::topicConfigs

protected

Definition at line 77 of file priority_mux.h.

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

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Member Function Documentation

◆ cb()

◆ lockCb()

◆ onInit()

◆ onLockTimeout()

◆ onPriorityTimeout()

◆ onSelectedTopicTimeout()

◆ publishPriorityChange()

◆ publishSelectedTopicChange()

◆ updatePriorities()

Member Data Documentation

◆ activePriorityPub

◆ lastActivePriority

◆ lastLockStamps

◆ lastReceiveStamps

◆ lastSelectedTopics

◆ lockConfigs

◆ lockedPublishers

◆ lockTimeoutTimers

◆ outQueueSize

◆ priorityBackToNoneTimer

◆ priorityNone

◆ publishers

◆ selectedBackToNoneTimers

◆ selectedPublishers

◆ subscribers

◆ topicConfigs