#include <DQMEventInfo.h>

Inheritance diagram for DQMEventInfo:

Public Member Functions
	DQMEventInfo (const edm::ParameterSet &ps)
	Constructor. More...

virtual	~DQMEventInfo ()
	Destructor. More...

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

virtual void	beginStream (edm::StreamID id) final

	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

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)
	Analyze. More...

void	beginLuminosityBlock (const edm::LuminosityBlock &l, const edm::EventSetup &c)

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

void	dqmBeginRun (const edm::Run &r, const edm::EventSetup &c)

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
MonitorElement *	cmsswVer_
	Current working directory of the job. More...

double	currentTime_

DQMStore *	dbe_

MonitorElement *	dqmPatch_
	CMSSW version run for this job. More...

MonitorElement *	errSummary_
	DQM patch version for this job. More...

MonitorElement *	errSummaryEtaPhi_
	Subdetector-specific error summary (float) More...

MonitorElement *	errSummarySegment_ [10]
	Subdetector-specific etaPhi summary (float) More...

MonitorElement *	eventId_
	UTC time of the run start. More...

std::string	eventInfoFolder_

MonitorElement *	eventTimeStamp_

int64_t	evtRateCount_

double	evtRateWindow_

MonitorElement *	hostName_
	of event processed so far More...

double	lastAvgTime_

double	lastUpdateTime_

MonitorElement *	lumisecId_

MonitorElement *	nUpdates_
	These MEs are either static or updated upon each analyze() call. More...

edm::ParameterSet	parameters_

int64_t	pEvent_

MonitorElement *	processEventRate_
	Time elapsed since the last event. More...

MonitorElement *	processEvents_
	Avg # of events in programmable window (default: 5 min) More...

MonitorElement *	processId_
	Number of collector updates (TBD) More...

MonitorElement *	processLatency_
	The UTC time of the last event. More...

MonitorElement *	processName_
	Hostname of the local machine. More...

MonitorElement *	processStartTimeStamp_
	The PID associated with this job. More...

MonitorElement *	processTimeStamp_
	The UTC time of the first event processed. More...

MonitorElement *	runId_

double	runStartTime_

MonitorElement *	runStartTimeStamp_

std::string	subsystemname_

MonitorElement *	workingDir_
	DQM "name" of the job (eg, Hcal or DT) More...

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 32 of file DQMEventInfo.h.

Constructor & Destructor Documentation

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

Constructor.

Definition at line 25 of file DQMEventInfo.cc.

References currentTime_, eventInfoFolder_, evtRateCount_, evtRateWindow_, edm::ParameterSet::getUntrackedParameter(), lastAvgTime_, parameters_, pEvent_, stampToReal(), AlCaHLTBitMon_QueryRunRegistry::string, and subsystemname_.

                                                    {
 
   struct timeval now;
   gettimeofday(&now, 0);
 
   parameters_ = ps;
   pEvent_ = 0;
   evtRateCount_ = 0;
   lastAvgTime_ = currentTime_ = stampToReal(now);
 
   // read config parms
   std::string folder = parameters_.getUntrackedParameter<std::string>("eventInfoFolder", "EventInfo") ;
   subsystemname_ = parameters_.getUntrackedParameter<std::string>("subSystemFolder", "YourSubsystem") ;
 
   eventInfoFolder_ = subsystemname_ + "/" +  folder ;
   evtRateWindow_ = parameters_.getUntrackedParameter<double>("eventRateWindow", 0.5);
   if(evtRateWindow_<=0.15) evtRateWindow_=0.15;
 
 }

DQMEventInfo::~DQMEventInfo ( )

virtual

Destructor.

Definition at line 45 of file DQMEventInfo.cc.

45 {

46 }

Member Function Documentation

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

protectedvirtual

Analyze.

Implements edm::stream::EDAnalyzerBase.

Definition at line 119 of file DQMEventInfo.cc.

