40 #include <boost/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_);
IntraProcessSubscriberLink(const PublicationPtr &parent)
virtual void getPublishTypes(bool &ser, bool &nocopy, const std::type_info &ti)
virtual ~IntraProcessSubscriberLink()
ROSCPP_DECL const std::string & getName()
Returns the name of the current node.
unsigned int connection_id_
std::string destination_caller_id_
IntraProcessPublisherLinkPtr subscriber_
#define ROSCPP_LOG_DEBUG(...)
static const ConnectionManagerPtr & instance()
virtual std::string getTransportInfo()
void setSubscriber(const IntraProcessPublisherLinkPtr &subscriber)
boost::recursive_mutex drop_mutex_
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...
virtual std::string getTransportType()