RecipientsHandler Class Reference

#include <recipients_handler.hh>

Public Member Functions
	RecipientsHandler (size_t circbuf_size=10)
	~RecipientsHandler ()
bool	add (const std::string &id)
bool	remove (const std::string &id)
bool	send (const Frame &data)
void	wipe ()

Private Types
typedef std::vector< Recipient * >	container_t

Private Member Functions
container_t::iterator	find (const boost::asio::ip::tcp::endpoint &ep)

Private Attributes
boost::asio::io_service	m_service
const size_t	m_circbuff_size
container_t	m_recipients

Detailed Description

Definition at line 17 of file recipients_handler.hh.

Member Typedef Documentation

typedef std::vector<Recipient*> RecipientsHandler::container_t

private

Definition at line 19 of file recipients_handler.hh.

Constructor & Destructor Documentation

RecipientsHandler::RecipientsHandler ( size_t  circbuf_size = 10 )

inline

Definition at line 27 of file recipients_handler.hh.

    :
    m_circbuff_size(circbuf_size)
  {}

RecipientsHandler::~RecipientsHandler ( )

inline

Definition at line 32 of file recipients_handler.hh.

  {
    wipe();
  }

Member Function Documentation

bool RecipientsHandler::add ( const std::string &  id )

inline

Definition at line 37 of file recipients_handler.hh.

  {
    if (find(make_endpoint(id)) == m_recipients.end())
    {
      m_recipients.push_back(
          new Recipient(
              m_service,
              make_endpoint(id),
              m_circbuff_size));
      return true;
    }

    return false;
  }

bool RecipientsHandler::remove ( const std::string &  id )

inline

Definition at line 52 of file recipients_handler.hh.

  {
    container_t::iterator it = find(make_endpoint(id));

    if (it != m_recipients.end()) {
      const Recipient* to_be_erased = *it;

      m_recipients.erase(it);

      // write on disk to_be_erased->m_cbuffer. If necessary...

      delete to_be_erased;
      return true;
    }

    return false;
  }

bool RecipientsHandler::send ( const Frame &  data )

inline

Definition at line 70 of file recipients_handler.hh.

  {
    bool status = false;
    if (m_recipients.size())
    {
      const size_t n = data.getSeqNumber() % m_recipients.size();
      status = m_recipients[n]->sendIfPossible(data);
    }
    return status;
  }

void RecipientsHandler::wipe ( )

inline

Definition at line 81 of file recipients_handler.hh.

  {
    for (size_t i = 0; i < m_recipients.size(); ++i)
    {
      delete m_recipients[i];
    }
    m_recipients.clear();
  }

container_t::iterator RecipientsHandler::find ( const boost::asio::ip::tcp::endpoint &  ep )

inlineprivate

Definition at line 92 of file recipients_handler.hh.

  {
    container_t::iterator it = m_recipients.begin();
    for (container_t::const_iterator et = m_recipients.end(); it != et; ++it)
    {
      if ((*it)->m_endpoint == ep)
      {
        break;
      }
    }

    return it;
  }

Member Data Documentation

boost::asio::io_service RecipientsHandler::m_service

private

Definition at line 21 of file recipients_handler.hh.

const size_t RecipientsHandler::m_circbuff_size

private

Definition at line 22 of file recipients_handler.hh.

container_t RecipientsHandler::m_recipients

private

Definition at line 23 of file recipients_handler.hh.

---

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

• recipients_handler.hh