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. More...

Private Attributes
boost::asio::ip::tcp::socket	m_sock
boost::asio::ip::tcp::endpoint	m_endpoint
CircularBuffer	m_cbuffer
bool	m_connected
bool	link_active
long	heartbeat_c
const long	heartbeat_interval =5000

Friends
class	RecipientsHandler

Detailed Description

Definition at line 15 of file recipient.hh.

Constructor & Destructor Documentation

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

inline

Definition at line 26 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";
      link_active=false;   
    }else 
      link_active=true;
    heartbeat_c=0;
  }

Recipient::~Recipient ( )

inline

Definition at line 95 of file recipient.hh.

  {
    stop();
  }

Member Function Documentation

void Recipient::sock_reset ( )

inline

Definition at line 45 of file recipient.hh.

  {
    stop();
    connect();
  }

bool Recipient::sendIfPossible ( const Frame &  data )

inline

Definition at line 51 of file recipient.hh.

  {

    //if Recipient receives a EAGAIN message, it stops sending tcp frames for the heartbeat interval
    //otherwise the RAM usage could increase out of control
     if (! link_active){
            m_cbuffer.push_back(data);
            heartbeat_c++;
            if (heartbeat_c == heartbeat_interval){
                    link_active=true;
                    heartbeat_c=0;
            }
            return false;
    }
    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;
  }

void Recipient::connect ( )

inlineprivate

Definition at line 104 of file recipient.hh.

  {
    boost::system::error_code ec;
    m_sock.connect(m_endpoint, ec);
    m_connected = !ec;

    if (m_connected) {
      boost::asio::socket_base::send_buffer_size option(67108864);
      m_sock.set_option(option);
      boost::asio::socket_base::non_blocking_io command(true);
      m_sock.io_control(command);
      LOG_NOTICE << "Connection to " << m_endpoint << " succeeded";
      boost::system::error_code ec;
      m_sock.shutdown(boost::asio::ip::tcp::socket::shutdown_receive, ec);
    }
  }

void Recipient::stop ( )

inlineprivate

Definition at line 121 of file recipient.hh.

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

bool Recipient::send ( const Frame &  data )

inlineprivate

Send data.

Parameters

data	the Frame to send.

Returns

true if OK; else false

Definition at line 133 of file recipient.hh.

  {
    boost::system::error_code ec;
    ssize_t nsent = boost::asio::write(m_sock, boost::asio::buffer(data.data(), data.getFrameLength()), ec);
    m_connected = !ec;

    if (ec) {
      if(ec.value()==11 && nsent<100){ //errno 11 = EAGAIN or EWOULDBLOCK
              link_active=false;
              LOG_ERROR << "The link with " << m_endpoint << 
              " gives EAGAIN: stop sending frame for the heartbeat interval in order to prevent strong RAM usage";
      }else  if(ec.value()!=11)   
            LOG_ERROR << "Error transmitting data to " << m_endpoint << ": " << ec;

    }
    return m_connected;
  }

Friends And Related Function Documentation

friend class RecipientsHandler

friend

Definition at line 100 of file recipient.hh.

Member Data Documentation

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

private

Definition at line 17 of file recipient.hh.

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

private

Definition at line 18 of file recipient.hh.

CircularBuffer Recipient::m_cbuffer

private

Definition at line 19 of file recipient.hh.

bool Recipient::m_connected

private

Definition at line 20 of file recipient.hh.

bool Recipient::link_active

private

Definition at line 21 of file recipient.hh.

long Recipient::heartbeat_c

private

Definition at line 22 of file recipient.hh.

const long Recipient::heartbeat_interval =5000

private

Definition at line 23 of file recipient.hh.

---

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

• recipient.hh