SubscriberLink handles broadcasting messages to a single subscriber on a single topic. More...
#include <intraprocess_subscriber_link.h>
Public Member Functions | |
virtual void | drop () |
virtual void | enqueueMessage (const SerializedMessage &m, bool ser, bool nocopy) |
Queue up a message for publication. Throws out old messages if we've reached our Publication's max queue size. | |
virtual void | getPublishTypes (bool &ser, bool &nocopy, const std::type_info &ti) |
virtual std::string | getTransportType () |
IntraProcessSubscriberLink (const PublicationPtr &parent) | |
virtual bool | isIntraprocess () |
bool | isLatching () |
void | setSubscriber (const IntraProcessPublisherLinkPtr &subscriber) |
virtual | ~IntraProcessSubscriberLink () |
Private Attributes | |
boost::recursive_mutex | drop_mutex_ |
bool | dropped_ |
IntraProcessPublisherLinkPtr | subscriber_ |
SubscriberLink handles broadcasting messages to a single subscriber on a single topic.
Definition at line 39 of file intraprocess_subscriber_link.h.
ros::IntraProcessSubscriberLink::IntraProcessSubscriberLink | ( | const PublicationPtr & | parent | ) |
Definition at line 34 of file intraprocess_subscriber_link.cpp.
ros::IntraProcessSubscriberLink::~IntraProcessSubscriberLink | ( | ) | [virtual] |
Definition at line 42 of file intraprocess_subscriber_link.cpp.
void ros::IntraProcessSubscriberLink::drop | ( | ) | [virtual] |
Implements ros::SubscriberLink.
Definition at line 80 of file intraprocess_subscriber_link.cpp.
void ros::IntraProcessSubscriberLink::enqueueMessage | ( | const SerializedMessage & | m, | |
bool | nocopy, | |||
bool | ser | |||
) | [virtual] |
Queue up a message for publication. Throws out old messages if we've reached our Publication's max queue size.
Implements ros::SubscriberLink.
Definition at line 63 of file intraprocess_subscriber_link.cpp.
void ros::IntraProcessSubscriberLink::getPublishTypes | ( | bool & | ser, | |
bool & | nocopy, | |||
const std::type_info & | ti | |||
) | [virtual] |
Reimplemented from ros::SubscriberLink.
Definition at line 106 of file intraprocess_subscriber_link.cpp.
std::string ros::IntraProcessSubscriberLink::getTransportType | ( | ) | [virtual] |
Implements ros::SubscriberLink.
Definition at line 75 of file intraprocess_subscriber_link.cpp.
virtual bool ros::IntraProcessSubscriberLink::isIntraprocess | ( | ) | [inline, virtual] |
Reimplemented from ros::SubscriberLink.
Definition at line 51 of file intraprocess_subscriber_link.h.
bool ros::IntraProcessSubscriberLink::isLatching | ( | ) |
Definition at line 53 of file intraprocess_subscriber_link.cpp.
void ros::IntraProcessSubscriberLink::setSubscriber | ( | const IntraProcessPublisherLinkPtr & | subscriber | ) |
Definition at line 46 of file intraprocess_subscriber_link.cpp.
boost::recursive_mutex ros::IntraProcessSubscriberLink::drop_mutex_ [private] |
Definition at line 57 of file intraprocess_subscriber_link.h.
bool ros::IntraProcessSubscriberLink::dropped_ [private] |
Definition at line 56 of file intraprocess_subscriber_link.h.
Definition at line 55 of file intraprocess_subscriber_link.h.