#include <DTSpyReader.h>

Inheritance diagram for DTSpyReader:

Public Member Functions
uint64_t	dmaUnpack (const uint32_t *dmaData, bool &isData)
	pre-unpack the data if read via DMA More...

	DTSpyReader (const edm::ParameterSet &pset)
	Constructor. More...

virtual int	fillRawData (edm::Event &e, FEDRawDataCollection *&data)
	Generate and fill FED raw data for a full event. More...

bool	isHeader (uint64_t word, bool dataTag)
	check for a 64 bits word to be a DDU header More...

bool	isTrailer (uint64_t word, bool dataTag, unsigned int wordCount)
	check for a 64 bits word to be a DDU trailer More...

void	produce (edm::Event &, edm::EventSetup const &) override

void	swap (uint64_t &word)
	swapping the lsBits with the msBits More...

	~DTSpyReader () override
	Destructor. More...

Public Member Functions inherited from edm::EDProducer
	EDProducer ()

SerialTaskQueue *	globalLuminosityBlocksQueue ()

SerialTaskQueue *	globalRunsQueue ()

ModuleDescription const &	moduleDescription () const

	~EDProducer () override

Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const

std::vector< bool > const &	recordProvenanceList () const

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)

TypeLabelList const &	typeLabelList () const
	used by the fwk to register the list of products of this module More...

	~ProducerBase () noexcept(false) override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase &&)=default

	EDConsumerBase (EDConsumerBase const &)=delete

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase &	operator= (EDConsumerBase &&)=default

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Private Attributes
int	dduID

bool	debug

edm::EventNumber_t	eventNumber

DTSpy *	mySpy

edm::RunNumber_t	runNumber

Static Private Attributes
static const int	dduWordLength = 8

Additional Inherited Members
Public Types inherited from edm::EDProducer
typedef EDProducer	ModuleType

Public Types inherited from edm::ProducerBase
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const , const char , edm::ProductResolverIndex > >

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Static Public Member Functions inherited from edm::EDProducer
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

static bool	wantsGlobalLuminosityBlocks ()

static bool	wantsGlobalRuns ()

static bool	wantsStreamLuminosityBlocks ()

static bool	wantsStreamRuns ()

Protected Member Functions inherited from edm::ProducerBase
template<class ProductType >
BranchAliasSetterT< ProductType >	produces ()
	declare what type of product will make and with which optional label More...

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces ()

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces ()

BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<BranchType B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<Transition B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<class ProductType >
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

ProducesCollector	producesCollector ()

Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

Detailed Description

Read DT ROS8 raw data files

Date: 2010/02/03 16:58:24

Revision: 1.4

Author: M. Zanetti - INFN Padova

Definition at line 24 of file DTSpyReader.h.

Constructor & Destructor Documentation

◆ DTSpyReader()

DTSpyReader::DTSpyReader ( const edm::ParameterSet & pset )

Constructor.

connecting to XDAQ note ("0.0.0.0" = localhost)

Definition at line 31 of file DTSpyReader.cc.

                                                     : runNumber(1), eventNumber(0) {
   // instatiating Sandro's spy (My name is Bond, Sandro Bond)
   mySpy = new DTSpy();
  
   string connectionParameters = pset.getUntrackedParameter<string>("connectionParameters");
   mySpy->Connect(connectionParameters.c_str(), 10000);
  
   cout << endl;
   cout << "DT Local DAQ online spy. Connected to IP " << connectionParameters.c_str()
        << ". Waiting for the data to be flushed" << endl;
   cout << endl;
  
   debug = pset.getUntrackedParameter<bool>("debug", false);
   dduID = pset.getUntrackedParameter<int32_t>("dduID", 770);  // NOT needed
  
   produces<FEDRawDataCollection>();
 }

References DTCtcp::Connect(), gather_cfg::cout, dduID, debug, mySpy, and muonDTDigis_cfi::pset.

◆ ~DTSpyReader()

DTSpyReader::~DTSpyReader ( )

override

Destructor.

Definition at line 50 of file DTSpyReader.cc.

50 { delete mySpy; }

References mySpy.

Member Function Documentation

◆ dmaUnpack()

uint64_t DTSpyReader::dmaUnpack	(	const uint32_t *	dmaData,
		bool &	isData
	)

