#include <CastorMonitorModule.h>

Inheritance diagram for CastorMonitorModule:

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

	~CastorMonitorModule () override

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

virtual void	analyze (edm::Event const &, edm::EventSetup const &)

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

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

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

	DQMEDAnalyzer ()

	DQMEDAnalyzer (DQMEDAnalyzer const &)=delete

	DQMEDAnalyzer (DQMEDAnalyzer &&)=delete

void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override

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

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

void	endRunProduce (edm::Run &run, edm::EventSetup const &setup) override

	~DQMEDAnalyzer () override=default

Public Member Functions inherited from edm::one::EDProducer< edm::Accumulator, edm::EndLuminosityBlockProducer, edm::EndRunProducer, edm::one::WatchLuminosityBlocks, edm::one::WatchRuns >
	EDProducer ()=default

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

bool	hasAbilityToProduceInLumis () const final

bool	hasAbilityToProduceInRuns () const final

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

Public Member Functions inherited from edm::one::EDProducerBase
	EDProducerBase ()

ModuleDescription const &	moduleDescription () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

	~EDProducerBase () 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

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)

	~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 const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

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 const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

virtual	~EDConsumerBase () noexcept(false)

Protected Member Functions
void	analyze (const edm::Event &iEvent, const edm::EventSetup &eventSetup) override

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

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

void	endRun (const edm::Run &run, const edm::EventSetup &eventSetup) override

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 Types
typedef std::vector< reco::BasicJet >	BasicJetCollection

typedef std::vector< reco::CastorTower >	CastorTowerCollection

Private Attributes
MonitorElement *	CastorEventProduct

edm::ESHandle< CastorDbService >	conditions_

edm::CPUTimer	cpu_timer

edm::ESHandle< CastorPedestals >	dbPedestals

CastorDigiMonitor *	DigiMon_

bool	digiOK_

int	fVerbosity

MonitorElement *	hunpkrep

int	ibunch_

int	ievent_

int	ievt_

int	ilumisec_

edm::EDGetTokenT< CastorTowerCollection >	inputTokenCastorTowers_

edm::EDGetTokenT< CastorDigiCollection >	inputTokenDigi_

edm::EDGetTokenT< FEDRawDataCollection >	inputTokenRaw_

edm::EDGetTokenT< CastorRecHitCollection >	inputTokenRecHitCASTOR_

edm::EDGetTokenT< HcalUnpackerReport >	inputTokenReport_

int	irun_

edm::EDGetTokenT< BasicJetCollection >	JetAlgorithm

CastorLEDMonitor *	LedMon_

int	NBunchesOrbit

bool	rawOK_

CastorRecHitMonitor *	RecHitMon_

bool	rechitOK_

bool	reportOK_

bool	showTiming_

std::string	subsystemname_

Additional Inherited Members
Public Types inherited from edm::one::EDProducerBase
typedef EDProducerBase	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::one::EDProducerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

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

edm::EDPutTokenT< DQMToken >	runToken_

Detailed Description

Definition at line 72 of file CastorMonitorModule.h.

Member Typedef Documentation

typedef std::vector<reco::BasicJet> CastorMonitorModule::BasicJetCollection

private

Definition at line 105 of file CastorMonitorModule.h.

typedef std::vector<reco::CastorTower> CastorMonitorModule::CastorTowerCollection

private

Definition at line 103 of file CastorMonitorModule.h.

Constructor & Destructor Documentation

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

Definition at line 25 of file CastorMonitorModule.cc.

