#include <DTDataIntegrityROSOffline.h>

Inheritance diagram for DTDataIntegrityROSOffline:

Public Member Functions
void	analyze (const edm::Event &e, const edm::EventSetup &c) override

	DTDataIntegrityROSOffline (const edm::ParameterSet &ps)

void	fedEntry (int dduID)

void	fedFatal (int dduID)

void	fedNonFatal (int dduID)

void	processFED (DTDDUData &dduData, const std::vector< DTROS25Data > &rosData, int dduID)

void	processROS25 (DTROS25Data &data, int dduID, int ros)

	~DTDataIntegrityROSOffline () override

Public Member Functions inherited from DQMEDAnalyzer
void	accumulate (edm::Event const &event, edm::EventSetup const &setup) final

void	beginLuminosityBlock (edm::LuminosityBlock const &lumi, edm::EventSetup const &setup) final

void	beginRun (edm::Run const &run, edm::EventSetup const &setup) final

void	beginStream (edm::StreamID id) final

virtual void	dqmBeginRun (edm::Run const &, edm::EventSetup const &)

	DQMEDAnalyzer ()

void	endLuminosityBlock (edm::LuminosityBlock const &lumi, edm::EventSetup const &setup) final

void	endRun (edm::Run const &run, edm::EventSetup const &setup) final

virtual bool	getCanSaveByLumi ()

Public Member Functions inherited from edm::stream::EDProducer< edm::GlobalCache< DQMEDAnalyzerGlobalCache >, edm::EndRunProducer, edm::EndLuminosityBlockProducer, edm::Accumulator >
	EDProducer ()=default

	EDProducer (const EDProducer &)=delete

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginProcessBlocks () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndProcessBlocks () const final

bool	hasAbilityToProduceInEndRuns () const final

const EDProducer &	operator= (const EDProducer &)=delete

Protected Member Functions
void	bookHistograms (DQMStore::IBooker &, edm::Run const &, edm::EventSetup const &) override

Protected Member Functions inherited from DQMEDAnalyzer
uint64_t	meId () const

Private Member Functions
void	bookHistos (DQMStore::IBooker &, const int fedMin, const int fedMax)

void	bookHistos (DQMStore::IBooker &, std::string folder, DTROChainCoding code)

void	bookHistosROS25 (DQMStore::IBooker &, DTROChainCoding code)

void	channelsInCEROS (int cerosId, int chMask, std::vector< int > &channels)

void	channelsInROS (int cerosMask, std::vector< int > &channels)

std::string	topFolder (bool isFEDIntegrity) const

Private Attributes
edm::EDGetTokenT< DTDDUCollection >	dduToken

bool	eventErrorFlag

std::set< int >	fedBXIds

std::map< std::string, std::map< int, MonitorElement * > >	fedHistos

int	FEDIDmax

int	FEDIDmin

std::string	fedIntegrityFolder

bool	getSCInfo

MonitorElement *	hCorruptionSummary

MonitorElement *	hFEDEntry

MonitorElement *	hFEDFatal

MonitorElement *	hFEDNonFatal

MonitorElement *	hTTSSummary

MonitorElement *	nEventMonitor

int	nevents

int	neventsFED

int	neventsROS

const int	nROS = 12

edm::EDGetTokenT< DTROS25Collection >	ros25Token

std::map< int, std::set< int > >	rosBxIdsPerFED

std::map< std::string, std::map< int, MonitorElement * > >	rosHistos

std::map< int, std::set< int > >	rosL1AIdsPerFED

std::map< std::string, std::map< int, MonitorElement * > >	summaryHistos

Additional Inherited Members
Public Types inherited from DQMEDAnalyzer
typedef dqm::reco::DQMStore	DQMStore

typedef dqm::reco::MonitorElement	MonitorElement

Public Types inherited from edm::stream::EDProducer< edm::GlobalCache< DQMEDAnalyzerGlobalCache >, edm::EndRunProducer, edm::EndLuminosityBlockProducer, edm::Accumulator >
using	CacheTypes = CacheContexts< T... >

using	GlobalCache = typename CacheTypes::GlobalCache

using	HasAbility = AbilityChecker< T... >

using	InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache

using	LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache

using	LuminosityBlockContext = LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >

using	LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache

using	RunCache = typename CacheTypes::RunCache

using	RunContext = RunContextT< RunCache, GlobalCache >

using	RunSummaryCache = typename CacheTypes::RunSummaryCache

Static Public Member Functions inherited from DQMEDAnalyzer
static void	globalEndJob (DQMEDAnalyzerGlobalCache const *)

static void	globalEndLuminosityBlockProduce (edm::LuminosityBlock &lumi, edm::EventSetup const &setup, LuminosityBlockContext const *context)

static void	globalEndRunProduce (edm::Run &run, edm::EventSetup const &setup, RunContext const *context)

static std::unique_ptr< DQMEDAnalyzerGlobalCache >	initializeGlobalCache (edm::ParameterSet const &)

Protected Attributes inherited from DQMEDAnalyzer
edm::EDPutTokenT< DQMToken >	lumiToken_

edm::EDPutTokenT< DQMToken >	runToken_

unsigned int	streamId_

Detailed Description

Class for DT Data Integrity.

