23 #ifndef INCLUDED_GR_UDP_SOURCE_IMPL_H
24 #define INCLUDED_GR_UDP_SOURCE_IMPL_H
27 #include <boost/asio.hpp>
28 #include <boost/format.hpp>
48 unsigned short d_port;
50 boost::asio::ip::udp::socket *d_socket;
51 boost::asio::ip::udp::endpoint d_endpoint;
52 boost::asio::ip::udp::endpoint d_endpoint_rcvd;
53 boost::asio::io_service d_io_service;
60 void handle_read(
const boost::system::error_code& error,
61 size_t bytes_transferred);
62 void run_io_service() { d_io_service.run(); }
66 const std::string &host,
int port,
70 void connect(
const std::string &host,
int port);
76 int work(
int noutput_items,