Go to the documentation of this file.00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028 #ifndef ROSCPP_TRANSPORT_SUBSCRIBER_LINK_H
00029 #define ROSCPP_TRANSPORT_SUBSCRIBER_LINK_H
00030 #include "common.h"
00031 #include "subscriber_link.h"
00032
00033 #include <boost/signals2/connection.hpp>
00034
00035 namespace ros
00036 {
00037
00041 class ROSCPP_DECL TransportSubscriberLink : public SubscriberLink
00042 {
00043 public:
00044 TransportSubscriberLink();
00045 virtual ~TransportSubscriberLink();
00046
00047
00048 bool initialize(const ConnectionPtr& connection);
00049 bool handleHeader(const Header& header);
00050
00051 const ConnectionPtr& getConnection() { return connection_; }
00052
00053 virtual void enqueueMessage(const SerializedMessage& m, bool ser, bool nocopy);
00054 virtual void drop();
00055 virtual std::string getTransportType();
00056 virtual std::string getTransportInfo();
00057
00058 private:
00059 void onConnectionDropped(const ConnectionPtr& conn);
00060
00061 void onHeaderWritten(const ConnectionPtr& conn);
00062 void onMessageWritten(const ConnectionPtr& conn);
00063 void startMessageWrite(bool immediate_write);
00064
00065 bool writing_message_;
00066 bool header_written_;
00067
00068 ConnectionPtr connection_;
00069 boost::signals2::connection dropped_conn_;
00070
00071 std::queue<SerializedMessage> outbox_;
00072 boost::mutex outbox_mutex_;
00073 bool queue_full_;
00074 };
00075 typedef boost::shared_ptr<TransportSubscriberLink> TransportSubscriberLinkPtr;
00076
00077 }
00078
00079 #endif // ROSCPP_TRANSPORT_SUBSCRIBER_LINK_H
roscpp
Author(s): Morgan Quigley, Josh Faust, Brian Gerkey, Troy Straszheim
autogenerated on Thu Jun 6 2019 21:10:05