FRDEventMessage.cc

Go to the documentation of this file.

#include "IOPool/Streamer/interface/FRDEventMessage.h"

FRDEventMsgView::FRDEventMsgView(void* buf)
  : buf_((uint8*)buf),
    payload_(nullptr),
    size_(0),
    version_(0),
    run_(0),
    lumi_(0),
    event_(0),
    eventSize_(0),
    paddingSize_(0),
    adler32_(0),
    crc32c_(0)
{
  uint32* bufPtr = static_cast<uint32*>(buf);
  version_ = *bufPtr;
  // if the version number is rather large, then we assume that the true
  // version number is one.  (In version one of the format, there was
  // no version number in the data, and the run number appeared first.)
  if (version_ >= 32) {
      version_ = 1;
  }

  size_ = 0;

  // version number
  if (version_ >= 2) {
      size_ += sizeof(uint32);
      ++bufPtr;
  }

  // run number
  run_ = *bufPtr;
  size_ += sizeof(uint32);
  ++bufPtr;

  // lumi number
  if (version_ >= 2) {
      lumi_ = *bufPtr;
      size_ += sizeof(uint32);
      ++bufPtr;
  }

  // event number
  if (version_ == 4) {
    uint64 eventLow =  *bufPtr;
    size_ += sizeof(uint32);
    ++bufPtr;

    uint64 eventHigh =  *bufPtr;
    size_ += sizeof(uint32);
    ++bufPtr;

    event_ = (eventHigh << 32) | eventLow;

  } else {
    event_ = *bufPtr;
    size_ += sizeof(uint32);
    ++bufPtr;
  }

  if (version_ >= 3) {
      // event size
      eventSize_ = *bufPtr;
      size_ += sizeof(uint32) + eventSize_;
      ++bufPtr;

      if (version_ >= 5) {
        crc32c_ = *bufPtr;
        size_ += sizeof(uint32);
        ++bufPtr;
      }
      else {
        // padding size up to V4
        paddingSize_ = *bufPtr;
        size_ += sizeof(uint32) + paddingSize_;
        ++bufPtr;

        adler32_ = *bufPtr;
        size_ += sizeof(uint32);
        ++bufPtr;
      }
  }
  else {
      for (int idx = 0; idx < 1024; idx++) {
          size_ += sizeof(uint32);  // FED N size
          size_ += *bufPtr;         // FED N data
          eventSize_ += *bufPtr;
          ++bufPtr;
      }
  }

  payload_ = (void*)bufPtr;
}