References gather_cfg::cout, DigiMon_, fVerbosity, edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), ibunch_, ievent_, ievt_, ilumisec_, inputTokenCastorTowers_, inputTokenDigi_, inputTokenRaw_, inputTokenRecHitCASTOR_, inputTokenReport_, irun_, JetAlgorithm, LedMon_, NBunchesOrbit, RecHitMon_, showTiming_, AlCaHLTBitMon_QueryRunRegistry::string, and subsystemname_.

 {
   fVerbosity        = ps.getUntrackedParameter<int>("debug", 0);
   if(fVerbosity>0) std::cout<<"CastorMonitorModule Constructor(start)"<<std::endl;
  subsystemname_=ps.getUntrackedParameter<std::string>("subSystemFolder","Castor");
   inputTokenRaw_    = consumes<FEDRawDataCollection>(ps.getParameter<edm::InputTag>("rawLabel"));
   inputTokenReport_     = consumes<HcalUnpackerReport>(ps.getParameter<edm::InputTag>("unpackerReportLabel"));
  inputTokenDigi_    = consumes<CastorDigiCollection>(ps.getParameter<edm::InputTag>("digiLabel"));
  inputTokenRecHitCASTOR_ = consumes<CastorRecHitCollection>(ps.getParameter<edm::InputTag>("CastorRecHitLabel"));
  inputTokenCastorTowers_ = consumes<CastorTowerCollection>(ps.getParameter<edm::InputTag>("CastorTowerLabel")); 
  JetAlgorithm       = consumes<BasicJetCollection>(ps.getParameter<edm::InputTag>("CastorBasicJetsLabel"));
 
   NBunchesOrbit     = ps.getUntrackedParameter<int>("nBunchesOrbit",3563);
   showTiming_       = ps.getUntrackedParameter<bool>("showTiming",false);
 
   irun_= ilumisec_=  ievent_ = ibunch_=0;
 
   DigiMon_ = nullptr; 
   RecHitMon_ = nullptr;
   LedMon_ = nullptr;
  
   if ( ps.getUntrackedParameter<bool>("DigiMonitor", false) )
     DigiMon_ = new CastorDigiMonitor(ps);
 
   if ( ps.getUntrackedParameter<bool>("RecHitMonitor", false) )
     RecHitMon_ = new CastorRecHitMonitor(ps);
 
   if ( ps.getUntrackedParameter<bool>("LEDMonitor", false) ) 
     LedMon_ = new CastorLEDMonitor(ps);
   
   ievt_ = 0;
   
   if(fVerbosity>0) std::cout<<"CastorMonitorModule Constructor(end)"<< std::endl;
 }

CastorMonitorModule::~CastorMonitorModule ( )

override

Definition at line 60 of file CastorMonitorModule.cc.

References DigiMon_, LedMon_, and RecHitMon_.

                                           { 
   if (DigiMon_ != nullptr)  delete DigiMon_;
   if (RecHitMon_ != nullptr) delete RecHitMon_; 
   if (LedMon_ != nullptr) delete LedMon_;
 }

Member Function Documentation

void CastorMonitorModule::analyze	(	const edm::Event &	iEvent,
		const edm::EventSetup &	eventSetup
	)

overrideprotected

Definition at line 117 of file CastorMonitorModule.cc.

