#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 39 of file DTDDUUnpacker.h.

References controlData.

                                                      {
     return controlData;
   }

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

inline

Definition at line 35 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 33 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);
 
 }