Public Member Functions | Private Member Functions | Private Attributes | List of all members
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:
Inheritance graph
[legend]

Public Member Functions

virtual void drop ()
 
const ConnectionPtrgetConnection ()
 
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 ()
 

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

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:


roscpp
Author(s): Morgan Quigley, Josh Faust, Brian Gerkey, Troy Straszheim, Dirk Thomas
autogenerated on Mon Feb 28 2022 23:33:27