Author: Marco Zanetti (INFN Padova), Gianluca Cerminara (INFN Torino)

Definition at line 33 of file DTDataIntegrityROSOffline.h.

Constructor & Destructor Documentation

◆ DTDataIntegrityROSOffline()

DTDataIntegrityROSOffline::DTDataIntegrityROSOffline ( const edm::ParameterSet & ps )

Definition at line 29 of file DTDataIntegrityROSOffline.cc.

References dduToken, FEDIDmax, FEDIDmin, fedIntegrityFolder, getSCInfo, edm::ParameterSet::getUntrackedParameter(), LogTrace, FEDNumbering::MAXDTFEDID, FEDNumbering::MINDTFEDID, neventsFED, and ros25Token.

                                                                               : nevents(0) {
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline]: Constructor" << endl;
 
   dduToken = consumes<DTDDUCollection>(ps.getUntrackedParameter<InputTag>("dtDDULabel"));
   ros25Token = consumes<DTROS25Collection>(ps.getUntrackedParameter<InputTag>("dtROS25Label"));
   FEDIDmin = FEDNumbering::MINDTFEDID;
   FEDIDmax = FEDNumbering::MAXDTFEDID;
 
   neventsFED = 0;
 
   //   Plot quantities about SC
   getSCInfo = ps.getUntrackedParameter<bool>("getSCInfo", false);
 
   fedIntegrityFolder = ps.getUntrackedParameter<string>("fedIntegrityFolder", "DT/FEDIntegrity");
 }

◆ ~DTDataIntegrityROSOffline()

DTDataIntegrityROSOffline::~DTDataIntegrityROSOffline ( )

override

Definition at line 46 of file DTDataIntegrityROSOffline.cc.

References LogTrace, and neventsFED.

                                                       {
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline]: Destructor. Analyzed " << neventsFED << " events" << endl;
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline]: postEndJob called!" << endl;
 }

Member Function Documentation

◆ analyze()

void DTDataIntegrityROSOffline::analyze	(	const edm::Event &	e,
		const edm::EventSetup &	c
	)

overridevirtual

Reimplemented from DQMEDAnalyzer.

Definition at line 713 of file DTDataIntegrityROSOffline.cc.

References dduToken, MillePedeFileConverter_cfg::e, eventErrorFlag, fedBXIds, FEDIDmax, FEDIDmin, dqm::impl::MonitorElement::Fill(), DTDDUData::getDDUHeader(), RecoTauValidation_cfi::header, mps_fire::i, edm::HandleBase::isValid(), dqmiolumiharvest::j, LogTrace, genParticles_cff::map, nEventMonitor, nevents, processFED(), processROS25(), ros25Token, rosBxIdsPerFED, and rosL1AIdsPerFED.

                                                                                  {
   nevents++;
   nEventMonitor->Fill(nevents);
 
   LogTrace("DTRawToDigi|TDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline]: preProcessEvent" << endl;
 
   //Legacy ROS
   // clear the set of BXids from the ROSs
   for (map<int, set<int> >::iterator rosBxIds = rosBxIdsPerFED.begin(); rosBxIds != rosBxIdsPerFED.end(); ++rosBxIds) {
     (*rosBxIds).second.clear();
   }
 
   fedBXIds.clear();
 
   for (map<int, set<int> >::iterator rosL1AIds = rosL1AIdsPerFED.begin(); rosL1AIds != rosL1AIdsPerFED.end();
        ++rosL1AIds) {
     (*rosL1AIds).second.clear();
   }
 
   // reset the error flag
   eventErrorFlag = false;
 
   // Digi collection
   edm::Handle<DTDDUCollection> dduProduct;
   e.getByToken(dduToken, dduProduct);
   edm::Handle<DTROS25Collection> ros25Product;
   e.getByToken(ros25Token, ros25Product);
 
   DTDDUData dduData;
   std::vector<DTROS25Data> ros25Data;
   if (dduProduct.isValid() && ros25Product.isValid()) {
     for (unsigned int i = 0; i < dduProduct->size(); ++i) {
       dduData = dduProduct->at(i);
       ros25Data = ros25Product->at(i);
       FEDHeader header = dduData.getDDUHeader();
       int id = header.sourceID();
       if (id > FEDIDmax || id < FEDIDmin)
         continue;  //SIM uses extra FEDs not monitored
 
       processFED(dduData, ros25Data, id);
       for (unsigned int j = 0; j < ros25Data.size(); ++j) {
         int rosid = j + 1;
         processROS25(ros25Data[j], id, rosid);
       }
     }
   }
 }

◆ bookHistograms()

void DTDataIntegrityROSOffline::bookHistograms	(	DQMStore::IBooker &	ibooker,
		edm::Run const &	iRun,
		edm::EventSetup const &	iSetup
	)

overrideprotectedvirtual

Implements DQMEDAnalyzer.

Definition at line 62 of file DTDataIntegrityROSOffline.cc.

References bookHistos(), bookHistosROS25(), FEDIDmax, FEDIDmin, LogTrace, nROS, DTROChainCoding::setDDU(), and DTROChainCoding::setROS().

                                                                             {
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline]: postBeginJob" << endl;
 
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline] Get DQMStore service" << endl;
 
   // Loop over the DT FEDs
 
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << " FEDS: " << FEDIDmin << " to " << FEDIDmax << " in the RO" << endl;
 
   // book FED integrity histos
   bookHistos(ibooker, FEDIDmin, FEDIDmax);
 
   //Legacy ROS
 
   // static booking of the histograms
 
   for (int fed = FEDIDmin; fed <= FEDIDmax; ++fed) {  // loop over the FEDs in the readout
     DTROChainCoding code;
     code.setDDU(fed);
     bookHistos(ibooker, string("ROS_S"), code);
 
     bookHistos(ibooker, string("DDU"), code);
 
     for (int ros = 1; ros <= nROS; ++ros) {  // loop over all ROS
       code.setROS(ros);
       bookHistosROS25(ibooker, code);
     }
   }
 }

