#include <input_channel_handler.hh>
|
void | handle (const boost::system::error_code &error, size_t size) |
|
- Author
- cpellegrino
Definition at line 15 of file input_channel_handler.hh.
◆ InChannelHandler()
InChannelHandler::InChannelHandler |
( |
boost::asio::io_service & |
service, |
|
|
unsigned short |
port, |
|
|
FrameFarm & |
farm |
|
) |
| |
|
inline |
Definition at line 65 of file input_channel_handler.hh.
69 m_socket(service, boost::asio::ip::udp::endpoint(boost::asio::ip::udp::v4(), port)),
75 boost::asio::ip::udp::socket::receive_buffer_size option(
recv_buf_size);
77 handle(boost::system::error_code(), 0);
static InBufferCollector & getCollector()
boost::asio::ip::udp::socket m_socket
void handle(const boost::system::error_code &error, size_t size)
boost::atomic< bool > m_paused
static const int recv_buf_size
◆ ~InChannelHandler()
InChannelHandler::~InChannelHandler |
( |
| ) |
|
|
inline |
◆ handle()
void InChannelHandler::handle |
( |
const boost::system::error_code & |
error, |
|
|
size_t |
size |
|
) |
| |
|
inlineprivate |
Definition at line 22 of file input_channel_handler.hh.
41 boost::asio::placeholders::error,
42 boost::asio::placeholders::bytes_transferred));
bool insert(CLBDataGram *datagram)
CLBDataGram * getEmptyDataGram()
◆ pause()
void InChannelHandler::pause |
( |
| ) |
|
|
inline |
◆ cont()
void InChannelHandler::cont |
( |
| ) |
|
|
inline |
◆ m_socket
boost::asio::ip::udp::socket InChannelHandler::m_socket |
|
private |
◆ m_buffer
◆ m_farm
◆ m_paused
boost::atomic<bool> InChannelHandler::m_paused |
|
private |
◆ recv_buf_size
const int InChannelHandler::recv_buf_size = 67108864 |
|
static |
The documentation for this class was generated from the following file: