PuzzledFrame Class Reference

#include <puzzled_frame.hh>

Inheritance diagram for PuzzledFrame:

Public Types
typedef std::map< unsigned int, CLBDataGram * >	container_t

Public Member Functions
	PuzzledFrame ()
	~PuzzledFrame ()
void	setTimer (const Timer &exp)
void	setSeqNumber (unsigned int seqnumber)
void	setDataType (unsigned int datatype)
void	setDetectorId (unsigned int detector_id)
void	setFrameIndex (frame_idx_t frame_idx)
bool	insert (CLBDataGram *datagram)
bool	hasExpired () const
bool	hasExpiredWrt (Timer const &t) const
void	getFrame (Frame &frame)
void	reset ()
uint32_t	frameLength () const
uint32_t	frameDomStatus (int i=1) const

Static Public Attributes
static boost::atomic< unsigned int >	n_obj

Private Attributes
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

Detailed Description

Author

cpellegrino

Definition at line 18 of file puzzled_frame.hh.

Member Typedef Documentation

typedef std::map<unsigned int, CLBDataGram*> PuzzledFrame::container_t

Definition at line 22 of file puzzled_frame.hh.

Constructor & Destructor Documentation

PuzzledFrame::PuzzledFrame ( )

inline

Definition at line 41 of file puzzled_frame.hh.

    :
    m_seqnumber(0),
    m_detector_id(0),
    m_datatype(0),
    m_totalsize(0),
    m_frame_idx(0)
  {
    ++n_obj;
  }

PuzzledFrame::~PuzzledFrame ( )

inline

Definition at line 52 of file puzzled_frame.hh.

  {
    reset();
    --n_obj;
  }

Member Function Documentation

void PuzzledFrame::setTimer ( const Timer &  exp )

inline

Definition at line 58 of file puzzled_frame.hh.

  {
    m_expiration.set(exp);
  }

void PuzzledFrame::setSeqNumber ( unsigned int  seqnumber )

inline

Definition at line 63 of file puzzled_frame.hh.

  {
    m_seqnumber = seqnumber;
  }

void PuzzledFrame::setDataType ( unsigned int  datatype )

inline

Definition at line 68 of file puzzled_frame.hh.

  {
    m_datatype = datatype;
  }

void PuzzledFrame::setDetectorId ( unsigned int  detector_id )

inline

Definition at line 73 of file puzzled_frame.hh.

  {
    m_detector_id = detector_id;
  }

void PuzzledFrame::setFrameIndex ( frame_idx_t  frame_idx )

inline

Definition at line 78 of file puzzled_frame.hh.

  {
    m_frame_idx = frame_idx;
  }

bool PuzzledFrame::insert

(

CLBDataGram *

datagram

)

Definition at line 61 of file puzzled_frame.cc.

{
  //Test collision: is m_container[idx] empty?
  unsigned int const idx = datagram->getUDPSequenceNumber();

  container_t::const_iterator const it = m_container.find(idx);

  if (it != m_container.end()) {
    LOG_DEBUG << "Datagram collision. idx: " << idx << '\n'
              << "container.size(): " << m_container.size() << '\n'
              << "INFO:\n" << *datagram->getCLBCommonHeader();

    Log::Counter::get().add("collision");
    InBufferCollector::getCollector().putDataGram(datagram);
    return false;
  }

  if (!m_totalsize) {
    benchmark::chrono_swap(*datagram, *this);
  }

  m_container.insert(m_container.end(), container_t::value_type(idx, datagram));

  m_totalsize += datagram->size();

  return true;
}

bool PuzzledFrame::hasExpired ( ) const

inline

Definition at line 85 of file puzzled_frame.hh.

  {
    return m_expiration.hasExpired();
  }

bool PuzzledFrame::hasExpiredWrt ( Timer const &  t ) const

inline

Definition at line 90 of file puzzled_frame.hh.

  {
    return m_expiration.hasExpiredWrt(t);
  }

void PuzzledFrame::getFrame

(

Frame &

frame

)

Definition at line 304 of file puzzled_frame.cc.

