#include <DQMEventInfo.h>

Inheritance diagram for DQMEventInfo:

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

	~DQMEventInfo () override
	Destructor. More...

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 &e, const edm::EventSetup &c) override
	Analyze. More...

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

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

Constructor & Destructor Documentation

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

Constructor.

Definition at line 27 of file DQMEventInfo.cc.

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

                                                    {
 
   struct timeval now;
   gettimeofday(&now, nullptr);
 
   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 ( )

overridedefault

Destructor.

Referenced by DQMEventInfo().

Member Function Documentation

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

overrideprotected

Analyze.

Definition at line 135 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, nullptr);
   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
	)

overrideprotected

Definition at line 130 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 49 of file DQMEventInfo.cc.

References edm::RunBase::beginTime(), DQMStore::IBooker::bookFloat(), DQMStore::IBooker::bookInt(), DQMStore::IBooker::bookString(), cmsswVer_, currentTime_, csvReporter::delimiter, eventId_, eventInfoFolder_, eventTimeStamp_, MonitorElement::Fill(), edm::ParameterSet::getParameter(), edm::ParameterSet::getParameterSet(), edm::getProcessParameterSetContainingModule(), edm::getReleaseVersion(), edm::ParameterSet::getUntrackedParameter(), hostName_, edm::RunBase::id(), join(), lumisecId_, edm::one::EDProducerBase::moduleDescription(), nUpdates_, pEvent_, processEventRate_, processEvents_, processId_, processLatency_, processName_, processStartTimeStamp_, processTimeStamp_, alignCSCRings::pwd, edm::RunID::run(), runId_, runStartTimeStamp_, alignCSCRings::s, 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(nullptr, 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") == "DQMStreamerReader" ){
     std::string evSelection;
     std::vector<std::string> evSelectionList;
     std::string delimiter( ", " );
     evSelectionList = sourcePSet.getUntrackedParameter<std::vector<std::string> >("SelectEvents");
     // add single quotes inline in the vector of HLT paths:
     // we do copy assignment, and getUntrackedParameter returns
     // a by-value copy of the vector of strings 
     std::for_each( evSelectionList.begin(), evSelectionList.end(),
                    []( std::string & s ){ std::string squote( "'" );
                                           s = squote + s + squote;
                                           }
                    );
     evSelection = boost::algorithm::join( evSelectionList, delimiter );
     // if no HLT paths are specified, no selections are performed:
     // we mark this with an asterisk.
     if( evSelection.empty() ) {
       evSelection = std::string( "'*'" );
     }
     ibooker.setCurrentFolder(eventInfoFolder_);
     ibooker.bookString("eventSelection",evSelection);
   }
 
 
 }