XmasToDQMEventInfo Class Reference

#include <XmasToDQMEventInfo.h>

Inheritance diagram for XmasToDQMEventInfo:

Public Member Functions
	XmasToDQMEventInfo (const edm::ParameterSet &ps)
	Constructor. More...
virtual	~XmasToDQMEventInfo ()
	Destructor. More...
Public Member Functions inherited from edm::EDAnalyzer
	EDAnalyzer ()
std::string	workerType () const
virtual	~EDAnalyzer ()
Public Member Functions inherited from edm::EDConsumerBase
	EDConsumerBase ()
ProductHolderIndex	indexFrom (EDGetToken, BranchType, TypeID const &) const
void	itemsMayGet (BranchType, std::vector< ProductHolderIndex > &) const
void	itemsToGet (BranchType, std::vector< ProductHolderIndex > &) const
void	labelsForToken (EDGetToken iToken, Labels &oLabels) 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	beginRun (const edm::Run &r, const edm::EventSetup &c)
Protected Member Functions inherited from edm::EDAnalyzer
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
CurrentProcessingContext const *	currentContext () const
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 Member Functions
double	getUTCtime (timeval *a, timeval *b=NULL)

Private Attributes
MonitorElement *	cmsswVer_
	Current working directory of the job. More...
timeval	currentTime_
DQMStore *	dbe_
MonitorElement *	errSummary_
	CMSSW version run 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...
MonitorElement *	eventTimeStamp_
int	evtRateCount_
float	evtRateWindow_
MonitorElement *	hostName_
	of event processed so far More...
timeval	lastAvgTime_
timeval	lastUpdateTime_
MonitorElement *	lumisecId_
MonitorElement *	nUpdates_
	These MEs are either static or updated upon each analyze() call. More...
edm::ParameterSet	parameters_
int	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_
timeval	runStartTime_
MonitorElement *	runStartTimeStamp_
MonitorElement *	workingDir_
	DQM "name" of the job (eg, Hcal or DT) More...

Additional Inherited Members
Public Types inherited from edm::EDAnalyzer
typedef EDAnalyzer	ModuleType
typedef WorkerT< EDAnalyzer >	WorkerType
Static Public Member Functions inherited from edm::EDAnalyzer
static const std::string &	baseType ()
static void	fillDescriptions (ConfigurationDescriptions &descriptions)
static void	prevalidate (ConfigurationDescriptions &)

Detailed Description

Definition at line 35 of file XmasToDQMEventInfo.h.

Constructor & Destructor Documentation

XmasToDQMEventInfo::XmasToDQMEventInfo

(

const edm::ParameterSet &

ps

)

Constructor.

Definition at line 25 of file XmasToDQMEventInfo.cc.

