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