pre-unpack the data if read via DMA

Definition at line 147 of file DTSpyReader.cc.

                                                                      {
   uint32_t unpackedData[2] = {0, 0};
   // adjust 4 32-bits words  into 2 32-bits words
   unpackedData[0] |= dmaData[3] & 0x3ffff;
   unpackedData[0] |= (dmaData[2] << 18) & 0xfffc0000;
   unpackedData[1] |= (dmaData[2] >> 14) & 0x0f;
   unpackedData[1] |= (dmaData[1] << 4) & 0x3ffff0;
   unpackedData[1] |= (dmaData[0] << 22) & 0xffc00000;
  
   isData = (dmaData[0] >> 10) & 0x01;
  
   //printf ("Lower part: %x \n", unpackedData[0]);
   //printf ("Upper part: %x \n", unpackedData[1]);
  
   // push_back to a 64 word
   uint64_t dduWord = (uint64_t(unpackedData[1]) << 32) | unpackedData[0];
  
   return dduWord;
 }

References HLTBitAnalyser_cfi::isData.

Referenced by fillRawData().

◆ fillRawData()

int DTSpyReader::fillRawData	(	edm::Event &	e,
		FEDRawDataCollection *&	data
	)

virtual

Generate and fill FED raw data for a full event.

Definition at line 52 of file DTSpyReader.cc.

                                                           {
   EventID eID = e.id();
  
   // ask for a new buffer
   mySpy->getNextBuffer();
  
   // get the pointer to the beginning of the buffer
   const char* rawDTData = mySpy->getEventPointer();
  
   const uint32_t* rawDTData32 = reinterpret_cast<const uint32_t*>(rawDTData);
  
   // instantiate the FEDRawDataCollection
   data = new FEDRawDataCollection();
  
   vector<uint64_t> eventData;
   uint64_t word = 0;
   int wordCount = 0;
   int wordCountCheck = 0;
  
   bool headerTag = false;
   bool dataTag = true;
  
   // Advance at long-word steps until the trailer is reached.
   // Skipped whatever else is in the buffer (e.g. another event..)
   while (!isTrailer(word, dataTag, wordCount)) {
     // dma gets 4 32-bits words and create a 64 bit one
     word = dmaUnpack(rawDTData32, dataTag);
  
     // look for the DDU header
     if (isHeader(word, dataTag))
       headerTag = true;
  
     // check whether the first word is a DDU header
     if (wordCountCheck > 0 && !headerTag && debug)
       cout << "[DTSpyReader]: WARNING: header still not found!!" << endl;
  
     // from now on fill the eventData with the ROS data
     if (headerTag) {
       // swapping only the 32 bits words
       if (dataTag)
         swap(word);
       // WARNING also the ddu status words have been swapped!
       // Control the correct interpretation in DDUUnpacker
  
       eventData.push_back(word);
       wordCount++;
     }
  
     // advancing by 4 32-bits words
     rawDTData32 += 4;
  
     // counting the total number of group of 128 bits (=4*32) in the buffer
     wordCountCheck++;
   }
  
   // Setting the Event ID
   runNumber = mySpy->getRunNo();
   eID = EventID(runNumber, 1U, eventNumber);
  
   // eventDataSize = (Number Of Words)* (Word Size)
   int eventDataSize = eventData.size() * dduWordLength;
  
   if (debug)
     cout << " DDU ID = " << dduID << endl;
  
   FEDRawData& fedRawData = data->FEDData(dduID);
   fedRawData.resize(eventDataSize);
  
   copy(reinterpret_cast<unsigned char*>(&eventData[0]),
        reinterpret_cast<unsigned char*>(&eventData[0]) + eventDataSize,
        fedRawData.data());
  
   mySpy->setlastPointer((char*)rawDTData32);
  
   return true;
 }

References filterCSVwithJSON::copy, gather_cfg::cout, data, gctErrorAnalyzer_cfi::dataTag, dduID, dduWordLength, debug, dmaUnpack(), MillePedeFileConverter_cfg::e, eventNumber, l1t_dqm_sourceclient-live_cfg::fedRawData, EcalFEDMonitor_cfi::FEDRawDataCollection, DTSpy::getEventPointer(), DTSpy::getNextBuffer(), DTSpy::getRunNo(), isHeader(), isTrailer(), mySpy, runNumber, DTSpy::setlastPointer(), swap(), and mitigatedMETSequence_cff::U.

