Public Member Functions | Private Member Functions | Private Attributes | List of all members
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]

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. More...
 
const ConnectionPtrgetConnection ()
 
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_
 

Additional Inherited Members

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

ros::TransportSubscriberLink::TransportSubscriberLink ( )

Definition at line 44 of file transport_subscriber_link.cpp.

ros::TransportSubscriberLink::~TransportSubscriberLink ( )
virtual

Definition at line 52 of file transport_subscriber_link.cpp.

Member Function Documentation

void ros::TransportSubscriberLink::drop ( )
virtual

Implements ros::SubscriberLink.

Definition at line 233 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 177 of file transport_subscriber_link.cpp.

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

Definition at line 51 of file transport_subscriber_link.h.

std::string ros::TransportSubscriberLink::getTransportInfo ( )
virtual

Implements ros::SubscriberLink.

Definition at line 228 of file transport_subscriber_link.cpp.

std::string ros::TransportSubscriberLink::getTransportType ( )
virtual

Implements ros::SubscriberLink.

Definition at line 223 of file transport_subscriber_link.cpp.

bool ros::TransportSubscriberLink::handleHeader ( const Header header)

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 137 of file transport_subscriber_link.cpp.

void ros::TransportSubscriberLink::onMessageWritten ( const ConnectionPtr conn)
private

Definition at line 144 of file transport_subscriber_link.cpp.

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

Definition at line 151 of file transport_subscriber_link.cpp.

Member Data Documentation

ConnectionPtr ros::TransportSubscriberLink::connection_
private

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.

bool ros::TransportSubscriberLink::header_written_
private

Definition at line 66 of file transport_subscriber_link.h.

std::queue<SerializedMessage> ros::TransportSubscriberLink::outbox_
private

Definition at line 71 of file transport_subscriber_link.h.

boost::mutex ros::TransportSubscriberLink::outbox_mutex_
private

Definition at line 72 of file transport_subscriber_link.h.

bool ros::TransportSubscriberLink::queue_full_
private

Definition at line 73 of file transport_subscriber_link.h.

bool ros::TransportSubscriberLink::writing_message_
private

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 Sun Feb 3 2019 03:29:54