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

datagram_collector_t

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

private

Definition at line 16 of file input_buffer_collector.hh.

Constructor & Destructor Documentation

InBufferCollector()

InBufferCollector::InBufferCollector ( )

inlineprivate

Definition at line 22 of file input_buffer_collector.hh.

  {}

Member Function Documentation

getCollector()

static InBufferCollector & InBufferCollector::getCollector ( )

inlinestatic

Definition at line 27 of file input_buffer_collector.hh.

  {
    static InBufferCollector istance;
 
    return istance;
  }

getEmptyDataGram()

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;
  }

putDataGram()

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

m_collector

datagram_collector_t InBufferCollector::m_collector

private

Definition at line 18 of file input_buffer_collector.hh.

m_mutex

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