Recipient Class Reference

#include <recipient.hh>

Public Member Functions
	Recipient (boost::asio::io_service &service, const boost::asio::ip::tcp::endpoint &endpoint, size_t circbuff_size)
void	sock_reset ()
bool	sendIfPossible (const Frame &data)
	~Recipient ()

Private Member Functions
void	connect ()
void	stop ()
bool	send (const Frame &data)
	Send data.

Private Attributes
boost::asio::ip::tcp::socket	m_sock
boost::asio::ip::tcp::endpoint	m_endpoint
CircularBuffer	m_cbuffer
bool	m_connected

Friends
class	RecipientsHandler

Detailed Description

Definition at line 15 of file recipient.hh.

Constructor & Destructor Documentation

Recipient()

Recipient::Recipient ( boost::asio::io_service & service, const boost::asio::ip::tcp::endpoint & endpoint, size_t circbuff_size )

inline

Definition at line 24 of file recipient.hh.

    :
    m_sock(service),
    m_endpoint(endpoint),
    m_cbuffer(circbuff_size),
    m_connected(false)
  {
    LOG_NOTICE << "Trying to connect to " << m_endpoint;
    connect();
    if (!m_connected) {
      LOG_ERROR << "Connection to " << m_endpoint << " failed";
   }
 }

~Recipient()

Recipient::~Recipient ( )

inline

Definition at line 79 of file recipient.hh.

  {
    stop();
  }

Member Function Documentation

sock_reset()

void Recipient::sock_reset ( )

inline

Definition at line 40 of file recipient.hh.

  {
    stop();
    connect();
  }

sendIfPossible()

bool Recipient::sendIfPossible ( const Frame & data )

inline

Definition at line 46 of file recipient.hh.

  {
 
    if (! m_connected)
    {
      sock_reset();
 
      if (! m_connected)
      {
        m_cbuffer.push_back(data);
        return false;
      }
    }
 
    while (m_cbuffer.size())
    {
      if (send(m_cbuffer.front()))
      {
        m_cbuffer.pop_front();
      }
      else
      {
        break;
      }
    }
    if (! send(data))
    {
      m_cbuffer.push_back(data);
    } 
    
    return m_connected;
  }

connect()

void Recipient::connect ( )

inlineprivate

Definition at line 88 of file recipient.hh.

  {
    boost::system::error_code ec;
    m_sock.connect(m_endpoint, ec);
    m_connected = !ec;
 
    if (m_connected) {
#if __APPLE__
      boost::asio::socket_base::send_buffer_size option(6108864);
#else
      boost::asio::socket_base::send_buffer_size option(67108864);
#endif
      m_sock.set_option(option);
      LOG_NOTICE << "Connection to " << m_endpoint << " succeeded";
      boost::system::error_code ec;
      m_sock.shutdown(boost::asio::ip::tcp::socket::shutdown_receive, ec);
    }
  }

stop()

void Recipient::stop ( )

inlineprivate

Definition at line 107 of file recipient.hh.

  {
    boost::system::error_code ec;
    m_sock.shutdown(boost::asio::ip::tcp::socket::shutdown_send, ec);
    m_sock.close(ec);
  }

send()

bool Recipient::send ( const Frame & data )

inlineprivate

Send data.

Parameters

data	the Frame to send.

Returns

true if OK; else false

Definition at line 119 of file recipient.hh.

  {
    boost::system::error_code ec;
    boost::asio::write(m_sock, boost::asio::buffer(data.data(), data.getFrameLength()), ec);    
    m_connected = !ec;
 
    if (ec) {
          LOG_ERROR << "Error transmitting data to " << m_endpoint << ": " << ec;
    }
    return m_connected;
  }

Friends And Related Symbol Documentation

RecipientsHandler

friend class RecipientsHandler

friend

Definition at line 84 of file recipient.hh.

Member Data Documentation

m_sock

boost::asio::ip::tcp::socket Recipient::m_sock

private

Definition at line 17 of file recipient.hh.

m_endpoint

boost::asio::ip::tcp::endpoint Recipient::m_endpoint

private

Definition at line 18 of file recipient.hh.

m_cbuffer

CircularBuffer Recipient::m_cbuffer

private

Definition at line 19 of file recipient.hh.

m_connected

bool Recipient::m_connected

private

Definition at line 20 of file recipient.hh.

---

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

• recipient.hh