UdpDataHandler< Consumer > Class Template Reference

Public Member Functions
	UdpDataHandler (boost::asio::io_service &service, int port, char *buffer, std::size_t buffer_size, Consumer const &consumer)

Private Types
typedef UdpDataHandler< Consumer >	this_type

Private Member Functions
void	data_handle (boost::system::error_code const &error, std::size_t bytes_transferred)

Private Attributes
boost::asio::ip::udp::socket	m_socket
char *	m_buffer
std::size_t	m_buffer_size
Consumer	m_consumer

Detailed Description

template<class Consumer>
class UdpDataHandler< Consumer >

Definition at line 368 of file clb_swiss_knife.cpp.

Member Typedef Documentation

this_type

template<class Consumer >

typedef UdpDataHandler<Consumer> UdpDataHandler< Consumer >::this_type

private

Definition at line 370 of file clb_swiss_knife.cpp.

Constructor & Destructor Documentation

UdpDataHandler()

template<class Consumer >

UdpDataHandler< Consumer >::UdpDataHandler ( boost::asio::io_service &  service, int  port, char *  buffer, std::size_t  buffer_size, Consumer const &  consumer  )

inline

Definition at line 400 of file clb_swiss_knife.cpp.

    : m_socket(
          service
        , boost::asio::ip::udp::endpoint(boost::asio::ip::udp::v4(), port)
      )
    , m_buffer(buffer)
    , m_buffer_size(buffer_size)
    , m_consumer(consumer)
  {
#if __APPLE__
    boost::asio::ip::udp::socket::receive_buffer_size option(3554432);
#else
    boost::asio::ip::udp::socket::receive_buffer_size option(33554432);
#endif
    m_socket.set_option(option);
 
    m_socket.async_receive(
        boost::asio::buffer(m_buffer, m_buffer_size)
      , boost::bind(
            &this_type::data_handle
          , this
          , boost::asio::placeholders::error
          , boost::asio::placeholders::bytes_transferred
        )
    );
  }

Member Function Documentation

data_handle()

template<class Consumer >

void UdpDataHandler< Consumer >::data_handle ( boost::system::error_code const &  error, std::size_t  bytes_transferred  )

inlineprivate

Definition at line 377 of file clb_swiss_knife.cpp.

    {
    if (error) {
      m_consumer(error, 0, 0);
    } else {
      m_consumer(error, m_buffer, bytes_transferred);
    }
 
    m_socket.async_receive(
        boost::asio::buffer(m_buffer, m_buffer_size)
      , boost::bind(
            &this_type::data_handle
          , this
          , boost::asio::placeholders::error
          , boost::asio::placeholders::bytes_transferred
        )
    );
  }

Member Data Documentation

m_socket

template<class Consumer >

boost::asio::ip::udp::socket UdpDataHandler< Consumer >::m_socket

private

Definition at line 372 of file clb_swiss_knife.cpp.

m_buffer

template<class Consumer >

char* UdpDataHandler< Consumer >::m_buffer

private

Definition at line 373 of file clb_swiss_knife.cpp.

m_buffer_size

template<class Consumer >

std::size_t UdpDataHandler< Consumer >::m_buffer_size

private

Definition at line 374 of file clb_swiss_knife.cpp.

m_consumer

template<class Consumer >

Consumer UdpDataHandler< Consumer >::m_consumer

private

Definition at line 375 of file clb_swiss_knife.cpp.

---

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

• clb_swiss_knife.cpp