References HcalUnpackerReport::badQualityDigis(), edm::EventBase::bunchCrossing(), HcalUnpackerReport::busySpigots(), CastorEventProduct, conditions_, gather_cfg::cout, cpu_timer, edm::CPUTimer::cpuTime(), DEFINE_FWK_MODULE, DigiMon_, digiOK_, HcalUnpackerReport::emptyEventSpigots(), edm::EventID::event(), MonitorElement::Fill(), objects.autophobj::float, fVerbosity, edm::Event::getByToken(), hunpkrep, ibunch_, edm::EventBase::id(), ievent_, ievt_, ilumisec_, inputTokenCastorTowers_, inputTokenDigi_, inputTokenRaw_, inputTokenRecHitCASTOR_, inputTokenReport_, irun_, edm::HandleBase::isValid(), JetAlgorithm, fwrapper::jets, LedMon_, edm::EventBase::luminosityBlock(), NBunchesOrbit, ecaldqm::nTowers, HcalUnpackerReport::OFWSpigots(), CastorDigiMonitor::processEvent(), CastorRecHitMonitor::processEvent(), CastorLEDMonitor::processEvent(), CastorRecHitMonitor::processEventJets(), CastorRecHitMonitor::processEventTowers(), rawOK_, RecHitMon_, rechitOK_, edmIntegrityCheck::report, edm::CPUTimer::reset(), edm::EventID::run(), showTiming_, edm::SortedCollection< T, SORT >::size(), HcalUnpackerReport::spigotFormatErrors(), edm::CPUTimer::start(), and edm::CPUTimer::stop().

 {
   if (fVerbosity>0)  std::cout <<"CastorMonitorModule::analyze (start)"<<std::endl;
 
   using namespace edm;
 
   irun_     = iEvent.id().run();
   ilumisec_ = iEvent.luminosityBlock();
   ievent_   = iEvent.id().event();
   ibunch_   = iEvent.bunchCrossing() % NBunchesOrbit;
 
   if (fVerbosity>1) { 
  std::cout <<"CastorMonitorModule: run="<<irun_<<" LS:"<<ilumisec_
   <<" evt="<<ievent_<<"\t total count = "<<ievt_<<std::endl; 
   }
 
   ievt_++;
 
   bool rawOK_    = true;
   bool digiOK_   = true;
   bool rechitOK_ = true, towerOK_ = true, jetsOK_ = true;
   int nDigi = 0, nrecHits = 0, nTowers = 0, nJets=0;
 
   edm::Handle<FEDRawDataCollection> RawData;  
   iEvent.getByToken(inputTokenRaw_,RawData);
   if (!RawData.isValid()) rawOK_=false;
 
   float fedsUnpacked=0.;  
   edm::Handle<HcalUnpackerReport> report; 
   iEvent.getByToken(inputTokenReport_,report);  
   if (!report.isValid()) rawOK_=false;
   else 
   {
     const std::vector<int> feds =  (*report).getFedsUnpacked();    
     fedsUnpacked = float(feds.size());
     hunpkrep->Fill(0,fedsUnpacked);
     hunpkrep->Fill(1,report->spigotFormatErrors());
     hunpkrep->Fill(2,report->emptyEventSpigots());
     hunpkrep->Fill(3,report->busySpigots());
     hunpkrep->Fill(4,report->OFWSpigots());
     hunpkrep->Fill(5,report->badQualityDigis());
   }
   
   edm::Handle<CastorDigiCollection> CastorDigi;
   iEvent.getByToken(inputTokenDigi_,CastorDigi);
   if (CastorDigi.isValid()) nDigi = CastorDigi->size();
   else digiOK_=false;
   
   edm::Handle<CastorRecHitCollection> CastorHits;
   iEvent.getByToken(inputTokenRecHitCASTOR_,CastorHits);
   if (CastorHits.isValid()) nrecHits=CastorHits->size();
   else rechitOK_ = false;
 
   edm::Handle<reco::CastorTowerCollection> castorTowers;
   iEvent.getByToken(inputTokenCastorTowers_,castorTowers);
   if (castorTowers.isValid()) nTowers = castorTowers->size(); 
   else towerOK_ = false;
 
   edm::Handle<reco::BasicJetCollection> jets;
   iEvent.getByToken(JetAlgorithm,jets);
   if(jets.isValid()) nJets = jets->size();
   else jetsOK_ = false;
 
  if(fVerbosity>0)
    std::cout<<"CastorProductValid(size): RawDataValid="<<RawData.isValid()
    <<" Digi="<<digiOK_ << "(" <<nDigi<<") Hits="<<rechitOK_<< "("<<nrecHits << ")" 
    <<" Towers="<<towerOK_<< "(" << nTowers << ")"
    <<" Jets="<<jetsOK_<< "(" << nJets << ")" <<std::endl;
 
  CastorEventProduct->Fill(0,fedsUnpacked/3.);
  CastorEventProduct->Fill(1,rawOK_);
  CastorEventProduct->Fill(2,digiOK_);
  CastorEventProduct->Fill(3,rechitOK_);
  CastorEventProduct->Fill(4,towerOK_);
  CastorEventProduct->Fill(5,jetsOK_);
 
   if(digiOK_) DigiMon_->processEvent(*CastorDigi,*conditions_);
   if (showTiming_){
    cpu_timer.stop();
    if (DigiMon_!=nullptr) std::cout <<"TIMER:: DIGI MONITOR ->"<<cpu_timer.cpuTime()<<std::endl;
    cpu_timer.reset(); cpu_timer.start();
   }
 
  if(rechitOK_)  RecHitMon_->processEvent(*CastorHits);
  if(showTiming_){
   cpu_timer.stop();
   if (RecHitMon_!=nullptr) std::cout<<"TIMER:: RECHIT MONITOR->"<<cpu_timer.cpuTime()<<std::endl;
   cpu_timer.reset(); cpu_timer.start();
  }
 
  if(digiOK_) LedMon_->processEvent(*CastorDigi,*conditions_);
  if (showTiming_){
    cpu_timer.stop();
    if(LedMon_!=nullptr) std::cout <<"TIMER:: LED MONITOR ->"<<cpu_timer.cpuTime()<<std::endl;
    cpu_timer.reset(); cpu_timer.start();
  }
 
  if(towerOK_)   RecHitMon_->processEventTowers(*castorTowers);
  if(jetsOK_)    RecHitMon_->processEventJets(*jets);
 
  if(fVerbosity>1 && ievt_%100 == 0)
     std::cout << "CastorMonitorModule: processed "<<ievt_<<" events"<<std::endl;
  if (fVerbosity>0)  std::cout <<"CastorMonitorModule::analyze (end)"<<std::endl;
  return;
 }

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