Referenced by produce().

◆ isHeader()

bool DTSpyReader::isHeader	(	uint64_t	word,
		bool	dataTag
	)

check for a 64 bits word to be a DDU header

Definition at line 167 of file DTSpyReader.cc.

                                                       {
   bool it_is = false;
   FEDHeader candidate(reinterpret_cast<const unsigned char*>(&word));
   if (candidate.check()) {
     // if ( candidate.check() && !dataTag) {
     it_is = true;
     dduID = candidate.sourceID();
     eventNumber++;
   }
   return it_is;
 }

References FEDHeader::check(), dduID, eventNumber, and FEDHeader::sourceID().

Referenced by fillRawData().

◆ isTrailer()

bool DTSpyReader::isTrailer	(	uint64_t	word,
		bool	dataTag,
		unsigned int	wordCount
	)

check for a 64 bits word to be a DDU trailer

Definition at line 179 of file DTSpyReader.cc.

                                                                                {
   bool it_is = false;
   FEDTrailer candidate(reinterpret_cast<const unsigned char*>(&word));
   if (candidate.check()) {
     //  if ( candidate.check() && !dataTag) {
     if (wordCount == candidate.fragmentLength())
       it_is = true;
   }
   return it_is;
 }

References FEDTrailer::check(), and FEDTrailer::fragmentLength().

Referenced by fillRawData().

◆ produce()

void DTSpyReader::produce	(	edm::Event &	e,
		edm::EventSetup const &	es
	)

overridevirtual

Implements edm::EDProducer.

Definition at line 131 of file DTSpyReader.cc.

                                                         {
   edm::Handle<FEDRawDataCollection> rawdata;
   FEDRawDataCollection* fedcoll = nullptr;
   fillRawData(e, fedcoll);
   std::unique_ptr<FEDRawDataCollection> bare_product(fedcoll);
   e.put(std::move(bare_product));
 }

References MillePedeFileConverter_cfg::e, fillRawData(), and eostools::move().

◆ swap()

void DTSpyReader::swap ( uint64_t & word )

swapping the lsBits with the msBits

Definition at line 139 of file DTSpyReader.cc.

                                      {
   twoNibble64* newWorld = reinterpret_cast<twoNibble64*>(&word);
  
   uint32_t msBits_tmp = newWorld->msBits;
   newWorld->msBits = newWorld->lsBits;
   newWorld->lsBits = msBits_tmp;
 }

References twoNibble64::lsBits, and twoNibble64::msBits.

Referenced by fillRawData().

Member Data Documentation

◆ dduID

int DTSpyReader::dduID

private

Definition at line 59 of file DTSpyReader.h.

Referenced by DTSpyReader(), fillRawData(), and isHeader().

◆ dduWordLength

const int DTSpyReader::dduWordLength = 8

staticprivate

Definition at line 61 of file DTSpyReader.h.

Referenced by fillRawData().

◆ debug

bool DTSpyReader::debug

private

Definition at line 58 of file DTSpyReader.h.

Referenced by DTSpyReader(), fillRawData(), runTauIdMVA.TauIDEmbedder::loadMVA_WPs_run2_2017(), and runTauIdMVA.TauIDEmbedder::runTauID().

◆ eventNumber

edm::EventNumber_t DTSpyReader::eventNumber

private

Definition at line 56 of file DTSpyReader.h.

Referenced by fillRawData(), and isHeader().

◆ mySpy

DTSpy* DTSpyReader::mySpy

private

Definition at line 53 of file DTSpyReader.h.

Referenced by DTSpyReader(), fillRawData(), and ~DTSpyReader().

◆ runNumber

edm::RunNumber_t DTSpyReader::runNumber

private

Definition at line 55 of file DTSpyReader.h.

Referenced by fillRawData().

Public Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DTSpyReader()

◆ ~DTSpyReader()

Member Function Documentation

◆ dmaUnpack()

◆ fillRawData()

◆ isHeader()

◆ isTrailer()

◆ produce()

◆ swap()

Member Data Documentation

◆ dduID

◆ dduWordLength

◆ debug

◆ eventNumber

◆ mySpy

◆ runNumber