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. More... | |
virtual void | getPublishTypes (bool &ser, bool &nocopy, const std::type_info &ti) |
virtual std::string | getTransportInfo () |
virtual std::string | getTransportType () |
IntraProcessSubscriberLink (const PublicationPtr &parent) | |
virtual bool | isIntraprocess () |
bool | isLatching () |
void | setSubscriber (const IntraProcessPublisherLinkPtr &subscriber) |
virtual | ~IntraProcessSubscriberLink () |
Public Member Functions inherited from ros::SubscriberLink | |
int | getConnectionID () const |
const std::string & | getDataType () |
const std::string & | getDestinationCallerID () const |
const std::string & | getMD5Sum () |
const std::string & | getMessageDefinition () |
const Stats & | getStats () |
const std::string & | getTopic () const |
SubscriberLink () | |
virtual | ~SubscriberLink () |
Private Attributes | |
boost::recursive_mutex | drop_mutex_ |
bool | dropped_ |
IntraProcessPublisherLinkPtr | subscriber_ |
Additional Inherited Members | |
Protected Member Functions inherited from ros::SubscriberLink | |
bool | verifyDatatype (const std::string &datatype) |
Protected Attributes inherited from ros::SubscriberLink | |
unsigned int | connection_id_ |
std::string | destination_caller_id_ |
PublicationWPtr | parent_ |
Stats | stats_ |
std::string | topic_ |
SubscriberLink handles broadcasting messages to a single subscriber on a single topic.
Definition at line 44 of file intraprocess_subscriber_link.h.
ros::IntraProcessSubscriberLink::IntraProcessSubscriberLink | ( | const PublicationPtr & | parent | ) |
Definition at line 45 of file intraprocess_subscriber_link.cpp.
|
virtual |
Definition at line 53 of file intraprocess_subscriber_link.cpp.
|
virtual |
Implements ros::SubscriberLink.
Definition at line 97 of file intraprocess_subscriber_link.cpp.
|
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 74 of file intraprocess_subscriber_link.cpp.
|
virtual |
Reimplemented from ros::SubscriberLink.
Definition at line 123 of file intraprocess_subscriber_link.cpp.
|
virtual |
Implements ros::SubscriberLink.
Definition at line 91 of file intraprocess_subscriber_link.cpp.
|
virtual |
Implements ros::SubscriberLink.
Definition at line 86 of file intraprocess_subscriber_link.cpp.
|
inlinevirtual |
Reimplemented from ros::SubscriberLink.
Definition at line 57 of file intraprocess_subscriber_link.h.
bool ros::IntraProcessSubscriberLink::isLatching | ( | ) |
Definition at line 64 of file intraprocess_subscriber_link.cpp.
void ros::IntraProcessSubscriberLink::setSubscriber | ( | const IntraProcessPublisherLinkPtr & | subscriber | ) |
Definition at line 57 of file intraprocess_subscriber_link.cpp.
|
private |
Definition at line 63 of file intraprocess_subscriber_link.h.
|
private |
Definition at line 62 of file intraprocess_subscriber_link.h.
|
private |
Definition at line 61 of file intraprocess_subscriber_link.h.