{
  benchmark::chrono_set(*this);
  benchmark::chrono_swap(*this, frame);

  CLBCommonHeader const*const clb_header
      = m_container.begin()->second->getCLBCommonHeader();

  int const frame_length = frameLength();

  // test the frame length
  // must be greater than 0
  if (frame_length < 0) {
    LOG_DEBUG << "Anomalous frame size: " << frame_length       << '\n'
              << "Read total size: "      << m_totalsize        << '\n'
              << "container.size(): "     << m_container.size();

    Log::Counter::get().add("wrong size");
    frame.clear();
    return;
  }

  frame.m_seqnumber = m_seqnumber;
  frame.resize(frame_length);

  DAQCommonHeader& daq_header = *static_cast<DAQCommonHeader*>(
      static_cast<void*>(
          &frame.front()));

  // initialise the parts of the DAQCommonHeader that are already known
  // before the assembling of the data.

  daq_header.DataType = clb_header->dataType();

  daq_header.DetectorIdentifier = m_detector_id;

  daq_header.RunNumber = clb_header->runNumber();

  daq_header.SequenceNumber = m_seqnumber;

  daq_header.Timestamp.Sec = clb_header->timeStamp().sec();
  daq_header.Timestamp.Tics = clb_header->timeStamp().tics();

  daq_header.DOMIdentifier = clb_header->domIdentifier();

  daq_header.NumberOfPackets = m_container.size();
  daq_header.HighestPacketNumber
    = m_container.rbegin()
    ->second
    ->getCLBCommonHeader()
    ->udpSequenceNumber();

  daq_header.DOMStatus1 = frameDomStatus(1);
  daq_header.DOMStatus2 = frameDomStatus(2);
  daq_header.DOMStatus3 = 0;
  daq_header.DOMStatus4 = 0;

  if (is_optical(daq_header.DataType)) {
    if (
        !(
            m_container.size() > 1
            || m_container.begin()->second->getCLBCommonHeader()->udpSequenceNumber() == 0
        )
    ) {
      LOG_DEBUG << "Optical frame "
                << m_frame_idx
                << " contains too few data to be assembled. Ignored.";

      Log::Counter::get().add("skipd oframe");
      frame.resize(0);
    } else {
      buildOpto(m_container, m_frame_idx, frame);
    }
  } else if (is_acoustic(daq_header.DataType)) {
    if (m_container.begin()->second->getUDPSequenceNumber() != 0) {
      LOG_DEBUG << "Acoustic frame "
                << m_frame_idx
                << " without infoword. Ignored.";

      Log::Counter::get().add("skipd aframe");
      frame.resize(0);
    } else if (m_container.begin()->second->size() <= sizeof(CLBCommonHeader)) {
      frame.resize(0);
    } else {
      buildAcou(m_container, m_frame_idx, frame);
    }
  } else {
    throw std::runtime_error("Unknown data type");
  }

  daq_header.FrameLength = frame.size();
  daq_header.NumberOfItems = calculate_number_of_items(frame);
}

void PuzzledFrame::reset

(

)

Definition at line 398 of file puzzled_frame.cc.

{
  for (
      container_t::const_iterator it = m_container.begin(), et = m_container.end();
      it != et;
      ++it
  )
  {
    InBufferCollector::getCollector().putDataGram(it->second);
  }

  m_container.clear();

  m_totalsize = 0;
  m_seqnumber = 0;
  m_detector_id = 0;
  m_datatype = 0;
  m_frame_idx = 0;
}

uint32_t PuzzledFrame::frameLength ( ) const

inline

Definition at line 99 of file puzzled_frame.hh.

  {
    return m_totalsize +
        sizeof(DAQCommonHeader) -
        sizeof(CLBCommonHeader) * m_container.size();
  }

uint32_t PuzzledFrame::frameDomStatus

(

int

i = 1

)

const

Definition at line 21 of file puzzled_frame.cc.

{
  uint32_t dom_status = 0;
  for (
      container_t::const_iterator it = m_container.begin(), et = m_container.end();
      it != et;
      ++it
  ) {
    const CLBCommonHeader* const clb_header = it->second->getCLBCommonHeader();
    dom_status = dom_status | clb_header->domStatus(i);
  }
  return dom_status;
}

Member Data Documentation

container_t PuzzledFrame::m_container

private

Definition at line 26 of file puzzled_frame.hh.

Timer PuzzledFrame::m_expiration

private

Definition at line 28 of file puzzled_frame.hh.

unsigned int PuzzledFrame::m_seqnumber

private

Definition at line 29 of file puzzled_frame.hh.

unsigned int PuzzledFrame::m_detector_id

private

Definition at line 30 of file puzzled_frame.hh.

unsigned int PuzzledFrame::m_datatype

private

Definition at line 31 of file puzzled_frame.hh.

unsigned int PuzzledFrame::m_totalsize

private

Definition at line 33 of file puzzled_frame.hh.

frame_idx_t PuzzledFrame::m_frame_idx

private

Definition at line 35 of file puzzled_frame.hh.

boost::atomic< unsigned int > PuzzledFrame::n_obj

static

Author

cpellegrino

Definition at line 39 of file puzzled_frame.hh.

---

The documentation for this class was generated from the following files:

• puzzled_frame.hh
• puzzled_frame.cc