#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

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndRuns () const final

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 >
typedef CacheContexts< T... >	CacheTypes

typedef CacheTypes::GlobalCache	GlobalCache

typedef AbilityChecker< T... >	HasAbility

typedef CacheTypes::LuminosityBlockCache	LuminosityBlockCache

typedef LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >	LuminosityBlockContext

typedef CacheTypes::LuminosityBlockSummaryCache	LuminosityBlockSummaryCache

typedef CacheTypes::RunCache	RunCache

typedef RunContextT< RunCache, GlobalCache >	RunContext

typedef CacheTypes::RunSummaryCache	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.

                                                                               : nevents(0) {
   LogTrace("DTRawToDigi|DTDQM|DTMonitorModule|DTDataIntegrityROSOffline")
       << "[DTDataIntegrityROSOffline]: Constructor" << endl;
  
   dduToken = consumes<DTDDUCollection>(ps.getParameter<InputTag>("dtDDULabel"));
   ros25Token = consumes<DTROS25Collection>(ps.getParameter<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");
 }

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

◆ ~DTDataIntegrityROSOffline()

DTDataIntegrityROSOffline::~DTDataIntegrityROSOffline ( )

override

Definition at line 46 of file DTDataIntegrityROSOffline.cc.

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

References LogTrace, and neventsFED.

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.

                                                                                  {
   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);
       }
     }
   }
 }

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.

◆ 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.

                                                                             {
   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);
     }
   }
 }

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

◆ bookHistos() [1/2]

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

private

Definition at line 97 of file DTDataIntegrityROSOffline.cc.

                                                                                                        {
   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);
 }

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

◆ 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.

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

References bookHistos().

Referenced by bookHistograms().

◆ channelsInCEROS()

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

private

Definition at line 693 of file DTDataIntegrityROSOffline.cc.

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

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

Referenced by processROS25().

◆ channelsInROS()

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

private

Definition at line 702 of file DTDataIntegrityROSOffline.cc.

                                                                                   {
   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;
 }

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

Referenced by processROS25().

◆ fedEntry()

void DTDataIntegrityROSOffline::fedEntry ( int dduID )

Definition at line 679 of file DTDataIntegrityROSOffline.cc.

679 { hFEDEntry->Fill(dduID); }

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

◆ fedFatal()

void DTDataIntegrityROSOffline::fedFatal ( int dduID )

Definition at line 682 of file DTDataIntegrityROSOffline.cc.

682 { hFEDFatal->Fill(dduID); }

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

◆ fedNonFatal()

void DTDataIntegrityROSOffline::fedNonFatal ( int dduID )

Definition at line 685 of file DTDataIntegrityROSOffline.cc.

685 { hFEDNonFatal->Fill(dduID); }

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

◆ processFED()

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

Definition at line 543 of file DTDataIntegrityROSOffline.cc.

                                                                                                           {
   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);
 }

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

◆ processROS25()

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

Definition at line 309 of file DTDataIntegrityROSOffline.cc.

                                                                                 {
   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);
   }
 }

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

◆ topFolder()

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

private

Definition at line 687 of file DTDataIntegrityROSOffline.cc.

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

References printsummarytable::folder.

Referenced by bookHistos().

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