DataInputInterface Class Reference

#include <data_input_interface.hh>

Public Member Functions
	DataInputInterface (size_t number_of_workers=1)
	~DataInputInterface ()
void	stop ()
void	pause ()
void	cont ()
void	start ()
void	add_worker ()
void	add_channel (unsigned short port, FrameFarm &farm)

Private Attributes
size_t	m_number_of_workers
std::vector< InChannelHandler * >	m_channel_handlers
boost::asio::io_service	m_service
boost::scoped_ptr < boost::thread_group >	m_threads

Detailed Description

Author

cpellegrino

Definition at line 18 of file data_input_interface.hh.

Constructor & Destructor Documentation

DataInputInterface::DataInputInterface ( size_t  number_of_workers = 1 )

inline

Definition at line 27 of file data_input_interface.hh.

    :
    m_number_of_workers(number_of_workers),
    m_threads(0)
  {}

DataInputInterface::~DataInputInterface ( )

inline

Definition at line 33 of file data_input_interface.hh.

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

Member Function Documentation

void DataInputInterface::stop ( )

inline

Definition at line 42 of file data_input_interface.hh.

  {
    m_service.stop();

    if (m_threads)
    {
      m_threads->join_all();
    }

    m_threads.reset();
  }

void DataInputInterface::pause ( )

inline

Definition at line 54 of file data_input_interface.hh.

  {
    BOOST_FOREACH(InChannelHandler* h, m_channel_handlers)
    {
      h->pause();
    }
  }

void DataInputInterface::cont ( )

inline

Definition at line 62 of file data_input_interface.hh.

  {
    BOOST_FOREACH(InChannelHandler* h, m_channel_handlers)
    {
      h->cont();
    }
  }

void DataInputInterface::start ( )

inline

Definition at line 70 of file data_input_interface.hh.

  {
    assert(!m_threads && "Calling DataInputInterface::start() on started istance.");

    m_threads.reset(new boost::thread_group);
    m_service.reset();
    for (std::size_t i = 0; i < m_number_of_workers; ++i)
    {
      m_threads->create_thread(boost::bind(&boost::asio::io_service::run,
                                          &m_service));
    }
  }

void DataInputInterface::add_worker ( )

inline

Definition at line 83 of file data_input_interface.hh.

  {
    if (m_threads)
    {
      m_threads->create_thread(boost::bind(&boost::asio::io_service::run,
                                            &m_service));
    }

    ++m_number_of_workers;
  }

void DataInputInterface::add_channel ( unsigned short  port, FrameFarm &  farm  )

inline

Definition at line 94 of file data_input_interface.hh.

  {
    InChannelHandler* new_channel = new InChannelHandler(m_service, port, farm);
    m_channel_handlers.push_back(new_channel);
  }

Member Data Documentation

size_t DataInputInterface::m_number_of_workers

private

Definition at line 20 of file data_input_interface.hh.

std::vector<InChannelHandler*> DataInputInterface::m_channel_handlers

private

Definition at line 21 of file data_input_interface.hh.

boost::asio::io_service DataInputInterface::m_service

private

Definition at line 22 of file data_input_interface.hh.

boost::scoped_ptr<boost::thread_group> DataInputInterface::m_threads

private

Definition at line 23 of file data_input_interface.hh.

---

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

• data_input_interface.hh