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