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:

[legend]

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

◆ TransportPublisherLink()

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.

◆ ~TransportPublisherLink()

ros::TransportPublisherLink::~TransportPublisherLink ( )

virtual

Definition at line 66 of file transport_publisher_link.cpp.

Member Function Documentation

◆ drop()

void ros::TransportPublisherLink::drop ( )

virtual

Implements ros::PublisherLink.

Definition at line 113 of file transport_publisher_link.cpp.

◆ getConnection()

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

inline

Definition at line 60 of file transport_publisher_link.h.

◆ getTransportInfo()

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

virtual

Implements ros::PublisherLink.

Definition at line 317 of file transport_publisher_link.cpp.

◆ getTransportType()

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

virtual

Implements ros::PublisherLink.

Definition at line 312 of file transport_publisher_link.cpp.

◆ handleMessage()

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 299 of file transport_publisher_link.cpp.

◆ initialize()

bool ros::TransportPublisherLink::initialize ( const ConnectionPtr & connection )

Definition at line 78 of file transport_publisher_link.cpp.

◆ onConnectionDropped()

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

private

Definition at line 256 of file transport_publisher_link.cpp.

◆ onHeaderReceived()

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

private

Definition at line 130 of file transport_publisher_link.cpp.

◆ onHeaderWritten()

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

private

Definition at line 124 of file transport_publisher_link.cpp.

◆ onMessage()

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

private

Definition at line 187 of file transport_publisher_link.cpp.

◆ onMessageLength()

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

private

Definition at line 152 of file transport_publisher_link.cpp.

◆ onRetryTimer()

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

private

Definition at line 205 of file transport_publisher_link.cpp.

Member Data Documentation

◆ connection_

ConnectionPtr ros::TransportPublisherLink::connection_

private

Definition at line 81 of file transport_publisher_link.h.

◆ dropping_

bool ros::TransportPublisherLink::dropping_

private

Definition at line 87 of file transport_publisher_link.h.

◆ needs_retry_

bool ros::TransportPublisherLink::needs_retry_

private

Definition at line 84 of file transport_publisher_link.h.

◆ next_retry_

SteadyTime ros::TransportPublisherLink::next_retry_

private

Definition at line 86 of file transport_publisher_link.h.

◆ retry_period_

WallDuration ros::TransportPublisherLink::retry_period_

private

Definition at line 85 of file transport_publisher_link.h.

◆ retry_timer_handle_

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:

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ TransportPublisherLink()

◆ ~TransportPublisherLink()

Member Function Documentation

◆ drop()

◆ getConnection()

◆ getTransportInfo()

◆ getTransportType()

◆ handleMessage()

◆ initialize()

◆ onConnectionDropped()

◆ onHeaderReceived()

◆ onHeaderWritten()

◆ onMessage()

◆ onMessageLength()

◆ onRetryTimer()

Member Data Documentation

◆ connection_

◆ dropping_

◆ needs_retry_

◆ next_retry_

◆ retry_period_

◆ retry_timer_handle_