#include <ESFEDIntegrityTask.h>

Inheritance diagram for ESFEDIntegrityTask:

Public Member Functions
	ESFEDIntegrityTask (const edm::ParameterSet &ps)

virtual	~ESFEDIntegrityTask ()

Public Member Functions inherited from DQMEDAnalyzer
virtual void	beginRun (edm::Run const &, edm::EventSetup const &) final

virtual void	beginStream (edm::StreamID id) final

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

	DQMEDAnalyzer (void)

virtual void	endLuminosityBlockSummary (edm::LuminosityBlock const &, edm::EventSetup const &, dqmDetails::NoCache *) const final

virtual void	endRunSummary (edm::Run const &, edm::EventSetup const &, dqmDetails::NoCache *) const final

uint32_t	streamId () const

Public Member Functions inherited from edm::stream::EDAnalyzer< edm::RunSummaryCache< dqmDetails::NoCache >, edm::LuminosityBlockSummaryCache< dqmDetails::NoCache > >
	EDAnalyzer ()=default

Public Member Functions inherited from edm::stream::EDAnalyzerBase
	EDAnalyzerBase ()

ModuleDescription const &	moduleDescription () const

virtual	~EDAnalyzerBase ()

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

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

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

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

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

Protected Member Functions
void	analyze (const edm::Event &e, const edm::EventSetup &c) override
	Analyze. More...

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

void	endJob ()

Protected Member Functions inherited from edm::stream::EDAnalyzerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

