LigierDataHandler< Consumer > Class Template Reference

Public Member Functions
	LigierDataHandler (boost::asio::io_service &service, std::string const &tag, boost::asio::ip::tcp::endpoint const &endpoint, char *buffer, std::size_t buffer_size, Consumer const &consumer)

Private Types
typedef LigierDataHandler< Consumer >	this_type

Private Member Functions
void	data_handle (boost::system::error_code const &error, std::size_t size)
void	timeout_handle (boost::system::error_code const &error)
void	connect_handle (boost::system::error_code const &error)
void	subscribe_handle (boost::system::error_code const &error, std::size_t bytes_transferred)
void	header_handle (boost::system::error_code const &error, std::size_t bytes_transferred)
void	restart ()
	LigierDataHandler (LigierDataHandler const &)
LigierDataHandler &	operator= (LigierDataHandler const &)

Private Attributes
boost::asio::ip::tcp::socket	m_socket
boost::asio::deadline_timer	m_timer
std::string	m_tag
boost::asio::ip::tcp::endpoint	m_endpoint
char *	m_buffer
std::size_t const	m_buffer_size
Consumer	m_consumer

Detailed Description

template<class Consumer>
class LigierDataHandler< Consumer >

Definition at line 189 of file clb_swiss_knife.cpp.

Member Typedef Documentation

this_type

template<class Consumer >

LigierDataHandler<Consumer> LigierDataHandler< Consumer >::this_type

private

Definition at line 191 of file clb_swiss_knife.cpp.

Constructor & Destructor Documentation

LigierDataHandler() [1/2]

template<class Consumer >

LigierDataHandler< Consumer >::LigierDataHandler ( LigierDataHandler< Consumer > const & )

private

LigierDataHandler() [2/2]

template<class Consumer >

LigierDataHandler< Consumer >::LigierDataHandler ( boost::asio::io_service & service, std::string const & tag, boost::asio::ip::tcp::endpoint const & endpoint, char * buffer, std::size_t buffer_size, Consumer const & consumer )

inline

Definition at line 341 of file clb_swiss_knife.cpp.

    : m_socket(service)
    , m_timer(service)
    , m_tag(tag)
    , m_endpoint(endpoint)
    , m_buffer(buffer)
    , m_buffer_size(buffer_size)
    , m_consumer(consumer)
  {
    m_socket.async_connect(
        m_endpoint
      , boost::bind(
            &this_type::connect_handle
          , this
          , boost::asio::placeholders::error
        )
    );
  }

Member Function Documentation

data_handle()

template<class Consumer >

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

inlineprivate

Definition at line 204 of file clb_swiss_knife.cpp.

  {
    if (error && error != boost::asio::error::operation_aborted) {
      m_consumer(error, 0, 0);
      restart();
    } else if (error == boost::asio::error::operation_aborted) {
    } else {
      m_consumer(error, m_buffer + 16, size);
 
      boost::asio::async_read(
          m_socket
        , boost::asio::buffer(m_buffer, 16)
        , boost::bind(
              &this_type::header_handle
            , this
            , boost::asio::placeholders::error
            , boost::asio::placeholders::bytes_transferred
          )
      );
    }
  }

timeout_handle()

template<class Consumer >

void LigierDataHandler< Consumer >::timeout_handle ( boost::system::error_code const & error )

inlineprivate

Definition at line 229 of file clb_swiss_knife.cpp.

  {
    if (!error) {
      m_socket.async_connect(
          m_endpoint
        , boost::bind(
              &this_type::connect_handle
            , this
            , boost::asio::placeholders::error
          )
      );
    }
  }

connect_handle()

template<class Consumer >

void LigierDataHandler< Consumer >::connect_handle ( boost::system::error_code const & error )

inlineprivate

