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