References currentTime_, delta, edm::EventID::event(), eventId_, eventTimeStamp_, evtRateCount_, evtRateWindow_, MonitorElement::Fill(), edm::EventBase::id(), lastAvgTime_, lastUpdateTime_, pEvent_, processEventRate_, processEvents_, processLatency_, processTimeStamp_, stampToReal(), and edm::EventBase::time().

                                                                    {
 
   eventId_->Fill(int64_t(e.id().event()));
   eventTimeStamp_->Fill(stampToReal(e.time()));
 
   pEvent_++;
   evtRateCount_++;
   processEvents_->Fill(pEvent_);
 
   struct timeval now;
   gettimeofday(&now, 0);
   lastUpdateTime_ = currentTime_;
   currentTime_ = stampToReal(now);
 
   processTimeStamp_->Fill(currentTime_);
   processLatency_->Fill(currentTime_ - lastUpdateTime_);
 
   double delta = currentTime_ - lastAvgTime_;
   if (delta >= (evtRateWindow_*60.0))
   {
     processEventRate_->Fill(evtRateCount_/delta);
     evtRateCount_ = 0;
     lastAvgTime_ = currentTime_;
   }
 
   return;
 }

void DQMEventInfo::beginLuminosityBlock	(	const edm::LuminosityBlock &	l,
		const edm::EventSetup &	c
	)

protectedvirtual

Reimplemented from edm::stream::EDAnalyzerBase.

Definition at line 114 of file DQMEventInfo.cc.

References MonitorElement::Fill(), edm::LuminosityBlockBase::id(), edm::LuminosityBlockID::luminosityBlock(), and lumisecId_.

 {
   lumisecId_->Fill(l.id().luminosityBlock());
 }

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

overrideprotectedvirtual

Implements DQMEDAnalyzer.

Definition at line 48 of file DQMEventInfo.cc.

References DQMStore::IBooker::bookFloat(), DQMStore::IBooker::bookInt(), DQMStore::IBooker::bookString(), cmsswVer_, currentTime_, eventId_, eventInfoFolder_, eventTimeStamp_, MonitorElement::Fill(), edm::ParameterSet::getParameter(), edm::ParameterSet::getParameterSet(), edm::getProcessParameterSet(), edm::getReleaseVersion(), edm::ParameterSet::getUntrackedParameterSet(), hostName_, lumisecId_, nUpdates_, pEvent_, processEventRate_, processEvents_, processId_, processLatency_, processName_, processStartTimeStamp_, processTimeStamp_, runId_, runStartTimeStamp_, DQMStore::IBooker::setCurrentFolder(), AlCaHLTBitMon_QueryRunRegistry::string, subsystemname_, and workingDir_.

 {
   ibooker.setCurrentFolder(eventInfoFolder_) ;
 
   //Event specific contents
   runId_     = ibooker.bookInt("iRun");
   runId_->Fill(-1);
   lumisecId_ = ibooker.bookInt("iLumiSection");
   lumisecId_->Fill(-1);
   eventId_   = ibooker.bookInt("iEvent");
   eventId_->Fill(-1);
   eventTimeStamp_ = ibooker.bookFloat("eventTimeStamp");
 
   ibooker.setCurrentFolder(eventInfoFolder_) ;
   //Process specific contents
   processTimeStamp_ = ibooker.bookFloat("processTimeStamp");
   processTimeStamp_->Fill(currentTime_);
   processLatency_ = ibooker.bookFloat("processLatency");
   processTimeStamp_->Fill(-1);
   processEvents_ = ibooker.bookInt("processedEvents");
   processEvents_->Fill(pEvent_);
   processEventRate_ = ibooker.bookFloat("processEventRate");
   processEventRate_->Fill(-1);
   nUpdates_= ibooker.bookInt("processUpdates");
   nUpdates_->Fill(-1);
 
   //Static Contents
   processId_= ibooker.bookInt("processID");
   processId_->Fill(gSystem->GetPid());
   processStartTimeStamp_ = ibooker.bookFloat("processStartTimeStamp");
   processStartTimeStamp_->Fill(currentTime_);
   runStartTimeStamp_ = ibooker.bookFloat("runStartTimeStamp");
   hostName_= ibooker.bookString("hostName",gSystem->HostName());
   processName_= ibooker.bookString("processName",subsystemname_);
   workingDir_= ibooker.bookString("workingDir",gSystem->pwd());
   cmsswVer_= ibooker.bookString("CMSSW_Version",edm::getReleaseVersion());
 
   // Folder to be populated by sub-systems' code
   std::string subfolder = eventInfoFolder_ + "/reportSummaryContents" ;
   ibooker.setCurrentFolder(subfolder);
 
   //Online static histograms
   const edm::ParameterSet &sourcePSet = edm::getProcessParameterSet().getParameterSet("@main_input");
   if (sourcePSet.getParameter<std::string>("@module_type") == "EventStreamHttpReader" ){
     std::string evSelection;
     std::vector<std::string> evSelectionList;
     const edm::ParameterSet &evSelectionPSet = sourcePSet.getUntrackedParameterSet("SelectEvents");
     evSelectionList = evSelectionPSet.getParameter<std::vector<std::string> >("SelectEvents");
     for ( std::vector<std::string>::iterator it = evSelectionList.begin(); it <  evSelectionList.end(); it++ )
       evSelection += "'"+ *it + "', ";
 
     evSelection.resize(evSelection.length()-2);
     ibooker.setCurrentFolder(eventInfoFolder_);
     ibooker.bookString("eventSelection",evSelection);
   }
 
 }

