frame_farm.hh

Go to the documentation of this file.

#ifndef DATAQUEUE_FRAMEFACTORY_FRAME_FARM_HH
#define DATAQUEUE_FRAMEFACTORY_FRAME_FARM_HH

#include <boost/atomic.hpp>
#include <boost/thread/mutex.hpp>

#include <map>
#include <deque>

#include "puzzled_frame.hh"
#include "ptr_dispatcher.hh"
#include "dump_file.hh"

#include <stdint.h>
#include <DataFormats/clb_common_header.hh>

#include <Buffers/clb_datagram.hh>

/**
 * \author cpellegrino
 */

class FrameFarm
{
  typedef std::map<frame_idx_t, PuzzledFrame*> container_t;

  typedef std::deque<PuzzledFrame*> buffers_collector_t;

  container_t m_container;

  ptrDispatcher m_frames;

  buffers_collector_t m_empty_buffers;

  boost::mutex m_mutex;

  boost::mutex m_ebf_mutex;

  boost::atomic<bool> m_running;

  unsigned int m_timeslice_duration;

  uint64_t m_start_run_ms;

  std::size_t m_max_dump_size;

  int m_run_number;
  unsigned int m_detector_id;

  DumpFile m_dumpfile;

 public:

  FrameFarm(unsigned int DeltaTS,
            uint64_t run_start_time,
            std::size_t max_dump_size,
            const std::string& dump_prefix,
            const std::string& dump_postfix)
    :
    m_timeslice_duration(DeltaTS),
    m_start_run_ms(run_start_time * 1000),
    m_max_dump_size(max_dump_size),
    m_run_number(0),
    m_detector_id(0),
    m_dumpfile(FilenameGenerator(dump_prefix, dump_postfix), m_max_dump_size)
  {}

  ~FrameFarm();

  void operator ()();

  void stop()
  {
    m_running = false;
    m_frames.close();
  }

  unsigned int getTimeSliceDuration()
  {
    return m_timeslice_duration;
  }

  bool insert(CLBDataGram* datagram);

  void getFrame(Frame& frame);

  int runNumber() const
  {
    return m_run_number;
  }

  int runNumber(int rn)
  {
    return m_run_number = rn;
  }

  unsigned int detectorId(unsigned int detector_id)
  {
    return m_detector_id = detector_id;
  }

 private:

  PuzzledFrame* getEmptyPuzzledFrame();
};

#endif // DATAQUEUE_FRAMEFACTORY_FRAME_FARM_HH