InChannelHandler Class Reference

#include <input_channel_handler.hh>

Public Member Functions
void	pause ()
void	cont ()
	InChannelHandler (boost::asio::io_service &service, unsigned short port, FrameFarm &farm)
	~InChannelHandler ()

Static Public Attributes
static const int	recv_buf_size = 67108864

Private Member Functions
void	handle (const boost::system::error_code &error, size_t size)

Private Attributes
boost::asio::ip::udp::socket	m_socket
CLBDataGram *	m_buffer
FrameFarm *const	m_farm
boost::atomic< bool >	m_paused

Detailed Description

Author

cpellegrino

Definition at line 15 of file input_channel_handler.hh.

Constructor & Destructor Documentation

InChannelHandler()

InChannelHandler::InChannelHandler ( boost::asio::io_service & service, unsigned short port, FrameFarm & farm )

inline

Definition at line 65 of file input_channel_handler.hh.

    :
    m_socket(service, boost::asio::ip::udp::endpoint(boost::asio::ip::udp::v4(), port)),
    m_buffer(
        InBufferCollector::getCollector().getEmptyDataGram()),
    m_farm(&farm),
    m_paused(false)
  {
    boost::asio::ip::udp::socket::receive_buffer_size option(recv_buf_size);
    m_socket.set_option(option);
    handle(boost::system::error_code(), 0);
  }

~InChannelHandler()

InChannelHandler::~InChannelHandler ( )

inline

Definition at line 80 of file input_channel_handler.hh.

  {
    InBufferCollector::getCollector().putDataGram(m_buffer);
  }

Member Function Documentation

handle()

void InChannelHandler::handle ( const boost::system::error_code & error, size_t size )

inlineprivate

Definition at line 22 of file input_channel_handler.hh.

  {
    // The error_code should be handled in principle, but
    // it is not mandatory, since all possibilities should be already
    // handled somewhere else.
 
    if (size && ! m_paused)
    {
      m_buffer->resize(size);
      m_farm->insert(m_buffer);
 
      m_buffer = InBufferCollector::getCollector().getEmptyDataGram();
    }
 
    m_socket.async_receive(
        boost::asio::buffer(m_buffer->raw(), m_buffer->capacity()),
        boost::bind(
            &InChannelHandler::handle,
            this,
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred));
  }

pause()

void InChannelHandler::pause ( )

inline

Definition at line 55 of file input_channel_handler.hh.

  {
    m_paused = true;
  }

cont()

void InChannelHandler::cont ( )

inline

Definition at line 60 of file input_channel_handler.hh.

  {
    m_paused = false;
  }

Member Data Documentation

m_socket

boost::asio::ip::udp::socket InChannelHandler::m_socket

private

Definition at line 17 of file input_channel_handler.hh.

m_buffer

CLBDataGram* InChannelHandler::m_buffer

private

Definition at line 18 of file input_channel_handler.hh.

m_farm

FrameFarm* const InChannelHandler::m_farm

private

Definition at line 19 of file input_channel_handler.hh.

m_paused

boost::atomic<bool> InChannelHandler::m_paused

private

Definition at line 20 of file input_channel_handler.hh.

recv_buf_size

const int InChannelHandler::recv_buf_size = 67108864

static

Definition at line 52 of file input_channel_handler.hh.

---

The documentation for this class was generated from the following file:

• input_channel_handler.hh