SubscriberLink handles broadcasting messages to a single subscriber on a single topic. More...
#include <transport_subscriber_link.h>
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< SerializedMessage > | outbox_ |
| 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.
| 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 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.
| std::string ros::TransportSubscriberLink::getTransportInfo | ( | ) | [virtual] |
Implements ros::SubscriberLink.
Definition at line 227 of file transport_subscriber_link.cpp.
| std::string ros::TransportSubscriberLink::getTransportType | ( | ) | [virtual] |
Implements ros::SubscriberLink.
Definition at line 222 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 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
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: