DTDDUUnpacker.cc

Go to the documentation of this file.

#include "DataFormats/FEDRawData/interface/FEDHeader.h"
#include "DataFormats/FEDRawData/interface/FEDTrailer.h"
#include "DataFormats/DTDigi/interface/DTDDUWords.h"
#include "DataFormats/DTDigi/interface/DTControlData.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "EventFilter/DTRawToDigi/plugins/DTDDUUnpacker.h"

#include <iostream>

using namespace std;
using namespace edm;

DTDDUUnpacker::DTDDUUnpacker(const edm::ParameterSet& ps) : dduPSet(ps) {
  // the ROS unpacker
  ros25Unpacker = new DTROS25Unpacker(dduPSet.getParameter<edm::ParameterSet>("rosParameters"));

  // parameters
  localDAQ = dduPSet.getUntrackedParameter<bool>("localDAQ",false);
  debug = dduPSet.getUntrackedParameter<bool>("debug",false);
}

DTDDUUnpacker::~DTDDUUnpacker() {
  delete ros25Unpacker;
}


void DTDDUUnpacker::interpretRawData(const unsigned int* index32, int datasize,
                     int dduID,
                     edm::ESHandle<DTReadOutMapping>& mapping,
                     std::unique_ptr<DTDigiCollection>& detectorProduct,
                     std::unique_ptr<DTLocalTriggerCollection>& triggerProduct,
                     uint16_t rosList) {

  // Definitions
  const int wordSize_32 = 4;
  const int wordSize_64 = 8;

  int numberOf32Words = datasize/wordSize_32;

  const unsigned char* index8 = reinterpret_cast<const unsigned char*>(index32);


  /*  D D U   d a t a */

  // DDU header
  FEDHeader dduHeader(index8);
  if (dduHeader.check()) {
    if(debug) cout << "[DTDDUUnpacker] FED Header. BXID: "<<dduHeader.bxID()
           << " L1ID: "<<dduHeader.lvl1ID() <<endl;
  } else {
    LogWarning("DTRawToDigi|DTDDUUnpacker") << "[DTDDUUnpacker] WARNING!, this is not a DDU Header, FED ID: "
                        << dduID << endl;
  }

  // DDU trailer
  // [BITS] stop before FED trailer := 8 bytes
  FEDTrailer dduTrailer(index8 + datasize - 1*wordSize_64);

  if (dduTrailer.check()) {
    if(debug) cout << "[DTDDUUnpacker] FED Trailer. Length of the DT event: "
           << dduTrailer.fragmentLength() << endl;
  } else {
    LogWarning("DTRawToDigi|DTDDUUnpacker") << "[DTDDUUnpacker] WARNING!, this is not a DDU Trailer, FED ID: "
                        << dduID << endl;
  }


  // Initialize control data
  controlData.clean();
  controlData.addDDUHeader(dduHeader);
  controlData.addDDUTrailer(dduTrailer);
  // check the CRC set in the FED trailer (FCRC errors)
  controlData.checkCRCBit(index8 + datasize - 1*wordSize_64);

  // Check Status Words
  vector<DTDDUFirstStatusWord> rosStatusWords;
  // [BITS] 3 words of 8 bytes + "rosId" bytes
  // In the case we are reading from DMA, the status word are swapped as the ROS data
  if (localDAQ) {
    // DDU channels from 1 to 4
    for (int rosId = 0; rosId < 4; rosId++ ) {
      int wordIndex8 = numberOf32Words*wordSize_32 - 3*wordSize_64 + wordSize_32 + rosId;
      controlData.addROSStatusWord(DTDDUFirstStatusWord(index8[wordIndex8]));
    }
    // DDU channels from 5 to 8
    for (int rosId = 0; rosId < 4; rosId++ ) {
      int wordIndex8 = numberOf32Words*wordSize_32 - 3*wordSize_64 + rosId;
      controlData.addROSStatusWord(DTDDUFirstStatusWord(index8[wordIndex8]));
    }
    // DDU channels from 9 to 12
    for (int rosId = 0; rosId < 4; rosId++ ) {
      int wordIndex8 = numberOf32Words*wordSize_32 - 2*wordSize_64 + wordSize_32 + rosId;
      controlData.addROSStatusWord(DTDDUFirstStatusWord(index8[wordIndex8]));
    }
  }
  else {
    for (int rosId = 0; rosId < 12; rosId++ ) {
      int wordIndex8 = numberOf32Words*wordSize_32 - 3*wordSize_64 + rosId;
      controlData.addROSStatusWord(DTDDUFirstStatusWord(index8[wordIndex8]));
    }
  }

  int theROSList;
  // [BITS] 2 words of 8 bytes + 4 bytes (half 64 bit word)
  // In the case we are reading from DMA, the status word are swapped as the ROS data
  if (localDAQ) {
    DTDDUSecondStatusWord dduStatusWord(index32[numberOf32Words - 2*wordSize_64/wordSize_32]);
    controlData.addDDUStatusWord(dduStatusWord);
    theROSList =  dduStatusWord.rosList();
  }
  else {
    DTDDUSecondStatusWord dduStatusWord(index32[numberOf32Words - 2*wordSize_64/wordSize_32 + 1]);
    controlData.addDDUStatusWord(dduStatusWord);
    theROSList =  dduStatusWord.rosList();
  }


  /*  R O S   d a t a */

  // Set the index to start looping on ROS data
  // [BITS] one 8 bytes word
  index32 += (wordSize_64)/wordSize_32;

  // Set the datasize to look only at ROS data
  // [BITS] header, trailer, 2 status words
  datasize -= 4*wordSize_64;

  // unpacking the ROS payload
  ros25Unpacker->interpretRawData(index32, datasize, dduID, mapping, detectorProduct, triggerProduct, theROSList);

}