◆ bookHistos() [1/2]

void DTDataIntegrityROSOffline::bookHistos	(	DQMStore::IBooker &	ibooker,
		const int	fedMin,
		const int	fedMax
	)

private

Definition at line 97 of file DTDataIntegrityROSOffline.cc.

References dqm::implementation::IBooker::book1D(), dqm::implementation::IBooker::book2D(), dqm::implementation::IBooker::bookFloat(), hCorruptionSummary, hFEDEntry, hFEDFatal, hFEDNonFatal, hTTSSummary, nEventMonitor, dqm::impl::MonitorElement::setAxisTitle(), dqm::impl::MonitorElement::setBinLabel(), dqm::implementation::NavigatorBase::setCurrentFolder(), and topFolder().

Referenced by bookHistograms(), and bookHistosROS25().

                                                                                                        {
   ibooker.setCurrentFolder("DT/EventInfo/Counters");
   nEventMonitor = ibooker.bookFloat("nProcessedEventsDataIntegrity");
 
   // Standard FED integrity histos
   ibooker.setCurrentFolder(topFolder(true));
 
   int nFED = (fedMax - fedMin) + 1;
 
   hFEDEntry = ibooker.book1D("FEDEntries", "# entries per DT FED", nFED, fedMin, fedMax + 1);
 
   hFEDFatal = ibooker.book1D("FEDFatal", "# fatal errors DT FED", nFED, fedMin, fedMax + 1);
   hFEDNonFatal = ibooker.book1D("FEDNonFatal", "# NON fatal errors DT FED", nFED, fedMin, fedMax + 1);
 
   ibooker.setCurrentFolder(topFolder(false));
   hTTSSummary = ibooker.book2D("TTSSummary", "Summary Status TTS", nFED, fedMin, fedMax + 1, 9, 1, 10);
   hTTSSummary->setAxisTitle("FED", 1);
   hTTSSummary->setBinLabel(1, "ROS PAF", 2);
   hTTSSummary->setBinLabel(2, "DDU PAF", 2);
   hTTSSummary->setBinLabel(3, "ROS PAF", 2);
   hTTSSummary->setBinLabel(4, "DDU PAF", 2);
   hTTSSummary->setBinLabel(5, "DDU Full", 2);
   hTTSSummary->setBinLabel(6, "L1A Mism.", 2);
   hTTSSummary->setBinLabel(7, "ROS Error", 2);
   hTTSSummary->setBinLabel(8, "BX Mism.", 2);
   hTTSSummary->setBinLabel(9, "DDU Logic Err.", 2);
 
   // bookkeeping of the histos
   hCorruptionSummary =
       ibooker.book2D("DataCorruptionSummary", "Data Corruption Sources", nFED, fedMin, fedMax + 1, 8, 1, 9);
   hCorruptionSummary->setAxisTitle("FED", 1);
   hCorruptionSummary->setBinLabel(1, "Miss Ch.", 2);
   hCorruptionSummary->setBinLabel(2, "ROS BX mism", 2);
   hCorruptionSummary->setBinLabel(3, "DDU BX mism", 2);
   hCorruptionSummary->setBinLabel(4, "ROS L1A mism", 2);
   hCorruptionSummary->setBinLabel(5, "Miss Payload", 2);
   hCorruptionSummary->setBinLabel(6, "FCRC bit", 2);
   hCorruptionSummary->setBinLabel(7, "Header check", 2);
   hCorruptionSummary->setBinLabel(8, "Trailer Check", 2);
 }

◆ bookHistos() [2/2]

void DTDataIntegrityROSOffline::bookHistos	(	DQMStore::IBooker &	,
		std::string	folder,
		DTROChainCoding	code
	)

private

◆ bookHistosROS25()

void DTDataIntegrityROSOffline::bookHistosROS25	(	DQMStore::IBooker &	ibooker,
		DTROChainCoding	code
	)

private

Definition at line 305 of file DTDataIntegrityROSOffline.cc.

References bookHistos().

Referenced by bookHistograms().

                                                                                               {
   bookHistos(ibooker, string("ROS"), code);
 }

◆ channelsInCEROS()

void DTDataIntegrityROSOffline::channelsInCEROS	(	int	cerosId,
		int	chMask,
		std::vector< int > &	channels
	)

private

Definition at line 693 of file DTDataIntegrityROSOffline.cc.

References ewkTauDQM_cfi::channels, and testProducerWithPsetDescEmpty_cfi::x1.

