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. More... | |
| const ConnectionPtr & | getConnection () |
| virtual std::string | getTransportInfo () |
| virtual std::string | getTransportType () |
| bool | handleHeader (const Header &header) |
| bool | initialize (const ConnectionPtr &connection) |
| TransportSubscriberLink () | |
| virtual | ~TransportSubscriberLink () |
 Public Member Functions inherited from roswrap::SubscriberLink | |
| int | getConnectionID () const |
| const std::string & | getDataType () |
| const std::string & | getDestinationCallerID () const |
| const std::string & | getMD5Sum () |
| const std::string & | getMessageDefinition () |
| virtual void | getPublishTypes (bool &ser, bool &nocopy, const std::type_info &ti) |
| const Stats & | getStats () |
| const std::string & | getTopic () const |
| virtual bool | isIntraprocess () |
| SubscriberLink () | |
| virtual | ~SubscriberLink () |
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_ |
| std::mutex | outbox_mutex_ |
| bool | queue_full_ |
| bool | writing_message_ |
Additional Inherited Members | |
| Protected Member Functions inherited from roswrap::SubscriberLink | |
| bool | verifyDatatype (const std::string &datatype) |
| Protected Attributes inherited from roswrap::SubscriberLink | |
| unsigned int | connection_id_ |
| std::string | destination_caller_id_ |
| PublicationWPtr | parent_ |
| Stats | stats_ |
| std::string | topic_ |
Detailed Description
SubscriberLink handles broadcasting messages to a single subscriber on a single topic.
Definition at line 42 of file transport_subscriber_link.h.
Constructor & Destructor Documentation
◆ TransportSubscriberLink()
| roswrap::TransportSubscriberLink::TransportSubscriberLink | ( | ) |
◆ ~TransportSubscriberLink()
|
virtual |
Member Function Documentation
◆ drop()
|
virtual |
Implements roswrap::SubscriberLink.
◆ enqueueMessage()
|
virtual |
Queue up a message for publication. Throws out old messages if we've reached our Publication's max queue size.
Implements roswrap::SubscriberLink.
◆ getConnection()
|
inline |
Definition at line 52 of file transport_subscriber_link.h.
◆ getTransportInfo()
|
virtual |
Implements roswrap::SubscriberLink.
◆ getTransportType()
|
virtual |
Implements roswrap::SubscriberLink.
◆ handleHeader()
◆ initialize()
| bool roswrap::TransportSubscriberLink::initialize | ( | const ConnectionPtr & | connection | ) |
◆ onConnectionDropped()
|
private |
◆ onHeaderWritten()
|
private |
◆ onMessageWritten()
|
private |
◆ startMessageWrite()
|
private |
Member Data Documentation
◆ connection_
|
private |
Definition at line 69 of file transport_subscriber_link.h.
◆ dropped_conn_
|
private |
Definition at line 70 of file transport_subscriber_link.h.
◆ header_written_
|
private |
Definition at line 67 of file transport_subscriber_link.h.
◆ outbox_
|
private |
Definition at line 72 of file transport_subscriber_link.h.
◆ outbox_mutex_
|
private |
Definition at line 73 of file transport_subscriber_link.h.
◆ queue_full_
|
private |
Definition at line 74 of file transport_subscriber_link.h.
◆ writing_message_
|
private |
Definition at line 66 of file transport_subscriber_link.h.
The documentation for this class was generated from the following file: