ros::TransportPublisherLink Class Reference

Handles a connection to a single publisher on a given topic. Receives messages from a publisher and hands them off to its parent Subscription. More...

#include <transport_publisher_link.h>

Inheritance diagram for ros::TransportPublisherLink:

Public Member Functions
virtual void	drop ()
const ConnectionPtr &	getConnection ()
virtual std::string	getTransportInfo ()
virtual std::string	getTransportType ()
bool	initialize (const ConnectionPtr &connection)
	TransportPublisherLink (const SubscriptionPtr &parent, const std::string &xmlrpc_uri, const TransportHints &transport_hints)
virtual	~TransportPublisherLink ()
Public Member Functions inherited from ros::PublisherLink
const std::string &	getCallerID ()
int	getConnectionID () const
const std::string &	getMD5Sum ()
const std::string &	getPublisherXMLRPCURI ()
const Stats &	getStats ()
bool	isLatched ()
	PublisherLink (const SubscriptionPtr &parent, const std::string &xmlrpc_uri, const TransportHints &transport_hints)
bool	setHeader (const Header &header)
virtual	~PublisherLink ()

Private Member Functions
virtual void	handleMessage (const SerializedMessage &m, bool ser, bool nocopy)
	Handles handing off a received message to the subscription, where it will be deserialized and called back. More...
void	onConnectionDropped (const ConnectionPtr &conn, Connection::DropReason reason)
bool	onHeaderReceived (const ConnectionPtr &conn, const Header &header)
void	onHeaderWritten (const ConnectionPtr &conn)
void	onMessage (const ConnectionPtr &conn, const boost::shared_array< uint8_t > &buffer, uint32_t size, bool success)
void	onMessageLength (const ConnectionPtr &conn, const boost::shared_array< uint8_t > &buffer, uint32_t size, bool success)
void	onRetryTimer (const ros::SteadyTimerEvent &)

Private Attributes
ConnectionPtr	connection_
bool	dropping_
bool	needs_retry_
SteadyTime	next_retry_
WallDuration	retry_period_
int32_t	retry_timer_handle_

Additional Inherited Members
Protected Attributes inherited from ros::PublisherLink
std::string	caller_id_
unsigned int	connection_id_
Header	header_
bool	latched_
std::string	md5sum_
SubscriptionWPtr	parent_
std::string	publisher_xmlrpc_uri_
Stats	stats_
TransportHints	transport_hints_

Detailed Description

Handles a connection to a single publisher on a given topic. Receives messages from a publisher and hands them off to its parent Subscription.

Definition at line 51 of file transport_publisher_link.h.

Constructor & Destructor Documentation

ros::TransportPublisherLink::TransportPublisherLink	(	const SubscriptionPtr &	parent,
		const std::string &	xmlrpc_uri,
		const TransportHints &	transport_hints
	)

Definition at line 58 of file transport_publisher_link.cpp.

ros::TransportPublisherLink::~TransportPublisherLink ( )

virtual

Definition at line 66 of file transport_publisher_link.cpp.

Member Function Documentation

void ros::TransportPublisherLink::drop ( )

virtual

Implements ros::PublisherLink.

Definition at line 109 of file transport_publisher_link.cpp.

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

inline

Definition at line 60 of file transport_publisher_link.h.

std::string ros::TransportPublisherLink::getTransportInfo ( )

virtual

Implements ros::PublisherLink.

Definition at line 312 of file transport_publisher_link.cpp.

std::string ros::TransportPublisherLink::getTransportType ( )

virtual

Implements ros::PublisherLink.

Definition at line 307 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::handleMessage ( const SerializedMessage &  m, bool  ser, bool  nocopy  )

privatevirtual

Handles handing off a received message to the subscription, where it will be deserialized and called back.

Implements ros::PublisherLink.

Definition at line 294 of file transport_publisher_link.cpp.

bool ros::TransportPublisherLink::initialize

(

const ConnectionPtr &

connection

)

Definition at line 78 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::onConnectionDropped ( const ConnectionPtr &  conn, Connection::DropReason  reason  )

private

Definition at line 251 of file transport_publisher_link.cpp.

bool ros::TransportPublisherLink::onHeaderReceived ( const ConnectionPtr &  conn, const Header &  header  )

private

Definition at line 126 of file transport_publisher_link.cpp.

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

private

Definition at line 120 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::onMessage ( const ConnectionPtr &  conn, const boost::shared_array< uint8_t > &  buffer, uint32_t  size, bool  success  )

private

Definition at line 183 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::onMessageLength ( const ConnectionPtr &  conn, const boost::shared_array< uint8_t > &  buffer, uint32_t  size, bool  success  )

private

Definition at line 148 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::onRetryTimer ( const ros::SteadyTimerEvent &  )

private

Definition at line 201 of file transport_publisher_link.cpp.

Member Data Documentation

ConnectionPtr ros::TransportPublisherLink::connection_

private

Definition at line 81 of file transport_publisher_link.h.

bool ros::TransportPublisherLink::dropping_

private

Definition at line 87 of file transport_publisher_link.h.

bool ros::TransportPublisherLink::needs_retry_

private

Definition at line 84 of file transport_publisher_link.h.

SteadyTime ros::TransportPublisherLink::next_retry_

private

Definition at line 86 of file transport_publisher_link.h.

WallDuration ros::TransportPublisherLink::retry_period_

private

Definition at line 85 of file transport_publisher_link.h.

int32_t ros::TransportPublisherLink::retry_timer_handle_

private

Definition at line 83 of file transport_publisher_link.h.

---

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

• transport_publisher_link.h
• transport_publisher_link.cpp