Referenced by processROS25().

                                                                                               {
   for (int iCh = 0; iCh < 6; ++iCh) {
     if ((chMask >> iCh) & 0x1) {
       channels.push_back(cerosId * 6 + iCh);
     }
   }
   return;
 }

◆ channelsInROS()

void DTDataIntegrityROSOffline::channelsInROS	(	int	cerosMask,
		std::vector< int > &	channels
	)

private

Definition at line 702 of file DTDataIntegrityROSOffline.cc.

References ewkTauDQM_cfi::channels, and testProducerWithPsetDescEmpty_cfi::x1.

Referenced by processROS25().

                                                                                   {
   for (int iCeros = 0; iCeros < 5; ++iCeros) {
     if ((cerosMask >> iCeros) & 0x1) {
       for (int iCh = 0; iCh < 6; ++iCh) {
         channels.push_back(iCeros * 6 + iCh);
       }
     }
   }
   return;
 }

◆ fedEntry()

void DTDataIntegrityROSOffline::fedEntry ( int dduID )

Definition at line 679 of file DTDataIntegrityROSOffline.cc.

References dqm::impl::MonitorElement::Fill(), and hFEDEntry.

679 { hFEDEntry->Fill(dduID); }

dqm::impl::MonitorElement::Fill

void Fill(long long x)

Definition: MonitorElement.h:292

DTDataIntegrityROSOffline::hFEDEntry

MonitorElement * hFEDEntry

Definition: DTDataIntegrityROSOffline.h:79

◆ fedFatal()

void DTDataIntegrityROSOffline::fedFatal ( int dduID )

Definition at line 682 of file DTDataIntegrityROSOffline.cc.

References dqm::impl::MonitorElement::Fill(), and hFEDFatal.

682 { hFEDFatal->Fill(dduID); }

dqm::impl::MonitorElement::Fill

void Fill(long long x)

Definition: MonitorElement.h:292

DTDataIntegrityROSOffline::hFEDFatal

MonitorElement * hFEDFatal

Definition: DTDataIntegrityROSOffline.h:80

◆ fedNonFatal()

void DTDataIntegrityROSOffline::fedNonFatal ( int dduID )

Definition at line 685 of file DTDataIntegrityROSOffline.cc.

References dqm::impl::MonitorElement::Fill(), and hFEDNonFatal.

685 { hFEDNonFatal->Fill(dduID); }

dqm::impl::MonitorElement::Fill

void Fill(long long x)

Definition: MonitorElement.h:292

DTDataIntegrityROSOffline::hFEDNonFatal

MonitorElement * hFEDNonFatal

Definition: DTDataIntegrityROSOffline.h:81

◆ processFED()

void DTDataIntegrityROSOffline::processFED	(	DTDDUData &	dduData,
		const std::vector< DTROS25Data > &	rosData,
		int	dduID
	)

Definition at line 543 of file DTDataIntegrityROSOffline.cc.

References FEDTrailer::check(), data, fedBXIds, fedHistos, FEDIDmax, FEDIDmin, dqm::impl::MonitorElement::Fill(), FEDTrailer::fragmentLength(), DTROChainCoding::getDDUID(), hCorruptionSummary, RecoTauValidation_cfi::header, hFEDEntry, hFEDFatal, mps_fire::i, LogTrace, neventsFED, rosBxIdsPerFED, rosL1AIdsPerFED, DTDDUSecondStatusWord::rosList(), DTROChainCoding::setDDU(), and testProducerWithPsetDescEmpty_cfi::x1.

