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