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_;