Nodelet to automatically subscribe/unsubscribe topics according to subscription of advertised topics. More...
#include <connection_based_nodelet.h>
Public Member Functions | |
ConnectionBasedNodelet () | |
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 () | |
virtual | ~Nodelet () |
Protected Member Functions | |
template<class T > | |
ros::Publisher | advertise (ros::NodeHandle &nh, std::string topic, int queue_size) |
Advertise a topic and watch the publisher. Publishers which are created by this method. It automatically reads latch boolean parameter from nh and publish topic with appropriate latch parameter. More... | |
image_transport::CameraPublisher | advertiseCamera (ros::NodeHandle &nh, image_transport::ImageTransport &it, const std::string &topic, int queue_size) |
image_transport::CameraPublisher | advertiseCamera (ros::NodeHandle &nh, const std::string &topic, int queue_size) |
image_transport::Publisher | advertiseImage (ros::NodeHandle &nh, image_transport::ImageTransport &it, const std::string &topic, int queue_size) |
image_transport::Publisher | advertiseImage (ros::NodeHandle &nh, const std::string &topic, int queue_size) |
Advertise an image topic and watch the publisher. Publishers which are created by this method. It automatically reads latch boolean parameter from nh and it and publish topic with appropriate latch parameter. More... | |
virtual void | cameraConnectionBaseCallback () |
callback function which is called when new subscriber come for camera image publisher or camera info publisher. This function is called from cameraConnectionCallback or cameraInfoConnectionCallback. More... | |
virtual void | cameraConnectionCallback (const image_transport::SingleSubscriberPublisher &pub) |
callback function which is called when new subscriber come for camera image publisher More... | |
virtual void | cameraInfoConnectionCallback (const ros::SingleSubscriberPublisher &pub) |
callback function which is called when new subscriber come for camera info publisher More... | |
virtual void | connectionCallback (const ros::SingleSubscriberPublisher &pub) |
callback function which is called when new subscriber come More... | |
virtual void | imageConnectionCallback (const image_transport::SingleSubscriberPublisher &pub) |
callback function which is called when new subscriber come for image publisher More... | |
virtual bool | isSubscribed () |
Returns true when this nodelet subscribes topics, false otherwise. More... | |
virtual void | onInit () |
Initialize nodehandles nh_ and pnh_. Subclass should call this method in its onInit method. More... | |
virtual void | onInitPostProcess () |
Post processing of initialization of nodelet. You need to call this method in order to use always_subscribe feature. More... | |
virtual void | subscribe ()=0 |
This method is called when publisher is subscribed by other nodes. Set up subscribers in this method. More... | |
virtual void | unsubscribe ()=0 |
This method is called when publisher is unsubscribed by other nodes. Shut down subscribers in this method. More... | |
virtual void | warnNeverSubscribedCallback (const ros::WallTimerEvent &event) |
callback function which is called when walltimer duration run out. More... | |
virtual void | warnOnInitPostProcessCalledCallback (const ros::WallTimerEvent &event) |
callback function which is called when walltimer duration run out. More... | |
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 Attributes | |
bool | always_subscribe_ |
A flag to disable watching mechanism and always subscribe input topics. It can be specified via ~always_subscribe parameter. More... | |
std::vector< image_transport::CameraPublisher > | camera_publishers_ |
List of watching camera publishers. More... | |
boost::mutex | connection_mutex_ |
mutex to call subscribe() and unsubscribe() in critical section. More... | |
ConnectionStatus | connection_status_ |
Status of connection. More... | |
bool | ever_subscribed_ |
A flag to check if the node has been ever subscribed or not. More... | |
std::vector< image_transport::Publisher > | image_publishers_ |
List of watching image publishers. More... | |
boost::shared_ptr< ros::NodeHandle > | nh_ |
Shared pointer to nodehandle. More... | |
bool | on_init_post_process_called_ |
Never warning on not calling onInitPostProcess if true. More... | |
boost::shared_ptr< ros::NodeHandle > | pnh_ |
Shared pointer to private nodehandle. More... | |
std::vector< ros::Publisher > | publishers_ |
List of watching publishers. More... | |
bool | subscribed_ |
A flag to check if any publisher is already subscribed or not. More... | |
ros::WallTimer | timer_warn_never_subscribed_ |
WallTimer instance for warning about no connection. More... | |
ros::WallTimer | timer_warn_on_init_post_process_called_ |
WallTimer instance for warning about no connection. More... | |
bool | verbose_connection_ |
true if ~verbose_connection or verbose_connection parameter is true. More... | |
Nodelet to automatically subscribe/unsubscribe topics according to subscription of advertised topics.
It's important not to subscribe topic if no output is required.
In order to watch advertised topics, need to use advertise template method. And create subscribers in subscribe() and shutdown them in unsubscribed().
Definition at line 68 of file connection_based_nodelet.h.
|
inline |
Definition at line 71 of file connection_based_nodelet.h.
|
inlineprotected |
Advertise a topic and watch the publisher. Publishers which are created by this method. It automatically reads latch boolean parameter from nh and publish topic with appropriate latch parameter.
nh | NodeHandle. |
topic | topic name to advertise. |
queue_size | queue size for publisher. |
latch | set true if latch topic publication. |
Definition at line 166 of file connection_based_nodelet.h.
|
inlineprotected |
Definition at line 234 of file connection_based_nodelet.h.
|
inlineprotected |
Definition at line 244 of file connection_based_nodelet.h.
|
inlineprotected |
Definition at line 187 of file connection_based_nodelet.h.
|
inlineprotected |
Advertise an image topic and watch the publisher. Publishers which are created by this method. It automatically reads latch boolean parameter from nh and it and publish topic with appropriate latch parameter.
nh | NodeHandle. |
topic | topic name to advertise. |
queue_size | queue size for publisher. |
latch | set true if latch topic publication. |
Definition at line 209 of file connection_based_nodelet.h.
|
protectedvirtual |
callback function which is called when new subscriber come for camera image publisher or camera info publisher. This function is called from cameraConnectionCallback or cameraInfoConnectionCallback.
Definition at line 189 of file connection_based_nodelet.cpp.
|
protectedvirtual |
callback function which is called when new subscriber come for camera image publisher
Definition at line 177 of file connection_based_nodelet.cpp.
|
protectedvirtual |
callback function which is called when new subscriber come for camera info publisher
Definition at line 183 of file connection_based_nodelet.cpp.
|
protectedvirtual |
callback function which is called when new subscriber come
Definition at line 110 of file connection_based_nodelet.cpp.
|
protectedvirtual |
callback function which is called when new subscriber come for image publisher
Definition at line 143 of file connection_based_nodelet.cpp.
|
inlineprotectedvirtual |
Returns true when this nodelet subscribes topics, false otherwise.
Definition at line 90 of file connection_based_nodelet.cpp.
|
protectedvirtual |
Initialize nodehandles nh_ and pnh_. Subclass should call this method in its onInit method.
Implements nodelet::Nodelet.
Reimplemented in jsk_topic_tools::DiagnosticNodelet, jsk_topic_tools::VitalCheckerNodelet, and jsk_topic_tools::StringRelay.
Definition at line 41 of file connection_based_nodelet.cpp.
|
protectedvirtual |
Post processing of initialization of nodelet. You need to call this method in order to use always_subscribe feature.
Definition at line 80 of file connection_based_nodelet.cpp.
|
protectedpure virtual |
This method is called when publisher is subscribed by other nodes. Set up subscribers in this method.
Implemented in jsk_topic_tools::VitalCheckerNodelet, and jsk_topic_tools::StringRelay.
|
protectedpure virtual |
This method is called when publisher is unsubscribed by other nodes. Shut down subscribers in this method.
Implemented in jsk_topic_tools::VitalCheckerNodelet, and jsk_topic_tools::StringRelay.
|
protectedvirtual |
callback function which is called when walltimer duration run out.
Definition at line 103 of file connection_based_nodelet.cpp.
|
protectedvirtual |
callback function which is called when walltimer duration run out.
Definition at line 96 of file connection_based_nodelet.cpp.
|
protected |
A flag to disable watching mechanism and always subscribe input topics. It can be specified via ~always_subscribe parameter.
Definition at line 326 of file connection_based_nodelet.h.
|
protected |
List of watching camera publishers.
Definition at line 293 of file connection_based_nodelet.h.
|
protected |
mutex to call subscribe() and unsubscribe() in critical section.
Definition at line 278 of file connection_based_nodelet.h.
|
protected |
Status of connection.
Definition at line 331 of file connection_based_nodelet.h.
|
protected |
A flag to check if the node has been ever subscribed or not.
Definition at line 320 of file connection_based_nodelet.h.
|
protected |
List of watching image publishers.
Definition at line 288 of file connection_based_nodelet.h.
|
protected |
Shared pointer to nodehandle.
Definition at line 298 of file connection_based_nodelet.h.
|
protected |
Never warning on not calling onInitPostProcess if true.
Definition at line 341 of file connection_based_nodelet.h.
|
protected |
Shared pointer to private nodehandle.
Definition at line 303 of file connection_based_nodelet.h.
|
protected |
List of watching publishers.
Definition at line 283 of file connection_based_nodelet.h.
|
protected |
A flag to check if any publisher is already subscribed or not.
Definition at line 314 of file connection_based_nodelet.h.
|
protected |
WallTimer instance for warning about no connection.
Definition at line 308 of file connection_based_nodelet.h.
|
protected |
WallTimer instance for warning about no connection.
Definition at line 346 of file connection_based_nodelet.h.
|
protected |
true if ~verbose_connection
or verbose_connection
parameter is true.
Definition at line 336 of file connection_based_nodelet.h.