input_buffer_collector.hh

Go to the documentation of this file.

#ifndef DATAQUEUE_FRAMEFACTORY_INPUT_BUFFER_COLLECTOR_HH
#define DATAQUEUE_FRAMEFACTORY_INPUT_BUFFER_COLLECTOR_HH
 
#include <Buffers/clb_datagram.hh>
 
#include <boost/thread/mutex.hpp>
#include <deque>
#include <iostream>
 
/**
 * \author cpellegrino
 */
 
class InBufferCollector
{
  typedef std::deque<CLBDataGram*> datagram_collector_t;
 
  datagram_collector_t m_collector;
 
  boost::mutex             m_mutex;
 
  InBufferCollector()
  {}
 
 public:
 
  static InBufferCollector& getCollector()
  {
    static InBufferCollector istance;
 
    return istance;
  }
 
  CLBDataGram* getEmptyDataGram()
  {
    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 putDataGram(CLBDataGram* p)
  {
    boost::mutex::scoped_lock lock(m_mutex);
 
    if (m_collector.size() > 40000)
    {
      delete p;
    }
    else
    {
      m_collector.push_back(p);
    }
  }
 
};
 
#endif // DATAQUEUE_FRAMEFACTORY_INPUT_BUFFER_COLLECTOR_HH