void DQMEventInfo::dqmBeginRun	(	const edm::Run &	r,
		const edm::EventSetup &	c
	)

protectedvirtual

Reimplemented from DQMEDAnalyzer.

Definition at line 108 of file DQMEventInfo.cc.

References edm::RunBase::beginTime(), MonitorElement::Fill(), edm::RunBase::id(), edm::RunID::run(), runId_, runStartTimeStamp_, and stampToReal().

 {
   runId_->Fill(r.id().run());
   runStartTimeStamp_->Fill(stampToReal(r.beginTime()));
 }

Member Data Documentation

MonitorElement* DQMEventInfo::cmsswVer_

private

Current working directory of the job.

Definition at line 92 of file DQMEventInfo.h.

Referenced by bookHistograms().

double DQMEventInfo::currentTime_

private

Definition at line 63 of file DQMEventInfo.h.

Referenced by analyze(), bookHistograms(), and DQMEventInfo().

DQMStore* DQMEventInfo::dbe_

private

Definition at line 54 of file DQMEventInfo.h.

MonitorElement* DQMEventInfo::dqmPatch_

private

CMSSW version run for this job.

Definition at line 93 of file DQMEventInfo.h.

MonitorElement* DQMEventInfo::errSummary_

private

DQM patch version for this job.

Definition at line 94 of file DQMEventInfo.h.

MonitorElement* DQMEventInfo::errSummaryEtaPhi_

private

Subdetector-specific error summary (float)

Definition at line 95 of file DQMEventInfo.h.

MonitorElement* DQMEventInfo::errSummarySegment_[10]

private

Subdetector-specific etaPhi summary (float)

Definition at line 96 of file DQMEventInfo.h.

MonitorElement* DQMEventInfo::eventId_

private

UTC time of the run start.

Definition at line 75 of file DQMEventInfo.h.

Referenced by analyze(), and bookHistograms().

std::string DQMEventInfo::eventInfoFolder_

private

Definition at line 57 of file DQMEventInfo.h.

Referenced by bookHistograms(), and DQMEventInfo().

MonitorElement* DQMEventInfo::eventTimeStamp_

private

Definition at line 77 of file DQMEventInfo.h.

Referenced by analyze(), and bookHistograms().

int64_t DQMEventInfo::evtRateCount_

