Public Member Functions | Private Member Functions | Private Attributes
ros::TransportSubscriberLink Class Reference

SubscriberLink handles broadcasting messages to a single subscriber on a single topic. More...

#include <transport_subscriber_link.h>

Inheritance diagram for ros::TransportSubscriberLink:
Inheritance graph
[legend]

List of all members.

Public Member Functions

virtual void drop ()
virtual void enqueueMessage (const SerializedMessage &m, bool ser, bool nocopy)
 Queue up a message for publication. Throws out old messages if we've reached our Publication's max queue size.
const ConnectionPtr & getConnection ()
virtual std::string getTransportInfo ()
virtual std::string getTransportType ()
bool handleHeader (const Header &header)
bool initialize (const ConnectionPtr &connection)
 TransportSubscriberLink ()
virtual ~TransportSubscriberLink ()

Private Member Functions

void onConnectionDropped (const ConnectionPtr &conn)
void onHeaderWritten (const ConnectionPtr &conn)
void onMessageWritten (const ConnectionPtr &conn)
void startMessageWrite (bool immediate_write)

Private Attributes

ConnectionPtr connection_
boost::signals2::connection dropped_conn_
bool header_written_
std::queue< SerializedMessageoutbox_
boost::mutex outbox_mutex_
bool queue_full_
bool writing_message_

Detailed Description

SubscriberLink handles broadcasting messages to a single subscriber on a single topic.

Definition at line 41 of file transport_subscriber_link.h.


Constructor & Destructor Documentation

Definition at line 44 of file transport_subscriber_link.cpp.

Definition at line 52 of file transport_subscriber_link.cpp.


Member Function Documentation

Implements ros::SubscriberLink.

Definition at line 232 of file transport_subscriber_link.cpp.

void ros::TransportSubscriberLink::enqueueMessage ( const SerializedMessage m,
bool  ser,
bool  nocopy 
) [virtual]

Queue up a message for publication. Throws out old messages if we've reached our Publication's max queue size.

Implements ros::SubscriberLink.

Definition at line 176 of file transport_subscriber_link.cpp.

const ConnectionPtr& ros::TransportSubscriberLink::getConnection ( ) [inline]

Definition at line 51 of file transport_subscriber_link.h.

Implements ros::SubscriberLink.

Definition at line 227 of file transport_subscriber_link.cpp.

Implements ros::SubscriberLink.

Definition at line 222 of file transport_subscriber_link.cpp.

Definition at line 65 of file transport_subscriber_link.cpp.

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

Definition at line 57 of file transport_subscriber_link.cpp.

void ros::TransportSubscriberLink::onConnectionDropped ( const ConnectionPtr &  conn) [private]

Definition at line 122 of file transport_subscriber_link.cpp.

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

Definition at line 136 of file transport_subscriber_link.cpp.

void ros::TransportSubscriberLink::onMessageWritten ( const ConnectionPtr &  conn) [private]

Definition at line 143 of file transport_subscriber_link.cpp.

void ros::TransportSubscriberLink::startMessageWrite ( bool  immediate_write) [private]

Definition at line 150 of file transport_subscriber_link.cpp.


Member Data Documentation

Definition at line 68 of file transport_subscriber_link.h.

boost::signals2::connection ros::TransportSubscriberLink::dropped_conn_ [private]

Definition at line 69 of file transport_subscriber_link.h.

Definition at line 66 of file transport_subscriber_link.h.

Definition at line 71 of file transport_subscriber_link.h.

Definition at line 72 of file transport_subscriber_link.h.

Definition at line 73 of file transport_subscriber_link.h.

Definition at line 65 of file transport_subscriber_link.h.


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


roscpp
Author(s): Morgan Quigley, Josh Faust, Brian Gerkey, Troy Straszheim
autogenerated on Thu Jun 6 2019 21:10:06