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

template<class Consumer>

typedef LigierDataHandler<Consumer> LigierDataHandler< Consumer >::this_type

private

Definition at line 191 of file clb_swiss_knife.cpp.

Constructor & Destructor Documentation

template<class Consumer>

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

private

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

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
          )
      );
    }
  }

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
          )
      );
    }
  }

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
          )
      );
    }
  }

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
         )
      );
    }
  }

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
         )
      );
    }
  }

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
        )
    );
  }

template<class Consumer>

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

private

Member Data Documentation

template<class Consumer>

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

private

Definition at line 193 of file clb_swiss_knife.cpp.

template<class Consumer>

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

private

Definition at line 194 of file clb_swiss_knife.cpp.

template<class Consumer>

std::string LigierDataHandler< Consumer >::m_tag

private

Definition at line 196 of file clb_swiss_knife.cpp.

template<class Consumer>

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

private

Definition at line 197 of file clb_swiss_knife.cpp.

template<class Consumer>

char* LigierDataHandler< Consumer >::m_buffer

private

Definition at line 199 of file clb_swiss_knife.cpp.

template<class Consumer>

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

private

Definition at line 200 of file clb_swiss_knife.cpp.

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