InBufferCollector Class Reference

#include <input_buffer_collector.hh>

Public Member Functions
CLBDataGram *	getEmptyDataGram ()
void	putDataGram (CLBDataGram *p)

Static Public Member Functions
static InBufferCollector &	getCollector ()

Private Types
typedef std::deque< CLBDataGram * >	datagram_collector_t

Private Member Functions
	InBufferCollector ()

Private Attributes
datagram_collector_t	m_collector
boost::mutex	m_mutex

Detailed Description

Author

cpellegrino

Definition at line 14 of file input_buffer_collector.hh.

Member Typedef Documentation

typedef std::deque<CLBDataGram*> InBufferCollector::datagram_collector_t

private

Definition at line 16 of file input_buffer_collector.hh.

Constructor & Destructor Documentation

InBufferCollector::InBufferCollector ( )

inlineprivate

Definition at line 22 of file input_buffer_collector.hh.

  {}

Member Function Documentation

static InBufferCollector& InBufferCollector::getCollector ( )

inlinestatic

Definition at line 27 of file input_buffer_collector.hh.

  {
    static InBufferCollector istance;

    return istance;
  }

CLBDataGram* InBufferCollector::getEmptyDataGram ( )

inline

Definition at line 34 of file input_buffer_collector.hh.

  {
    CLBDataGram* temp;

    boost::mutex::scoped_lock lock(m_mutex);

    if (m_collector.empty()) {
      temp = new CLBDataGram;
    } else {
      temp = m_collector.back();

      m_collector.pop_back();
      temp->clear();
    }

    benchmark::chrono_reset(*temp);
    return temp;
  }

void InBufferCollector::putDataGram ( CLBDataGram *  p )

inline

Definition at line 53 of file input_buffer_collector.hh.

  {
    boost::mutex::scoped_lock lock(m_mutex);

    if (m_collector.size() > 40000)
    {
      delete p;
    }
    else
    {
      m_collector.push_back(p);
    }
  }

Member Data Documentation

datagram_collector_t InBufferCollector::m_collector

private

Definition at line 18 of file input_buffer_collector.hh.

boost::mutex InBufferCollector::m_mutex

private

Definition at line 20 of file input_buffer_collector.hh.

---

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

• input_buffer_collector.hh