DTDDUUnpacker Class Reference

#include <DTDDUUnpacker.h>

Inheritance diagram for DTDDUUnpacker:

Public Member Functions
	DTDDUUnpacker (const edm::ParameterSet &ps)
	Constructor. More...
const DTDDUData &	getDDUControlData () const
const std::vector< DTROS25Data > &	getROSsControlData () const
void	interpretRawData (const unsigned int *index, int datasize, int dduID, edm::ESHandle< DTReadOutMapping > &mapping, std::unique_ptr< DTDigiCollection > &product, std::unique_ptr< DTLocalTriggerCollection > &product2, uint16_t rosList=0) override
	~DTDDUUnpacker () override
	Destructor. More...
Public Member Functions inherited from DTUnpacker
	DTUnpacker ()
	Constructor. More...
virtual	~DTUnpacker ()
	Destructor. More...

Private Attributes
DTDDUData	controlData
const edm::ParameterSet	dduPSet
bool	debug
bool	localDAQ
	if data are read locally, status words are swapped More...
bool	performDataIntegrityMonitor
	perform DQM for DDU More...
DTROS25Unpacker *	ros25Unpacker

Detailed Description

The unpacker for DTs' FED.

Author

M. Zanetti INFN Padova FRC 060906

Definition at line 17 of file DTDDUUnpacker.h.

Constructor & Destructor Documentation

DTDDUUnpacker::DTDDUUnpacker

(

const edm::ParameterSet &

ps

)

Constructor.

Definition at line 19 of file DTDDUUnpacker.cc.

References dduPSet, debug, edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), localDAQ, and ros25Unpacker.

                                                      : 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 ( )

override

Destructor.

Definition at line 28 of file DTDDUUnpacker.cc.

References ros25Unpacker.

{ delete ros25Unpacker; }

Member Function Documentation

const DTDDUData& DTDDUUnpacker::getDDUControlData ( ) const

inline

Definition at line 36 of file DTDDUUnpacker.h.

References controlData.

{ return controlData; }

const std::vector<DTROS25Data>& DTDDUUnpacker::getROSsControlData ( ) const

inline

Definition at line 34 of file DTDDUUnpacker.h.

References DTROS25Unpacker::getROSsControlData(), and ros25Unpacker.

{ return ros25Unpacker->getROSsControlData(); }

void DTDDUUnpacker::interpretRawData ( const unsigned int *  index, int  datasize, int  dduID, edm::ESHandle< DTReadOutMapping > &  mapping, std::unique_ptr< DTDigiCollection > &  product, std::unique_ptr< DTLocalTriggerCollection > &  product2, uint16_t  rosList = 0  )

overridevirtual

Unpacking method. index is the pointer to the beginning of the buffer. datasize is the size of the buffer in bytes

Implements DTUnpacker.

Definition at line 30 of file DTDDUUnpacker.cc.

References DTDDUData::addDDUHeader(), DTDDUData::addDDUStatusWord(), DTDDUData::addDDUTrailer(), DTDDUData::addROSStatusWord(), FEDHeader::bxID(), FEDHeader::check(), FEDTrailer::check(), DTDDUData::checkCRCBit(), DTDDUData::clean(), controlData, gather_cfg::cout, debug, FEDTrailer::fragmentLength(), DTROS25Unpacker::interpretRawData(), localDAQ, FEDHeader::lvl1ID(), ros25Unpacker, and DTDDUSecondStatusWord::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);
}

Member Data Documentation

DTDDUData DTDDUUnpacker::controlData

private

Definition at line 51 of file DTDDUUnpacker.h.

Referenced by getDDUControlData(), and interpretRawData().

const edm::ParameterSet DTDDUUnpacker::dduPSet

private

Definition at line 39 of file DTDDUUnpacker.h.

Referenced by DTDDUUnpacker().

bool DTDDUUnpacker::debug

private

Definition at line 47 of file DTDDUUnpacker.h.

Referenced by util.rrapi.RRApi::dprint(), rrapi.RRApi::dprint(), DTDDUUnpacker(), pkg.AbstractPkg::generate(), util.rrapi.RRApi::get(), rrapi.RRApi::get(), pkg.AbstractPkg::get_kwds(), interpretRawData(), runTauIdMVA.TauIDEmbedder::loadMVA_WPs_run2_2017(), runTauIdMVA.TauIDEmbedder::runTauID(), and pkg.AbstractPkg::write().

bool DTDDUUnpacker::localDAQ

private

if data are read locally, status words are swapped

Definition at line 42 of file DTDDUUnpacker.h.

Referenced by DTDDUUnpacker(), and interpretRawData().

bool DTDDUUnpacker::performDataIntegrityMonitor

private

perform DQM for DDU

Definition at line 45 of file DTDDUUnpacker.h.

DTROS25Unpacker* DTDDUUnpacker::ros25Unpacker

private

Definition at line 49 of file DTDDUUnpacker.h.

Referenced by DTDDUUnpacker(), getROSsControlData(), interpretRawData(), and ~DTDDUUnpacker().