22 #ifndef __PLUGINS_GOSSIP_EXAMPLE_GEX_RECEIVER_THREAD_H_ 23 #define __PLUGINS_GOSSIP_EXAMPLE_GEX_RECEIVER_THREAD_H_ 25 #include <plugins/gossip/aspect/gossip.h> 26 #include <plugins/gossip/gossip/gossip_group.h> 28 #include <core/threading/thread.h> 29 #include <aspect/clock.h> 30 #include <aspect/logging.h> 31 #include <aspect/blocked_timing.h> 49 protected:
virtual void run() { Thread::run(); }
52 void handle_peer_msg(boost::asio::ip::udp::endpoint &endpoint,
53 uint16_t component_id, uint16_t msg_type,
54 std::shared_ptr<google::protobuf::Message> msg);
55 void handle_peer_recv_error(boost::asio::ip::udp::endpoint &endpoint, std::string msg);
56 void handle_peer_send_error(std::string msg);
59 boost::signals2::connection sig_rcvd_conn_;
60 boost::signals2::connection sig_recv_error_conn_;
61 boost::signals2::connection sig_send_error_conn_;
Thread aspect that allows to obtain the current time from the clock.
virtual void loop()
Code to execute in the thread.
Thread class encapsulation of pthreads.
Thread aspect to communicate with a group of robots.
virtual void init()
Initialize the thread.
virtual ~GossipExampleReceiverThread()
Destructor.
Thread aspect to use blocked timing.
Thread aspect to log output.
Gossip Example Plugin Thread - Receiver.
GossipExampleReceiverThread()
Constructor.
virtual void run()
Stub to see name in backtrace for easier debugging.
virtual void finalize()
Finalize the thread.