EDGetToken	consumes (const TypeToGet &id, 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 ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

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

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

Private Attributes
edm::EDGetTokenT < ESRawDataCollection >	dccCollections_

bool	debug_

std::string	fedDirName_

edm::EDGetTokenT < FEDRawDataCollection >	FEDRawDataCollection_

int	ievt_

MonitorElement *	meESFedsEntries_

MonitorElement *	meESFedsFatal_

MonitorElement *	meESFedsNonFatal_

std::string	prefixME_

Additional Inherited Members
Public Types inherited from edm::stream::EDAnalyzer< edm::RunSummaryCache< dqmDetails::NoCache >, edm::LuminosityBlockSummaryCache< dqmDetails::NoCache > >
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

Public Types inherited from edm::stream::EDAnalyzerBase
typedef EDAnalyzerAdaptorBase	ModuleType

Static Public Member Functions inherited from DQMEDAnalyzer
static std::shared_ptr < dqmDetails::NoCache >	globalBeginLuminosityBlockSummary (edm::LuminosityBlock const &, edm::EventSetup const &, LuminosityBlockContext const *)

static std::shared_ptr < dqmDetails::NoCache >	globalBeginRunSummary (edm::Run const &, edm::EventSetup const &, RunContext const *)

static void	globalEndLuminosityBlockSummary (edm::LuminosityBlock const &, edm::EventSetup const &, LuminosityBlockContext const , dqmDetails::NoCache )

static void	globalEndRunSummary (edm::Run const &, edm::EventSetup const &, RunContext const , dqmDetails::NoCache )

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Detailed Description

Definition at line 15 of file ESFEDIntegrityTask.h.

Constructor & Destructor Documentation

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

Definition at line 26 of file ESFEDIntegrityTask.cc.

References edm::ParameterSet::getParameter(), and edm::ParameterSet::getUntrackedParameter().

                                                              {
 
   prefixME_      = ps.getUntrackedParameter<string>("prefixME", "");
   fedDirName_    = ps.getUntrackedParameter<string>("FEDDirName", "FEDIntegrity");
   debug_         = ps.getUntrackedParameter<bool>("debug", false);
 
   dccCollections_       = consumes<ESRawDataCollection>(ps.getParameter<InputTag>("ESDCCCollections"));
   FEDRawDataCollection_ = consumes<FEDRawDataCollection>(ps.getParameter<edm::InputTag>("FEDRawDataCollection"));
 
   meESFedsEntries_  = 0;
   meESFedsFatal_    = 0;
   meESFedsNonFatal_ = 0;
 
   ievt_ = 0;
   
 }

virtual ESFEDIntegrityTask::~ESFEDIntegrityTask ( )

inlinevirtual

Definition at line 20 of file ESFEDIntegrityTask.h.

20 {}

Member Function Documentation

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

overrideprotectedvirtual

Analyze.

Implements edm::stream::EDAnalyzerBase.

Definition at line 66 of file ESFEDIntegrityTask.cc.

References gather_cfg::cout, FEDRawData::data(), ESDCCHeaderBlock::fedId(), ESDCCHeaderBlock::getBX(), edm::Event::getByToken(), ESDCCHeaderBlock::getDCCErrors(), ESDCCHeaderBlock::getFEChannelStatus(), ESDCCHeaderBlock::getLV1(), ESDCCHeaderBlock::getOptoRX0(), ESDCCHeaderBlock::getOptoRX1(), ESDCCHeaderBlock::getOptoRX2(), ESDCCHeaderBlock::getOrbitNumber(), i, FEDHeader::lvl1ID(), and FEDRawData::size().

                                                                    {
 
   ievt_++;
 
   int gt_L1A = 0; 
   // int gt_OrbitNumber = 0, gt_BX = 0;
   int esDCC_L1A_MostFreqCounts = 0;
   int esDCC_BX_MostFreqCounts = 0;
   int esDCC_OrbitNumber_MostFreqCounts = 0;
   int gtFedDataSize = 0;
 
   Handle<ESRawDataCollection> dccs;
   Handle<FEDRawDataCollection> allFedRawData;
 
   if ( e.getByToken(FEDRawDataCollection_, allFedRawData) ) {
 
     // ES FEDs
     for (int esFED=520; esFED<=575; ++esFED) { 
 
       const FEDRawData& fedData = allFedRawData->FEDData(esFED);
       int length = fedData.size()/sizeof(uint64_t);
       
       if ( length > 0 ) 
     if ( meESFedsEntries_ ) meESFedsEntries_->Fill(esFED);
     }
 
     // GT FED data
     const FEDRawData& gtFedData = allFedRawData->FEDData(812);
      
     gtFedDataSize = gtFedData.size()/sizeof(uint64_t);
      
     if ( gtFedDataSize > 0 ) {
        
       FEDHeader header(gtFedData.data());
        
       gt_L1A         = header.lvl1ID();
       //gt_OrbitNumber = e.orbitNumber();
       //gt_BX          = e.bunchCrossing();
     } else {
 
       map<int, int> esDCC_L1A_FreqMap;
       map<int, int> esDCC_BX_FreqMap;
       map<int, int> esDCC_OrbitNumber_FreqMap;
 
       if ( e.getByToken(dccCollections_, dccs) ) {
     
     for (ESRawDataCollection::const_iterator dccItr = dccs->begin(); dccItr != dccs->end(); ++dccItr) {
       ESDCCHeaderBlock esdcc = (*dccItr);
       
       esDCC_L1A_FreqMap[esdcc.getLV1()]++;
       esDCC_BX_FreqMap[esdcc.getBX()]++;
       esDCC_OrbitNumber_FreqMap[esdcc.getOrbitNumber()]++;
       
       if (esDCC_L1A_FreqMap[esdcc.getLV1()] > esDCC_L1A_MostFreqCounts) {
         esDCC_L1A_MostFreqCounts = esDCC_L1A_FreqMap[esdcc.getLV1()];
         gt_L1A = esdcc.getLV1();
       } 
       
       if (esDCC_BX_FreqMap[esdcc.getBX()] > esDCC_BX_MostFreqCounts) {
         esDCC_BX_MostFreqCounts = esDCC_BX_FreqMap[esdcc.getBX()];
         //gt_BX = esdcc.getBX();
       } 
       
       if (esDCC_OrbitNumber_FreqMap[esdcc.getOrbitNumber()] > esDCC_OrbitNumber_MostFreqCounts) {
         esDCC_OrbitNumber_MostFreqCounts = esDCC_OrbitNumber_FreqMap[esdcc.getOrbitNumber()];
         //gt_OrbitNumber = esdcc.getOrbitNumber();
       } 
       
     }
       } else {
     LogWarning("ESFEDIntegrityTask") << "dccCollections not available";
       }
 
     }
 
   } else {
     LogWarning("ESFEDIntegrityTask") << "FEDRawDataCollection not available";
   }
 
   vector<int> fiberStatus;
   if ( e.getByToken(dccCollections_, dccs) ) {
     for (ESRawDataCollection::const_iterator dccItr = dccs->begin(); dccItr != dccs->end(); ++dccItr) {
       ESDCCHeaderBlock dcc = (*dccItr);
       
       if (dcc.getDCCErrors() > 0) {
     
     if ( meESFedsFatal_ ) meESFedsFatal_->Fill(dcc.fedId());
     
       } else {
     if (debug_) cout<<dcc.fedId()<<" "<<dcc.getOptoRX0()<<" "<<dcc.getOptoRX1()<<" "<<dcc.getOptoRX2()<<endl;
     fiberStatus = dcc.getFEChannelStatus();
     
     if (dcc.getOptoRX0() == 128) {
       meESFedsNonFatal_->Fill(dcc.fedId(), 1./3.);
     } else if (dcc.getOptoRX0() == 129) {
       for (unsigned int i=0; i<12; ++i) {
         if (fiberStatus[i]==8 || fiberStatus[i]==10 || fiberStatus[i]==11 || fiberStatus[i]==12)
           if ( meESFedsNonFatal_ ) meESFedsNonFatal_->Fill(dcc.fedId(), 1./12.);
       }
     }
     if (dcc.getOptoRX1() == 128) { 
       meESFedsNonFatal_->Fill(dcc.fedId(), 1./3.);
     }   else if (dcc.getOptoRX1() == 129) {
       for (unsigned int i=12; i<24; ++i) {
         if (fiberStatus[i]==8 || fiberStatus[i]==10 || fiberStatus[i]==11 || fiberStatus[i]==12)
           if ( meESFedsNonFatal_ ) meESFedsNonFatal_->Fill(dcc.fedId(), 1./12.);
       }
     }
     if (dcc.getOptoRX2() == 128) {
       meESFedsNonFatal_->Fill(dcc.fedId(), 1./3.);
     } else if (dcc.getOptoRX2() == 129){
       for (unsigned int i=24; i<36; ++i) {
         if (fiberStatus[i]==8 || fiberStatus[i]==10 || fiberStatus[i]==11 || fiberStatus[i]==12)
           if ( meESFedsNonFatal_ ) meESFedsNonFatal_->Fill(dcc.fedId(), 1./12.);
       }
     }
       }
       
       if (dcc.getLV1() != gt_L1A) meESFedsNonFatal_->Fill(dcc.fedId());
       //if (dcc.getBX() != gt_BX) meESFedsNonFatal_->Fill(dcc.fedId());
       //if (dcc.getOrbitNumber() != gt_OrbitNumber) meESFedsNonFatal_->Fill(dcc.fedId());
     }
   }
 
   //for (ESLocalRawDataCollection::const_iterator kItr = kchips->begin(); kItr != kchips->end(); ++kItr) {
 
   //ESKCHIPBlock kchip = (*kItr);
 
   //Int_t nErr = 0;
   //if (kchip.getFlag1() > 0) nErr++; 
   //if (kchip.getFlag2() > 0) nErr++;
   //if (kchip.getBC() != kchip.getOptoBC()) nErr++;
   //if (kchip.getEC() != kchip.getOptoEC()) nErr++;
   //if (nErr>0) meESFedsNonFatal_->Fill(dcc.fedId());
   //}
 
 }

void ESFEDIntegrityTask::bookHistograms	(	DQMStore::IBooker &	iBooker,
		edm::Run const &	,
		edm::EventSetup const &
	)

overrideprotectedvirtual

Implements DQMEDAnalyzer.

Definition at line 44 of file ESFEDIntegrityTask.cc.

References DQMStore::IBooker::book1D(), timingPdfMaker::histo, and DQMStore::IBooker::setCurrentFolder().

 {
   char histo[200];
 
   iBooker.setCurrentFolder(prefixME_ + "/" + fedDirName_);
 
   sprintf(histo, "FEDEntries");
   meESFedsEntries_ = iBooker.book1D(histo, histo, 56, 520, 576);
 
   sprintf(histo, "FEDFatal");
   meESFedsFatal_ = iBooker.book1D(histo, histo, 56, 520, 576);
 
   sprintf(histo, "FEDNonFatal");
   meESFedsNonFatal_ = iBooker.book1D(histo, histo, 56, 520, 576);
 }

void ESFEDIntegrityTask::endJob ( void )

protected

Definition at line 60 of file ESFEDIntegrityTask.cc.

                                    {
 
   LogInfo("ESFEDIntegrityTask") << "analyzed " << ievt_ << " events";
 
 }

Member Data Documentation

edm::EDGetTokenT<ESRawDataCollection> ESFEDIntegrityTask::dccCollections_

private

Definition at line 39 of file ESFEDIntegrityTask.h.

bool ESFEDIntegrityTask::debug_

private

Definition at line 37 of file ESFEDIntegrityTask.h.

std::string ESFEDIntegrityTask::fedDirName_

private

Definition at line 36 of file ESFEDIntegrityTask.h.

edm::EDGetTokenT<FEDRawDataCollection> ESFEDIntegrityTask::FEDRawDataCollection_

private

Definition at line 40 of file ESFEDIntegrityTask.h.

int ESFEDIntegrityTask::ievt_

private

Definition at line 33 of file ESFEDIntegrityTask.h.

MonitorElement* ESFEDIntegrityTask::meESFedsEntries_

private

Definition at line 42 of file ESFEDIntegrityTask.h.

MonitorElement* ESFEDIntegrityTask::meESFedsFatal_

private

Definition at line 43 of file ESFEDIntegrityTask.h.

MonitorElement* ESFEDIntegrityTask::meESFedsNonFatal_

private

Definition at line 44 of file ESFEDIntegrityTask.h.

std::string ESFEDIntegrityTask::prefixME_

private

Definition at line 35 of file ESFEDIntegrityTask.h.

Public Member Functions

Protected Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation