#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

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
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

	EDAnalyzerBase ()

ModuleDescription const &	moduleDescription () const

virtual	~EDAnalyzerBase ()

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

	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 (std::string const &iProcessName, std::string const &iModuleLabel, bool iPrint, std::vector< char const * > &oModuleLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) 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

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

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

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 24 of file DQMEventInfo.cc.

References currentTime_, eventInfoFolder_, evtRateCount_, evtRateWindow_, hlt_dqm_clientPB-live_cfg::folder, 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 44 of file DQMEventInfo.cc.

44 {

45 }

Member Function Documentation

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

protectedvirtual

Analyze.

Implements edm::stream::EDAnalyzerBase.

Definition at line 123 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(e.id().event()); // Handing edm::EventNumber_t to Fill method which will handle further casting
   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 118 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 &	iRun,
		edm::EventSetup const &
	)

overrideprotectedvirtual

Implements DQMEDAnalyzer.

Definition at line 47 of file DQMEventInfo.cc.

References edm::RunBase::beginTime(), DQMStore::IBooker::bookFloat(), DQMStore::IBooker::bookInt(), DQMStore::IBooker::bookString(), cmsswVer_, currentTime_, eventId_, eventInfoFolder_, eventTimeStamp_, MonitorElement::Fill(), edm::ParameterSet::getParameter(), edm::ParameterSet::getParameterSet(), edm::getProcessParameterSetContainingModule(), edm::getReleaseVersion(), edm::ParameterSet::getUntrackedParameterSet(), hostName_, edm::RunBase::id(), lumisecId_, edm::stream::EDAnalyzerBase::moduleDescription(), NULL, nUpdates_, pEvent_, processEventRate_, processEvents_, processId_, processLatency_, processName_, processStartTimeStamp_, processTimeStamp_, alignCSCRings::pwd, edm::RunID::run(), runId_, runStartTimeStamp_, DQMStore::IBooker::setCurrentFolder(), stampToReal(), AlCaHLTBitMon_QueryRunRegistry::string, subsystemname_, and workingDir_.

 {
   ibooker.setCurrentFolder(eventInfoFolder_) ;
 
   //Event specific contents
   runId_     = ibooker.bookInt("iRun");
   runId_->Fill(iRun.id().run());
   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(getpid());
   processStartTimeStamp_ = ibooker.bookFloat("processStartTimeStamp");
   processStartTimeStamp_->Fill(currentTime_);
   runStartTimeStamp_ = ibooker.bookFloat("runStartTimeStamp");
   runStartTimeStamp_->Fill(stampToReal(iRun.beginTime()));
   char hostname[65];
   gethostname(hostname,64);
   hostname[64] = 0;
   hostName_= ibooker.bookString("hostName",hostname);
   processName_= ibooker.bookString("processName",subsystemname_);
   char* pwd = getcwd(NULL, 0);
   workingDir_= ibooker.bookString("workingDir",pwd);
   free(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::getProcessParameterSetContainingModule(moduleDescription())
     .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);
   }
 
 
 }