Definition at line 243 of file clb_swiss_knife.cpp.

  {
    if (error && error != boost::asio::error::operation_aborted) {
      m_consumer(error, 0, 0);
      m_timer.expires_from_now(boost::posix_time::seconds(1));
 
      m_timer.async_wait(
          boost::bind(
              &this_type::timeout_handle
            , this
            , boost::asio::placeholders::error
          )
      );
    } else if (error == boost::asio::error::operation_aborted) {
    } else {
      std::size_t const size = ligier::prepare_tag(m_buffer, m_buffer_size, m_tag);
 
      boost::asio::async_write(
          m_socket
        , boost::asio::buffer(m_buffer, size)
        , boost::bind(
              &this_type::subscribe_handle
            , this
            , boost::asio::placeholders::error
            , boost::asio::placeholders::bytes_transferred
          )
      );
    }
  }

subscribe_handle()

template<class Consumer >

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

inlineprivate

Definition at line 273 of file clb_swiss_knife.cpp.

    {
    if (error && error != boost::asio::error::operation_aborted) {
      m_consumer(error, 0, 0);
      restart();
    } else if (error == boost::asio::error::operation_aborted) {
    } else {
      boost::asio::async_read(
          m_socket
        , boost::asio::buffer(m_buffer, 16)
        , boost::bind(
              &this_type::header_handle
            , this
            , boost::asio::placeholders::error
            , boost::asio::placeholders::bytes_transferred
         )
      );
    }
  }

header_handle()

template<class Consumer >

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

inlineprivate

Definition at line 295 of file clb_swiss_knife.cpp.

    {
    if (error && error != boost::asio::error::operation_aborted) {
      m_consumer(error, 0, 0);
      restart();
    } else if (error == boost::asio::error::operation_aborted) {
    } else {
      std::size_t const size = ligier::read_data_size(m_buffer);
 
      boost::asio::async_read(
          m_socket
        , boost::asio::buffer(m_buffer + 16, size)
        , boost::bind(
              &this_type::data_handle
            , this
            , boost::asio::placeholders::error
            , boost::asio::placeholders::bytes_transferred
         )
      );
    }
  }

restart()

template<class Consumer >

void LigierDataHandler< Consumer >::restart ( )

inlineprivate

Definition at line 319 of file clb_swiss_knife.cpp.

  {
    boost::system::error_code ec;
 
    m_socket.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ec);
    m_socket.close(ec);
 
    m_socket.async_connect(
        m_endpoint
      , boost::bind(
            &this_type::connect_handle
          , this
          , boost::asio::placeholders::error
        )
    );
  }

operator=()

template<class Consumer >

LigierDataHandler & LigierDataHandler< Consumer >::operator= ( LigierDataHandler< Consumer > const & )

private

Member Data Documentation

m_socket

template<class Consumer >

boost::asio::ip::tcp::socket LigierDataHandler< Consumer >::m_socket

private

Definition at line 193 of file clb_swiss_knife.cpp.

m_timer

template<class Consumer >

boost::asio::deadline_timer LigierDataHandler< Consumer >::m_timer

private

Definition at line 194 of file clb_swiss_knife.cpp.

m_tag

template<class Consumer >

std::string LigierDataHandler< Consumer >::m_tag

private

Definition at line 196 of file clb_swiss_knife.cpp.

m_endpoint

template<class Consumer >

boost::asio::ip::tcp::endpoint LigierDataHandler< Consumer >::m_endpoint

private

Definition at line 197 of file clb_swiss_knife.cpp.

m_buffer

template<class Consumer >

char* LigierDataHandler< Consumer >::m_buffer

private

Definition at line 199 of file clb_swiss_knife.cpp.

m_buffer_size

template<class Consumer >

std::size_t const LigierDataHandler< Consumer >::m_buffer_size

private

Definition at line 200 of file clb_swiss_knife.cpp.

m_consumer

template<class Consumer >

Consumer LigierDataHandler< Consumer >::m_consumer

private

Definition at line 202 of file clb_swiss_knife.cpp.

---

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

• clb_swiss_knife.cpp