ros::TransportSubscriberLink Class Reference

SubscriberLink handles broadcasting messages to a single subscriber on a single topic. More...

#include <transport_subscriber_link.h>

Inheritance diagram for ros::TransportSubscriberLink:

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...
const ConnectionPtr &	getConnection ()
virtual std::string	getTransportInfo ()
virtual std::string	getTransportType ()
bool	handleHeader (const Header &header)
bool	initialize (const ConnectionPtr &connection)
	TransportSubscriberLink ()
virtual	~TransportSubscriberLink ()
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 ()
virtual void	getPublishTypes (bool &ser, bool &nocopy, const std::type_info &ti)
const Stats &	getStats ()
const std::string &	getTopic () const
virtual bool	isIntraprocess ()
	SubscriberLink ()
virtual	~SubscriberLink ()

Private Member Functions
void	onConnectionDropped (const ConnectionPtr &conn)
void	onHeaderWritten (const ConnectionPtr &conn)
void	onMessageWritten (const ConnectionPtr &conn)
void	startMessageWrite (bool immediate_write)

Private Attributes
ConnectionPtr	connection_
boost::signals2::connection	dropped_conn_
bool	header_written_
std::queue< SerializedMessage >	outbox_
boost::mutex	outbox_mutex_
bool	queue_full_
bool	writing_message_

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_

Detailed Description

SubscriberLink handles broadcasting messages to a single subscriber on a single topic.

Definition at line 41 of file transport_subscriber_link.h.

Constructor & Destructor Documentation

TransportSubscriberLink()

ros::TransportSubscriberLink::TransportSubscriberLink

(

)

Definition at line 44 of file transport_subscriber_link.cpp.

~TransportSubscriberLink()

ros::TransportSubscriberLink::~TransportSubscriberLink ( )

virtual

Definition at line 52 of file transport_subscriber_link.cpp.

Member Function Documentation

drop()

void ros::TransportSubscriberLink::drop ( )

virtual

Implements ros::SubscriberLink.

Definition at line 234 of file transport_subscriber_link.cpp.

enqueueMessage()

void ros::TransportSubscriberLink::enqueueMessage ( const SerializedMessage &  m, bool  ser, bool  nocopy  )

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 178 of file transport_subscriber_link.cpp.

getConnection()

const ConnectionPtr& ros::TransportSubscriberLink::getConnection ( )

inline

Definition at line 51 of file transport_subscriber_link.h.

getTransportInfo()

std::string ros::TransportSubscriberLink::getTransportInfo ( )

virtual

Implements ros::SubscriberLink.

Definition at line 229 of file transport_subscriber_link.cpp.

getTransportType()

std::string ros::TransportSubscriberLink::getTransportType ( )

virtual

Implements ros::SubscriberLink.

Definition at line 224 of file transport_subscriber_link.cpp.

handleHeader()

bool ros::TransportSubscriberLink::handleHeader

(

const Header &

header

)

Definition at line 66 of file transport_subscriber_link.cpp.

initialize()

bool ros::TransportSubscriberLink::initialize

(

const ConnectionPtr &

connection

)

Definition at line 58 of file transport_subscriber_link.cpp.

onConnectionDropped()

void ros::TransportSubscriberLink::onConnectionDropped ( const ConnectionPtr &  conn )

private

Definition at line 123 of file transport_subscriber_link.cpp.

onHeaderWritten()

void ros::TransportSubscriberLink::onHeaderWritten ( const ConnectionPtr &  conn )

private

Definition at line 138 of file transport_subscriber_link.cpp.

onMessageWritten()

void ros::TransportSubscriberLink::onMessageWritten ( const ConnectionPtr &  conn )

private

Definition at line 145 of file transport_subscriber_link.cpp.

startMessageWrite()

void ros::TransportSubscriberLink::startMessageWrite ( bool  immediate_write )

private

Definition at line 152 of file transport_subscriber_link.cpp.

Member Data Documentation

connection_

ConnectionPtr ros::TransportSubscriberLink::connection_

private

Definition at line 68 of file transport_subscriber_link.h.

dropped_conn_

boost::signals2::connection ros::TransportSubscriberLink::dropped_conn_

private

Definition at line 69 of file transport_subscriber_link.h.

header_written_

bool ros::TransportSubscriberLink::header_written_

private

Definition at line 66 of file transport_subscriber_link.h.

outbox_

std::queue<SerializedMessage> ros::TransportSubscriberLink::outbox_

private

Definition at line 71 of file transport_subscriber_link.h.

outbox_mutex_

boost::mutex ros::TransportSubscriberLink::outbox_mutex_

private

Definition at line 72 of file transport_subscriber_link.h.

queue_full_

bool ros::TransportSubscriberLink::queue_full_

private

Definition at line 73 of file transport_subscriber_link.h.

writing_message_

bool ros::TransportSubscriberLink::writing_message_

private

Definition at line 65 of file transport_subscriber_link.h.

---

The documentation for this class was generated from the following files:

• transport_subscriber_link.h
• transport_subscriber_link.cpp