Referenced by analyze().

                                                                                                           {
   neventsFED++;
   if (neventsFED % 1000 == 0)
     LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
         << "[DTDataIntegrityROSOffline]: " << neventsFED << " events analyzed by processFED" << endl;
 
   DTROChainCoding code;
   code.setDDU(ddu);
   if (code.getDDUID() < FEDIDmin || code.getDDUID() > FEDIDmax)
     return;
 
   hFEDEntry->Fill(code.getDDUID());
 
   const FEDTrailer& trailer = data.getDDUTrailer();
   const FEDHeader& header = data.getDDUHeader();
 
   // check consistency of header and trailer
   if (!header.check()) {
     // error code 7
     hFEDFatal->Fill(code.getDDUID());
     hCorruptionSummary->Fill(code.getDDUID(), 7);
   }
 
   if (!trailer.check()) {
     // error code 8
     hFEDFatal->Fill(code.getDDUID());
     hCorruptionSummary->Fill(code.getDDUID(), 8);
   }
 
   // check CRC error bit set by DAQ before sending data on SLink
   if (data.crcErrorBit()) {
     // error code 6
     hFEDFatal->Fill(code.getDDUID());
     hCorruptionSummary->Fill(code.getDDUID(), 6);
   }
 
   const DTDDUSecondStatusWord& secondWord = data.getSecondStatusWord();
 
   //2D HISTO: ROS VS STATUS (8 BIT = 8 BIN) from 1st-2nd status words (9th BIN FROM LIST OF ROS in 2nd status word)
   MonitorElement* hROSStatus = fedHistos["ROSStatus"][code.getDDUID()];
   //1D HISTO: NUMBER OF ROS IN THE EVENTS from 2nd status word
 
   int rosList = secondWord.rosList();
   set<int> rosPositions;
   for (int i = 0; i < 12; i++) {
     if (rosList & 0x1) {
       rosPositions.insert(i);
       //9th BIN FROM LIST OF ROS in 2nd status word
       hROSStatus->Fill(8, i, 1);
     }
     rosList >>= 1;
   }
 
   int channel = 0;
   for (vector<DTDDUFirstStatusWord>::const_iterator fsw_it = data.getFirstStatusWord().begin();
        fsw_it != data.getFirstStatusWord().end();
        fsw_it++) {
     // assuming association one-to-one between DDU channel and ROS
     hROSStatus->Fill(0, channel, (*fsw_it).channelEnabled());
     hROSStatus->Fill(1, channel, (*fsw_it).timeout());
     hROSStatus->Fill(2, channel, (*fsw_it).eventTrailerLost());
     hROSStatus->Fill(3, channel, (*fsw_it).opticalFiberSignalLost());
     hROSStatus->Fill(4, channel, (*fsw_it).tlkPropagationError());
     hROSStatus->Fill(5, channel, (*fsw_it).tlkPatternError());
     hROSStatus->Fill(6, channel, (*fsw_it).tlkSignalLost());
     hROSStatus->Fill(7, channel, (*fsw_it).errorFromROS());
     // check that the enabled channel was also in the read-out
     if ((*fsw_it).channelEnabled() == 1 && rosPositions.find(channel) == rosPositions.end()) {
       hROSStatus->Fill(9, channel, 1);
       // error code 1
       hFEDFatal->Fill(code.getDDUID());
       hCorruptionSummary->Fill(code.getDDUID(), 1);
     }
     channel++;
   }
 
   // ---------------------------------------------------------------------
   // cross checks between FED and ROS data
   // check the BX ID against the ROSs
   set<int> rosBXIds = rosBxIdsPerFED[ddu];
   if ((rosBXIds.size() > 1 || rosBXIds.find(header.bxID()) == rosBXIds.end()) &&
       !rosBXIds.empty()) {  // in this case look for faulty ROSs
     for (vector<DTROS25Data>::const_iterator rosControlData = rosData.begin(); rosControlData != rosData.end();
          ++rosControlData) {  // loop over the ROS data
       for (vector<DTROSDebugWord>::const_iterator debug_it = (*rosControlData).getROSDebugs().begin();
            debug_it != (*rosControlData).getROSDebugs().end();
            debug_it++) {                                                                    // Loop over ROS debug words
         if ((*debug_it).debugType() == 0 && (*debug_it).debugMessage() != header.bxID()) {  // check the BX
           int ros = (*rosControlData).getROSID();
           // fill the error bin
           hROSStatus->Fill(11, ros - 1);
           // error code 2
           hFEDFatal->Fill(code.getDDUID());
           hCorruptionSummary->Fill(code.getDDUID(), 2);
         }
       }
     }
   }
 
   // check the BX ID against other FEDs
   fedBXIds.insert(header.bxID());
   if (fedBXIds.size() != 1) {
     LogWarning("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
         << "ERROR: FED " << ddu << " BX ID different from other feds: " << header.bxID() << endl;
     // error code 3
     hFEDFatal->Fill(code.getDDUID());
     hCorruptionSummary->Fill(code.getDDUID(), 3);
   }
 
   // check the L1A ID against the ROSs
   set<int> rosL1AIds = rosL1AIdsPerFED[ddu];
   if ((rosL1AIds.size() > 1 || rosL1AIds.find(header.lvl1ID() - 1) == rosL1AIds.end()) &&
       !rosL1AIds.empty()) {  // in this case look for faulty ROSs
     //If L1A_ID error identify which ROS has wrong L1A
     for (vector<DTROS25Data>::const_iterator rosControlData = rosData.begin(); rosControlData != rosData.end();
          rosControlData++) {  // loop over the ROS data
       unsigned int ROSHeader_TTCCount =
           ((*rosControlData).getROSHeader().TTCEventCounter() + 1) %
           0x1000000;  // fix comparison in case of last counting bin in ROS /first one in DDU
       if (ROSHeader_TTCCount != header.lvl1ID()) {
         int ros = (*rosControlData).getROSID();
         hROSStatus->Fill(10, ros - 1);
         // error code 4
         hFEDFatal->Fill(code.getDDUID());
         hCorruptionSummary->Fill(code.getDDUID(), 4);
       }
     }
   }
 
   //1D HISTOS: EVENT LENGHT from trailer
   int fedEvtLength = trailer.fragmentLength() * 8;
   //   if(fedEvtLength > 16000) fedEvtLength = 16000; // overflow bin
   fedHistos["EventLength"][code.getDDUID()]->Fill(fedEvtLength);
 }

◆ processROS25()

void DTDataIntegrityROSOffline::processROS25	(	DTROS25Data &	data,
		int	dduID,
		int	ros
	)

Definition at line 309 of file DTDataIntegrityROSOffline.cc.

References DTROBHeaderWord::bunchID(), channelsInCEROS(), channelsInROS(), data, eventErrorFlag, dqm::impl::MonitorElement::Fill(), DTROChainCoding::getDDUID(), DTROChainCoding::getROB(), DTROChainCoding::getROS(), DTROChainCoding::getROSID(), LogTrace, neventsROS, DTTDCMeasurementWord::PC(), DTROBHeaderWord::robID(), rosBxIdsPerFED, rosHistos, rosL1AIdsPerFED, DTROChainCoding::setDDU(), DTROChainCoding::setROB(), DTROChainCoding::setROS(), and summaryHistos.

Referenced by analyze().

                                                                                 {
   neventsROS++;
 
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline]: " << neventsROS << " events analyzed by processROS25" << endl;
 
   // The ID of the RO board (used to map the histos)
   DTROChainCoding code;
   code.setDDU(ddu);
   code.setROS(ros);
 
   MonitorElement* ROSSummary = summaryHistos["ROSSummary"][code.getDDUID()];
 
   // Summary of all ROB errors
   MonitorElement* ROSError = nullptr;
   ROSError = rosHistos["ROSError"][code.getROSID()];
 
   if ((!ROSError)) {
     LogError("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
         << "Trying to access non existing ME at ROSID " << code.getROSID() << std::endl;
     return;
   }
 
   // L1A ids to be checked against FED one
   rosL1AIdsPerFED[ddu].insert(data.getROSHeader().TTCEventCounter());
 
   // ROS errors
 
   // check for TPX errors
   if (data.getROSTrailer().TPX() != 0) {
     LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
         << " TXP error en ROS " << code.getROS() << endl;
     ROSSummary->Fill(9, code.getROS());
   }
 
   // L1 Buffer almost full (non-critical error!)
   if (data.getROSTrailer().l1AFifoOccupancy() > 31) {
     ROSSummary->Fill(10, code.getROS());
   }
 
   for (vector<DTROSErrorWord>::const_iterator error_it = data.getROSErrors().begin();
        error_it != data.getROSErrors().end();
        error_it++) {  // Loop over ROS error words
 
     LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
         << " Error in ROS " << code.getROS() << " ROB Id " << (*error_it).robID() << " Error type "
         << (*error_it).errorType() << endl;
 
     // Fill the ROSSummary (1 per FED) histo
     ROSSummary->Fill((*error_it).errorType(), code.getROS());
     if ((*error_it).errorType() <= 11) {  // set error flag
       eventErrorFlag = true;
     }
 
     // Fill the ROB Summary (1 per ROS) histo
     if ((*error_it).robID() != 31) {
       ROSError->Fill((*error_it).errorType(), (*error_it).robID());
     } else if ((*error_it).errorType() == 4) {
       vector<int> channelBins;
       channelsInROS((*error_it).cerosID(), channelBins);
       vector<int>::const_iterator channelIt = channelBins.begin();
       vector<int>::const_iterator channelEnd = channelBins.end();
       for (; channelIt != channelEnd; ++channelIt) {
         ROSError->Fill(4, (*channelIt));
       }
     }
   }
 
   int ROSDebug_BunchNumber = -1;
 
   for (vector<DTROSDebugWord>::const_iterator debug_it = data.getROSDebugs().begin();
        debug_it != data.getROSDebugs().end();
        debug_it++) {  // Loop over ROS debug words
 
     int debugROSSummary = 0;
     int debugROSError = 0;
     vector<int> debugBins;
     bool hasEvIdMis = false;
     vector<int> evIdMisBins;
 
     if ((*debug_it).debugType() == 0) {
       ROSDebug_BunchNumber = (*debug_it).debugMessage();
     } else if ((*debug_it).debugType() == 1) {
       // not used
       // ROSDebug_BcntResCntLow = (*debug_it).debugMessage();
     } else if ((*debug_it).debugType() == 2) {
       // not used
       // ROSDebug_BcntResCntHigh = (*debug_it).debugMessage();
     } else if ((*debug_it).debugType() == 3) {
       if ((*debug_it).dontRead()) {
         debugROSSummary = 11;
         debugROSError = 8;
         channelsInCEROS((*debug_it).cerosIdCerosStatus(), (*debug_it).dontRead(), debugBins);
       }
       if ((*debug_it).evIdMis()) {
         hasEvIdMis = true;
         channelsInCEROS((*debug_it).cerosIdCerosStatus(), (*debug_it).evIdMis(), evIdMisBins);
       }
     } else if ((*debug_it).debugType() == 4 && (*debug_it).cerosIdRosStatus()) {
       debugROSSummary = 13;
       debugROSError = 10;
       channelsInROS((*debug_it).cerosIdRosStatus(), debugBins);
     }
 
     if (debugROSSummary) {
       ROSSummary->Fill(debugROSSummary, code.getROS());
       vector<int>::const_iterator channelIt = debugBins.begin();
       vector<int>::const_iterator channelEnd = debugBins.end();
       for (; channelIt != channelEnd; ++channelIt) {
         ROSError->Fill(debugROSError, (*channelIt));
       }
     }
 
     if (hasEvIdMis) {
       ROSSummary->Fill(12, code.getROS());
       vector<int>::const_iterator channelIt = evIdMisBins.begin();
       vector<int>::const_iterator channelEnd = evIdMisBins.end();
       for (; channelIt != channelEnd; ++channelIt) {
         ROSError->Fill(9, (*channelIt));
       }
     }
   }
 
   // ROB Group Header
   // Check the BX of the ROB headers against the BX of the ROS
   for (vector<DTROBHeader>::const_iterator rob_it = data.getROBHeaders().begin(); rob_it != data.getROBHeaders().end();
        rob_it++) {  // loop over ROB headers
 
     code.setROB((*rob_it).first);
     DTROBHeaderWord robheader = (*rob_it).second;
 
     rosBxIdsPerFED[ddu].insert(ROSDebug_BunchNumber);
 
     if (robheader.bunchID() != ROSDebug_BunchNumber) {
       // fill ROS Summary plot
       ROSSummary->Fill(8, code.getROS());
       eventErrorFlag = true;
 
       // fill ROB Summary plot for that particular ROS
       ROSError->Fill(7, robheader.robID());
     }
   }
 
   // TDC Data
   for (vector<DTTDCData>::const_iterator tdc_it = data.getTDCData().begin(); tdc_it != data.getTDCData().end();
        tdc_it++) {  // loop over TDC data
 
     DTTDCMeasurementWord tdcDatum = (*tdc_it).second;
 
     if (tdcDatum.PC() != 0) {
       LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " PC error in ROS " << code.getROS() << " TDC " << (*tdc_it).first << endl;
       //     fill ROS Summary plot
       ROSSummary->Fill(7, code.getROS());
 
       eventErrorFlag = true;
 
       // fill ROB Summary plot for that particular ROS
       ROSError->Fill(6, (*tdc_it).first);
     }
   }
 
   // TDC Error
   for (vector<DTTDCError>::const_iterator tdc_it = data.getTDCError().begin(); tdc_it != data.getTDCError().end();
        tdc_it++) {  // loop over TDC errors
 
     code.setROB((*tdc_it).first);
 
     int tdcError_ROSSummary = 0;
     int tdcError_ROSError = 0;
 
     if (((*tdc_it).second).tdcError() & 0x4000) {
       LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " ROS " << code.getROS() << " ROB " << code.getROB() << " Internal fatal Error 4000 in TDC "
           << (*tdc_it).first << endl;
 
       tdcError_ROSSummary = 14;
       tdcError_ROSError = 11;
 
     } else if (((*tdc_it).second).tdcError() & 0x0249) {
       LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " ROS " << code.getROS() << " ROB " << code.getROB() << " TDC FIFO overflow in TDC " << (*tdc_it).first
           << endl;
 
       tdcError_ROSSummary = 15;
       tdcError_ROSError = 12;
 
     } else if (((*tdc_it).second).tdcError() & 0x0492) {
       LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " ROS " << code.getROS() << " ROB " << code.getROB() << " TDC L1 buffer overflow in TDC "
           << (*tdc_it).first << endl;
 
       tdcError_ROSSummary = 16;
       tdcError_ROSError = 13;
 
     } else if (((*tdc_it).second).tdcError() & 0x2000) {
       LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " ROS " << code.getROS() << " ROB " << code.getROB() << " TDC L1A FIFO overflow in TDC " << (*tdc_it).first
           << endl;
 
       tdcError_ROSSummary = 17;
       tdcError_ROSError = 14;
 
     } else if (((*tdc_it).second).tdcError() & 0x0924) {
       LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " ROS " << code.getROS() << " ROB " << code.getROB() << " TDC hit error in TDC " << (*tdc_it).first
           << endl;
 
       tdcError_ROSSummary = 18;
       tdcError_ROSError = 15;
 
     } else if (((*tdc_it).second).tdcError() & 0x1000) {
       LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " ROS " << code.getROS() << " ROB " << code.getROB() << " TDC hit rejected in TDC " << (*tdc_it).first
           << endl;
 
       tdcError_ROSSummary = 19;
       tdcError_ROSError = 16;
 
     } else {
       LogWarning("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
           << " TDC error code not known " << ((*tdc_it).second).tdcError() << endl;
     }
 
     ROSSummary->Fill(tdcError_ROSSummary, code.getROS());
 
     if (tdcError_ROSSummary <= 15) {
       eventErrorFlag = true;
     }
 
     ROSError->Fill(tdcError_ROSError, (*tdc_it).first);
   }
 }

◆ topFolder()

std::string DTDataIntegrityROSOffline::topFolder ( bool isFEDIntegrity ) const

private

Definition at line 687 of file DTDataIntegrityROSOffline.cc.

References printsummarytable::folder.

Referenced by bookHistos().

                                                                         {
   string folder = "DT/00-DataIntegrity/";
 
   return folder;
 }

Member Data Documentation

◆ dduToken

edm::EDGetTokenT<DTDDUCollection> DTDataIntegrityROSOffline::dduToken

private

Definition at line 107 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), and DTDataIntegrityROSOffline().

◆ eventErrorFlag

bool DTDataIntegrityROSOffline::eventErrorFlag

private

Definition at line 98 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), and processROS25().

