1 #ifndef INPUT_CHANNEL_HANDLER_HH
2 #define INPUT_CHANNEL_HANDLER_HH
4 #include <boost/bind.hpp>
5 #include <boost/asio.hpp>
6 #include <boost/atomic.hpp>
22 void handle(
const boost::system::error_code& error,
size_t size)
41 boost::asio::placeholders::error,
42 boost::asio::placeholders::bytes_transferred));
65 m_socket(service, boost::asio::ip::udp::endpoint(boost::asio::ip::udp::v4(), port)),
71 boost::asio::ip::udp::socket::receive_buffer_size option(
recv_buf_size);
73 handle(boost::system::error_code(), 0);
82 #endif // INPUT_CHANNEL_HANDLER_HH
boost::asio::ip::udp::socket m_socket
void handle(const boost::system::error_code &error, size_t size)
void putDataGram(CLBDataGram *p)
static const int recv_buf_size
InChannelHandler(boost::asio::io_service &service, unsigned short port, FrameFarm &farm)
bool insert(CLBDataGram *datagram)
CLBDataGram * getEmptyDataGram()
static InBufferCollector & getCollector()
boost::atomic< bool > m_paused