roswrap::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 roswrap::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 roswrap::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::WallTimerEvent &)

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

Additional Inherited Members
Protected Attributes inherited from roswrap::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 52 of file transport_publisher_link.h.

Constructor & Destructor Documentation

TransportPublisherLink()

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

~TransportPublisherLink()

virtual roswrap::TransportPublisherLink::~TransportPublisherLink ( )

virtual

Member Function Documentation

drop()

virtual void roswrap::TransportPublisherLink::drop ( )

virtual

Implements roswrap::PublisherLink.

getConnection()

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

inline

Definition at line 61 of file transport_publisher_link.h.

getTransportInfo()

virtual std::string roswrap::TransportPublisherLink::getTransportInfo ( )

virtual

Implements roswrap::PublisherLink.

getTransportType()

virtual std::string roswrap::TransportPublisherLink::getTransportType ( )

virtual

Implements roswrap::PublisherLink.

handleMessage()

virtual void roswrap::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 roswrap::PublisherLink.

initialize()

bool roswrap::TransportPublisherLink::initialize

(

const ConnectionPtr &

connection

)

onConnectionDropped()

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

private

onHeaderReceived()

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

private

onHeaderWritten()

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

private

onMessage()

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

private

onMessageLength()

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

private

onRetryTimer()

void roswrap::TransportPublisherLink::onRetryTimer ( const ros::WallTimerEvent &  )

private

Member Data Documentation

connection_

ConnectionPtr roswrap::TransportPublisherLink::connection_

private

Definition at line 82 of file transport_publisher_link.h.

dropping_

bool roswrap::TransportPublisherLink::dropping_

private

Definition at line 88 of file transport_publisher_link.h.

needs_retry_

bool roswrap::TransportPublisherLink::needs_retry_

private

Definition at line 85 of file transport_publisher_link.h.

next_retry_

WallTime roswrap::TransportPublisherLink::next_retry_

private

Definition at line 87 of file transport_publisher_link.h.

retry_period_

WallDuration roswrap::TransportPublisherLink::retry_period_

private

Definition at line 86 of file transport_publisher_link.h.

retry_timer_handle_

int32_t roswrap::TransportPublisherLink::retry_timer_handle_

private

Definition at line 84 of file transport_publisher_link.h.

---

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

• transport_publisher_link.h