◆ fedBXIds

std::set<int> DTDataIntegrityROSOffline::fedBXIds

private

Definition at line 101 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), and processFED().

◆ fedHistos

std::map<std::string, std::map<int, MonitorElement*> > DTDataIntegrityROSOffline::fedHistos

private

Definition at line 72 of file DTDataIntegrityROSOffline.h.

Referenced by processFED().

◆ FEDIDmax

int DTDataIntegrityROSOffline::FEDIDmax

private

Definition at line 94 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), bookHistograms(), DTDataIntegrityROSOffline(), and processFED().

◆ FEDIDmin

int DTDataIntegrityROSOffline::FEDIDmin

private

Definition at line 93 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), bookHistograms(), DTDataIntegrityROSOffline(), and processFED().

◆ fedIntegrityFolder

std::string DTDataIntegrityROSOffline::fedIntegrityFolder

private

Definition at line 104 of file DTDataIntegrityROSOffline.h.

Referenced by DTDataIntegrityROSOffline().

◆ getSCInfo

bool DTDataIntegrityROSOffline::getSCInfo

private

Definition at line 65 of file DTDataIntegrityROSOffline.h.

Referenced by DTDataIntegrityROSOffline().

◆ hCorruptionSummary

MonitorElement* DTDataIntegrityROSOffline::hCorruptionSummary

