$search

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]

List of all members.

Public Member Functions

virtual void drop ()
const ConnectionPtr & getConnection ()
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.
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_

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 105 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::getTransportType (  )  [virtual]

Implements ros::PublisherLink.

Definition at line 296 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::handleMessage ( const SerializedMessage m,
bool  ser,
bool  nocopy 
) [private, virtual]

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

Implements ros::PublisherLink.

Definition at line 283 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 243 of file transport_publisher_link.cpp.

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

Definition at line 121 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::onHeaderWritten ( const ConnectionPtr &  conn  )  [private]

Definition at line 116 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 175 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 142 of file transport_publisher_link.cpp.

void ros::TransportPublisherLink::onRetryTimer ( const ros::WallTimerEvent  )  [private]

Definition at line 193 of file transport_publisher_link.cpp.


Member Data Documentation

Definition at line 80 of file transport_publisher_link.h.

Definition at line 86 of file transport_publisher_link.h.

Definition at line 83 of file transport_publisher_link.h.

Definition at line 85 of file transport_publisher_link.h.

Definition at line 84 of file transport_publisher_link.h.

Definition at line 82 of file transport_publisher_link.h.


The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines


roscpp
Author(s): Morgan Quigley mquigley@cs.stanford.edu, Josh Faust jfaust@willowgarage.com, Brian Gerkey gerkey@willowgarage.com, Troy Straszheim straszheim@willowgarage.com
autogenerated on Sat Mar 2 13:23:32 2013