#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 one::DQMEDAnalyzer< T >
	DQMEDAnalyzer ()=default

	DQMEDAnalyzer (DQMEDAnalyzer< T... > const &)=delete

	DQMEDAnalyzer (DQMEDAnalyzer< T... > &&)=delete

	~DQMEDAnalyzer () override=default

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

Private Attributes
MonitorElement *	cmsswVer_
	Current working directory of the job. More...

double	currentTime_

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...

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...

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_, pEvent_, stampToReal(), AlCaHLTBitMon_QueryRunRegistry::string, subsystemname_, and ~DQMEventInfo().

                                                    {
 
   struct timeval now;
   gettimeofday(&now, nullptr);
 
   pEvent_ = 0;
   evtRateCount_ = 0;
   lastAvgTime_ = currentTime_ = stampToReal(now);
 
   // read config parms
   std::string folder = ps.getUntrackedParameter<std::string>("eventInfoFolder", "EventInfo") ;
   subsystemname_ = ps.getUntrackedParameter<std::string>("subSystemFolder", "YourSubsystem") ;
 
   eventInfoFolder_ = subsystemname_ + "/" +  folder ;
   evtRateWindow_ = ps.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 129 of file DQMEventInfo.cc.

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

                                                                    {
 
   //Filling lumi here guarantees that the lumi number corresponds to the event when
   // using multiple concurrent lumis in a job
   lumisecId_->Fill(e.id().luminosityBlock());
   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::bookHistograms	(	DQMStore::IBooker &	ibooker,
		edm::Run const &	iRun,
		edm::EventSetup const &
	)

overrideprotected

Definition at line 48 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_, 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);
   }
 
 
 }