private

Definition at line 82 of file DTDataIntegrityROSOffline.h.

Referenced by bookHistos(), and processFED().

◆ hFEDEntry

MonitorElement* DTDataIntegrityROSOffline::hFEDEntry

private

Definition at line 79 of file DTDataIntegrityROSOffline.h.

Referenced by bookHistos(), fedEntry(), and processFED().

◆ hFEDFatal

MonitorElement* DTDataIntegrityROSOffline::hFEDFatal

private

Definition at line 80 of file DTDataIntegrityROSOffline.h.

Referenced by bookHistos(), fedFatal(), and processFED().

◆ hFEDNonFatal

MonitorElement* DTDataIntegrityROSOffline::hFEDNonFatal

private

Definition at line 81 of file DTDataIntegrityROSOffline.h.

Referenced by bookHistos(), and fedNonFatal().

◆ hTTSSummary

MonitorElement* DTDataIntegrityROSOffline::hTTSSummary

private

Definition at line 85 of file DTDataIntegrityROSOffline.h.

Referenced by bookHistos().

◆ nEventMonitor

MonitorElement* DTDataIntegrityROSOffline::nEventMonitor

private

Definition at line 70 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), and bookHistos().

◆ nevents

int DTDataIntegrityROSOffline::nevents

private

Definition at line 67 of file DTDataIntegrityROSOffline.h.