private

Definition at line 66 of file DQMEventInfo.h.

Referenced by analyze(), and DQMEventInfo().

double DQMEventInfo::evtRateWindow_

private

Definition at line 65 of file DQMEventInfo.h.

Referenced by analyze(), and DQMEventInfo().

MonitorElement* DQMEventInfo::hostName_

private

of event processed so far

Definition at line 89 of file DQMEventInfo.h.

Referenced by bookHistograms().

double DQMEventInfo::lastAvgTime_

private

Definition at line 63 of file DQMEventInfo.h.

Referenced by analyze(), and DQMEventInfo().

double DQMEventInfo::lastUpdateTime_

private

Definition at line 63 of file DQMEventInfo.h.

Referenced by analyze().

MonitorElement* DQMEventInfo::lumisecId_

private

Definition at line 76 of file DQMEventInfo.h.

Referenced by beginLuminosityBlock(), and bookHistograms().

MonitorElement* DQMEventInfo::nUpdates_

private

These MEs are either static or updated upon each analyze() call.

Definition at line 82 of file DQMEventInfo.h.

Referenced by bookHistograms().

edm::ParameterSet DQMEventInfo::parameters_

private

Definition at line 56 of file DQMEventInfo.h.

Referenced by Mixins._TypedParameterizable::clone(), Types.PSet::clone(), Mixins._TypedParameterizable::copy(), and DQMEventInfo().

int64_t DQMEventInfo::pEvent_

private

Definition at line 67 of file DQMEventInfo.h.

Referenced by analyze(), bookHistograms(), and DQMEventInfo().

MonitorElement* DQMEventInfo::processEventRate_

private

Time elapsed since the last event.

Definition at line 87 of file DQMEventInfo.h.

Referenced by analyze(), and bookHistograms().

MonitorElement* DQMEventInfo::processEvents_

private

Avg # of events in programmable window (default: 5 min)

Definition at line 88 of file DQMEventInfo.h.

Referenced by analyze(), and bookHistograms().

MonitorElement* DQMEventInfo::processId_

private

Number of collector updates (TBD)

Definition at line 83 of file DQMEventInfo.h.

Referenced by bookHistograms().

MonitorElement* DQMEventInfo::processLatency_

private

The UTC time of the last event.

Definition at line 86 of file DQMEventInfo.h.

Referenced by analyze(), and bookHistograms().

MonitorElement* DQMEventInfo::processName_

private

Hostname of the local machine.

Definition at line 90 of file DQMEventInfo.h.

Referenced by bookHistograms().

MonitorElement* DQMEventInfo::processStartTimeStamp_

private

The PID associated with this job.

Definition at line 84 of file DQMEventInfo.h.

Referenced by bookHistograms().

MonitorElement* DQMEventInfo::processTimeStamp_

private

The UTC time of the first event processed.

Definition at line 85 of file DQMEventInfo.h.

Referenced by analyze(), and bookHistograms().

MonitorElement* DQMEventInfo::runId_

private

These MEs are filled with the info from the most recent event by the module

Definition at line 73 of file DQMEventInfo.h.

Referenced by bookHistograms(), and dqmBeginRun().

double DQMEventInfo::runStartTime_

private

Definition at line 64 of file DQMEventInfo.h.

MonitorElement* DQMEventInfo::runStartTimeStamp_

private

Definition at line 74 of file DQMEventInfo.h.

Referenced by bookHistograms(), and dqmBeginRun().

std::string DQMEventInfo::subsystemname_

private

Definition at line 58 of file DQMEventInfo.h.

Referenced by bookHistograms(), and DQMEventInfo().

MonitorElement* DQMEventInfo::workingDir_

private

DQM "name" of the job (eg, Hcal or DT)

Definition at line 91 of file DQMEventInfo.h.

Referenced by bookHistograms().

Public Member Functions

Protected Member Functions

Private Attributes

of event processed so far

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

of event processed so far