Go to the documentation of this file.
40 #include <boost/bind/bind.hpp>
50 topic_ = parent->getName();
68 return parent->isLatching();
76 boost::recursive_mutex::scoped_lock lock(
drop_mutex_);
88 return std::string(
"INTRAPROCESS");
100 boost::recursive_mutex::scoped_lock lock(
drop_mutex_);
119 parent->removeSubscriberLink(shared_from_this());
125 boost::recursive_mutex::scoped_lock lock(
drop_mutex_);
unsigned int connection_id_
IntraProcessSubscriberLink(const PublicationPtr &parent)
std::string destination_caller_id_
virtual void getPublishTypes(bool &ser, bool &nocopy, const std::type_info &ti)
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 qu...
IntraProcessPublisherLinkPtr subscriber_
virtual ~IntraProcessSubscriberLink()
const ROSCPP_DECL std::string & getName()
Returns the name of the current node.
virtual std::string getTransportInfo()
static const ConnectionManagerPtr & instance()
boost::recursive_mutex drop_mutex_
virtual std::string getTransportType()
void setSubscriber(const IntraProcessPublisherLinkPtr &subscriber)
#define ROSCPP_LOG_DEBUG(...)
roscpp
Author(s): Morgan Quigley, Josh Faust, Brian Gerkey, Troy Straszheim, Dirk Thomas
, Jacob Perron
autogenerated on Sat Sep 14 2024 02:59:35