Referenced by analyze().

◆ neventsFED

int DTDataIntegrityROSOffline::neventsFED

private

Definition at line 87 of file DTDataIntegrityROSOffline.h.

Referenced by DTDataIntegrityROSOffline(), processFED(), and ~DTDataIntegrityROSOffline().

◆ neventsROS

int DTDataIntegrityROSOffline::neventsROS

private

Definition at line 88 of file DTDataIntegrityROSOffline.h.

Referenced by processROS25().

◆ nROS

const int DTDataIntegrityROSOffline::nROS = 12

private

Definition at line 91 of file DTDataIntegrityROSOffline.h.

Referenced by bookHistograms().

◆ ros25Token

edm::EDGetTokenT<DTROS25Collection> DTDataIntegrityROSOffline::ros25Token

private

Definition at line 109 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), and DTDataIntegrityROSOffline().

◆ rosBxIdsPerFED

std::map<int, std::set<int> > DTDataIntegrityROSOffline::rosBxIdsPerFED

private

Definition at line 100 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), processFED(), and processROS25().

◆ rosHistos

std::map<std::string, std::map<int, MonitorElement*> > DTDataIntegrityROSOffline::rosHistos

private

Definition at line 76 of file DTDataIntegrityROSOffline.h.

Referenced by processROS25().

◆ rosL1AIdsPerFED

std::map<int, std::set<int> > DTDataIntegrityROSOffline::rosL1AIdsPerFED

private

Definition at line 102 of file DTDataIntegrityROSOffline.h.

Referenced by analyze(), processFED(), and processROS25().

◆ summaryHistos

std::map<std::string, std::map<int, MonitorElement*> > DTDataIntegrityROSOffline::summaryHistos

private

Definition at line 74 of file DTDataIntegrityROSOffline.h.

Referenced by processROS25().

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DTDataIntegrityROSOffline()

◆ ~DTDataIntegrityROSOffline()

Member Function Documentation

◆ analyze()

◆ bookHistograms()

◆ bookHistos() [1/2]

◆ bookHistos() [2/2]

◆ bookHistosROS25()

◆ channelsInCEROS()

◆ channelsInROS()

◆ fedEntry()

◆ fedFatal()

◆ fedNonFatal()

◆ processFED()

◆ processROS25()

◆ topFolder()

Member Data Documentation

◆ dduToken

◆ eventErrorFlag

◆ fedBXIds

◆ fedHistos

◆ FEDIDmax

◆ FEDIDmin

◆ fedIntegrityFolder

◆ getSCInfo

◆ hCorruptionSummary

◆ hFEDEntry

◆ hFEDFatal

◆ hFEDNonFatal

◆ hTTSSummary

◆ nEventMonitor

◆ nevents

◆ neventsFED

◆ neventsROS

◆ nROS

◆ ros25Token

◆ rosBxIdsPerFED

◆ rosHistos

◆ rosL1AIdsPerFED

◆ summaryHistos