References DQMStore::bookFloat(), DQMStore::bookInt(), DQMStore::bookString(), gather_cfg::cout, dbe_, MonitorElement::Fill(), edm::getReleaseVersion(), NULL, cppFunctionSkipper::operator, and DQMStore::setCurrentFolder().

                                                            {

 cout << "Constructor of XmasToDQMEventInfo called...." << endl;
  
  parameters_ = ps;
  pEvent_ = 0;
  evtRateCount_ = 0;
  gettimeofday(&currentTime_,NULL);
  lastAvgTime_ = currentTime_;
  
  dbe_ = edm::Service<DQMStore>().operator->();

  string eventinfofolder = parameters_.getUntrackedParameter<string>("eventInfoFolder", "EventInfo") ;
  string subsystemname = parameters_.getUntrackedParameter<string>("subSystemFolder", "YourSubsystem") ;
  string currentfolder = subsystemname + "/" +  eventinfofolder ;
  cout << "currentfolder " << currentfolder << endl;

  evtRateWindow_ = parameters_.getUntrackedParameter<double>("eventRateWindow", 0.5);
  if(evtRateWindow_<=0.15) evtRateWindow_=0.15;
  cout << "Event Rate averaged over " << evtRateWindow_ << " minutes" << endl;

  dbe_->setCurrentFolder(currentfolder) ;

  //Event specific contents
  runId_     = dbe_->bookInt("iRun");
  lumisecId_ = dbe_->bookInt("iLumiSection");
  eventId_   = dbe_->bookInt("iEvent");
  eventTimeStamp_ = dbe_->bookFloat("eventTimeStamp");
  
  dbe_->setCurrentFolder(currentfolder) ;
  //Process specific contents
  processTimeStamp_ = dbe_->bookFloat("processTimeStamp");
  processTimeStamp_->Fill(getUTCtime(&currentTime_));
  processLatency_ = dbe_->bookFloat("processLatency");
  processTimeStamp_->Fill(-1);
  processEvents_ = dbe_->bookInt("processedEvents");
  processEvents_->Fill(pEvent_);
  processEventRate_ = dbe_->bookFloat("processEventRate");
  processEventRate_->Fill(-1); 
  nUpdates_= dbe_->bookInt("processUpdates");
  nUpdates_->Fill(-1);

  //Static Contents
  processId_= dbe_->bookInt("processID"); 
  processId_->Fill(gSystem->GetPid());
  processStartTimeStamp_ = dbe_->bookFloat("processStartTimeStamp");
  processStartTimeStamp_->Fill(getUTCtime(&currentTime_));
  runStartTimeStamp_ = dbe_->bookFloat("runStartTimeStamp");
  hostName_= dbe_->bookString("hostName",gSystem->HostName());
  processName_= dbe_->bookString("processName",subsystemname);
  workingDir_= dbe_->bookString("workingDir",gSystem->pwd());
  cmsswVer_= dbe_->bookString("CMSSW_Version",edm::getReleaseVersion());
//  dqmPatch_= dbe_->bookString("DQM_Patch",dbe_->getDQMPatchVersion());
 
  // Folder to be populated by sub-systems' code
  string subfolder = currentfolder + "/reportSummaryContents" ;
  dbe_->setCurrentFolder(subfolder);

}

XmasToDQMEventInfo::~XmasToDQMEventInfo ( )

virtual

Destructor.

Definition at line 85 of file XmasToDQMEventInfo.cc.

References gather_cfg::cout.

                                       {

  cout<<"[XmasToDQMEventInfo]: destructor"<<endl;

}

Member Function Documentation

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

protectedvirtual

Analyze.

Implements edm::EDAnalyzer.

Definition at line 106 of file XmasToDQMEventInfo.cc.

References gather_cfg::cout, edm::EventID::event(), edm::EventBase::id(), xmas2dqm::wse::ToDqm::instance(), edm::EventBase::luminosityBlock(), NULL, convertSQLiteXML::runNumber, xmas2dqm::wse::ToDqm::runNumber_, AlCaHLTBitMon_QueryRunRegistry::string, edm::EventBase::time(), cond::rpcobgas::time, and edm::Timestamp::value().

                                                                   {
 
  static int icalls = 1;
  cout << "XmasToDQMEventInfo::analyze call = " << icalls << std::endl;
  
  //runId_->Fill(e.id().run());
  std::string runNumber;
  
  //xmas2dqm::wse::ToDqm::instance()->BSem_.take();
  runNumber = xmas2dqm::wse::ToDqm::instance()->runNumber_.toString();
  std::cout << "EventInfo runNumber ... = " << runNumber << std::endl;
  //xmas2dqm::wse::ToDqm::instance()->BSem_.give();
  
  std::istringstream istrfloat(runNumber);
  float runNumber_value;
  istrfloat >> runNumber_value;
  runId_->Fill(runNumber_value);
  
  lumisecId_->Fill(e.luminosityBlock());
  eventId_->Fill(e.id().event());
  eventTimeStamp_->Fill(e.time().value()/(double)0xffffffff);

  pEvent_++;
  evtRateCount_++;
  processEvents_->Fill(pEvent_);

  lastUpdateTime_=currentTime_;
  gettimeofday(&currentTime_,NULL);  
  processTimeStamp_->Fill(getUTCtime(&currentTime_));
  processLatency_->Fill(getUTCtime(&lastUpdateTime_,&currentTime_));

  float time = getUTCtime(&lastAvgTime_,&currentTime_);
  if(time>=(evtRateWindow_*60.0)){
    processEventRate_->Fill((float)evtRateCount_/time);
    evtRateCount_ = 0;
    lastAvgTime_ = currentTime_;    
  }

  icalls++;
  return;
}

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

protectedvirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 91 of file XmasToDQMEventInfo.cc.

References edm::RunBase::beginTime(), cond::rpcobgas::time, and edm::Timestamp::value().

                                                                          {
  
  const edm::Timestamp time = r.beginTime();

  float sec = time.value() >> 32; 
  float usec = 0xFFFFFFFF & time.value() ; 

  // cout << " begin Run " << r.run() << " " << time.value() << endl;
  // cout << setprecision(16) << getUTCtime(&currentTime_) << endl;
  // cout << sec+usec/1000000. << endl;

  runStartTimeStamp_->Fill(sec+usec/1000000.);
  
} 

double XmasToDQMEventInfo::getUTCtime ( timeval *  a, timeval *  b = NULL  )

private

Definition at line 148 of file XmasToDQMEventInfo.cc.

References NULL.

                                                           {
  double deltaT=(*a).tv_sec*1000.0+(*a).tv_usec/1000.0;
  if(b!=NULL) deltaT=(*b).tv_sec*1000.0+(*b).tv_usec/1000.0 - deltaT;
  return deltaT/1000.0;
}

Member Data Documentation

MonitorElement* XmasToDQMEventInfo::cmsswVer_

private

Current working directory of the job.

Definition at line 87 of file XmasToDQMEventInfo.h.

timeval XmasToDQMEventInfo::currentTime_

private

Definition at line 58 of file XmasToDQMEventInfo.h.

DQMStore* XmasToDQMEventInfo::dbe_

private

Definition at line 55 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::errSummary_

private

CMSSW version run for this job.

Definition at line 89 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::errSummaryEtaPhi_

private

Subdetector-specific error summary (float)

Definition at line 90 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::errSummarySegment_[10]

private

Subdetector-specific etaPhi summary (float)

Definition at line 91 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::eventId_

private

UTC time of the run start.

Definition at line 70 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::eventTimeStamp_

private

Definition at line 72 of file XmasToDQMEventInfo.h.

int XmasToDQMEventInfo::evtRateCount_

private

Definition at line 61 of file XmasToDQMEventInfo.h.

float XmasToDQMEventInfo::evtRateWindow_

private

Definition at line 60 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::hostName_

private

of event processed so far

Definition at line 84 of file XmasToDQMEventInfo.h.

timeval XmasToDQMEventInfo::lastAvgTime_

private

Definition at line 58 of file XmasToDQMEventInfo.h.

timeval XmasToDQMEventInfo::lastUpdateTime_

private

Definition at line 58 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::lumisecId_

private

Definition at line 71 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::nUpdates_

private

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

Definition at line 77 of file XmasToDQMEventInfo.h.

edm::ParameterSet XmasToDQMEventInfo::parameters_

private

Definition at line 57 of file XmasToDQMEventInfo.h.

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

int XmasToDQMEventInfo::pEvent_

private

Definition at line 62 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::processEventRate_

private

Time elapsed since the last event.

Definition at line 82 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::processEvents_

private

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

Definition at line 83 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::processId_

private

Number of collector updates (TBD)

Definition at line 78 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::processLatency_

private

The UTC time of the last event.

Definition at line 81 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::processName_

private

Hostname of the local machine.

Definition at line 85 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::processStartTimeStamp_

private

The PID associated with this job.

Definition at line 79 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::processTimeStamp_

private

The UTC time of the first event processed.

Definition at line 80 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::runId_

private

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

Definition at line 68 of file XmasToDQMEventInfo.h.

timeval XmasToDQMEventInfo::runStartTime_

private

Definition at line 59 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::runStartTimeStamp_

private

Definition at line 69 of file XmasToDQMEventInfo.h.

MonitorElement* XmasToDQMEventInfo::workingDir_

private

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

Definition at line 86 of file XmasToDQMEventInfo.h.