puzzled_frame.hh

Go to the documentation of this file.

#ifndef __PUZZLED_FRAME_HH
#define __PUZZLED_FRAME_HH
 
#include <map>
 
#include "timer.hh"
#include "frame.hh"
 
#include <Buffers/clb_datagram.hh>
#include <benchmark/time_tracking.hh>
 
#include <boost/atomic.hpp>
 
/**
 * \author cpellegrino
 */
 
class PuzzledFrame : public benchmark::chronometrable
{
 public:
 
  typedef std::map<unsigned int, CLBDataGram*> container_t;
 
 private:
 
  container_t m_container;
 
  Timer m_expiration;
  unsigned int m_seqnumber;
  unsigned int m_detector_id;
  unsigned int m_datatype;
 
  unsigned int m_totalsize;
 
  frame_idx_t m_frame_idx;
 
 public:
 
  static boost::atomic<unsigned int> n_obj;
 
  PuzzledFrame()
    :
    m_seqnumber(0),
    m_detector_id(0),
    m_datatype(0),
    m_totalsize(0),
    m_frame_idx(0)
  {
    ++n_obj;
  }
 
  ~PuzzledFrame()
  {
    reset();
    --n_obj;
  }
 
  void setTimer(const Timer& exp)
  {
    m_expiration.set(exp);
  }
 
  void setSeqNumber(unsigned int seqnumber)
  {
    m_seqnumber = seqnumber;
  }
 
  void setDataType(unsigned int datatype)
  {
    m_datatype = datatype;
  }
 
  void setDetectorId(unsigned int detector_id)
  {
    m_detector_id = detector_id;
  }
 
  void setFrameIndex(frame_idx_t frame_idx)
  {
    m_frame_idx = frame_idx;
  }
 
  bool insert(CLBDataGram* datagram);
 
  bool hasExpired() const
  {
    return m_expiration.hasExpired();
  }
 
  bool hasExpiredWrt(Timer const& t) const
  {
    return m_expiration.hasExpiredWrt(t);
  }
 
  void getFrame(Frame &frame);
 
  void reset();
 
  uint32_t frameLength() const
  {
    return m_totalsize +
        sizeof(DAQCommonHeader) -
        sizeof(CLBCommonHeader) * m_container.size();
  }
 
  uint32_t frameDomStatus(int i = 1) const;
};
 
#endif