overrideprotectedvirtual

Implements DQMEDAnalyzer.

Definition at line 77 of file CastorMonitorModule.cc.

References DQMStore::IBooker::book1D(), CastorDigiMonitor::bookHistograms(), CastorRecHitMonitor::bookHistograms(), CastorLEDMonitor::bookHistograms(), DQMStore::IBooker::bookProfile(), CastorEventProduct, gather_cfg::cout, DigiMon_, fVerbosity, MonitorElement::getTH1F(), MonitorElement::getTProfile(), hunpkrep, LedMon_, RecHitMon_, alignCSCRings::s, DQMStore::IBooker::setCurrentFolder(), and subsystemname_.

 {
  if(fVerbosity>0) std::cout<<"CastorMonitorModule::beginRun (start)" << std::endl;
 
  if (DigiMon_ != nullptr) { DigiMon_->bookHistograms(ibooker,iRun,iSetup);}
  if (RecHitMon_ != nullptr) { RecHitMon_->bookHistograms(ibooker,iRun,iSetup); }
  if (LedMon_ != nullptr) { LedMon_->bookHistograms(ibooker,iRun,iSetup); }
 
   ibooker.setCurrentFolder(subsystemname_); 
  char s[60];
   sprintf(s,"CastorEventProducts");
    CastorEventProduct = ibooker.book1D(s,s,6,-0.5,5.5);
    CastorEventProduct->getTH1F()->GetYaxis()->SetTitle("Events");
    TAxis *xa = CastorEventProduct->getTH1F()->GetXaxis();
    xa->SetBinLabel(1,"FEDs/3");
    xa->SetBinLabel(2,"RawData");
    xa->SetBinLabel(3,"Digi");
    xa->SetBinLabel(4,"RecHits");
    xa->SetBinLabel(5,"Towers");
    xa->SetBinLabel(6,"Jets");
 
   sprintf(s,"CASTORUnpackReport");
    hunpkrep=ibooker.bookProfile(s,s,6,-0.5,5.5, 100,0,1.e10,"");
    xa = hunpkrep->getTProfile()->GetXaxis();
    xa->SetBinLabel(1, "N_FEDs");
    xa->SetBinLabel(2, "SPIGOT_Err");
    xa->SetBinLabel(3, "empty");
    xa->SetBinLabel(4, "busy");
    xa->SetBinLabel(5, "OvF");
    xa->SetBinLabel(6, "BadDigis");
 
  return;
 }

void CastorMonitorModule::dqmBeginRun	(	const edm::Run &	iRun,
		const edm::EventSetup &	iSetup
	)

overrideprotected

Definition at line 66 of file CastorMonitorModule.cc.

References conditions_, gather_cfg::cout, dbPedestals, fVerbosity, edm::EventSetup::get(), and edm::ESHandleBase::isValid().

                                                                    {
   iSetup.get<CastorDbRecord>().get(conditions_);
 
   iSetup.get<CastorPedestalsRcd>().get(dbPedestals);
   if(!dbPedestals.isValid() && fVerbosity>0) {
     std::cout<<"CASTOR has no CastorPedestals in the CondDB"<<std::endl;
   }
 }