#include <DQMMonitoringService.h>

Public Member Functions
	DQMMonitoringService (const edm::ParameterSet &, edm::ActivityRegistry &)

void	evEvent (StreamID const &)

void	evLumi (GlobalContext const &)

void	keepAlive ()

void	outputUpdate (ptree &doc)

	~DQMMonitoringService ()

Private Attributes
ptree	doc_

long	last_report_nevents_

std::chrono::high_resolution_clock::time_point	last_report_time_

std::shared_ptr< std::ostream >	mstream_

long	nevents_

Detailed Description

Definition at line 42 of file DQMMonitoringService.h.

Constructor & Destructor Documentation

dqmservices::DQMMonitoringService::DQMMonitoringService	(	const edm::ParameterSet &	pset,
		edm::ActivityRegistry &	ar
	)

Definition at line 14 of file DQMMonitoringService.cc.

References dtNoiseDBValidation_cfg::cerr, evEvent(), evLumi(), last_report_nevents_, last_report_time_, mstream_, nevents_, fileCollector::now, edm::ActivityRegistry::watchPreGlobalBeginLumi(), edm::ActivityRegistry::watchPreSourceEvent(), and x.

                                                                                                {
   const char* x = getenv("DQMMON_UPDATE_PIPE");
 
   if (x) {
     std::cerr << "Monitoring pipe: " << x << std::endl;
     mstream_.reset(new std::ofstream(x));
   } else {
     std::cerr << "Monitoring file not found, disabling." << std::endl;
   }
 
   nevents_ = 0;
   last_report_nevents_ = 0;
   last_report_time_ = std::chrono::high_resolution_clock::now();
 
   ar.watchPreGlobalBeginLumi(this, &DQMMonitoringService::evLumi);
   ar.watchPreSourceEvent(this, &DQMMonitoringService::evEvent);
 }

dqmservices::DQMMonitoringService::~DQMMonitoringService ( )

Definition at line 32 of file DQMMonitoringService.cc.

32 {

33 }

Member Function Documentation

void dqmservices::DQMMonitoringService::evEvent ( StreamID const & iContext )

Definition at line 45 of file DQMMonitoringService.cc.

References prof2calltree::count, asciidump::doc, last_report_nevents_, last_report_time_, nevents_, fileCollector::now, outputUpdate(), RPCpg::rate(), and seconds().

Referenced by DQMMonitoringService().

                                                            {
   nevents_ += 1;
 
   using std::chrono::duration_cast;
   using std::chrono::seconds;
  
   auto now = std::chrono::high_resolution_clock::now();
   auto count = duration_cast<seconds>(now - last_report_time_).count();
 
   if (count < 30) {
     // we don't want to report too often
     return;
   }
 
   ptree doc;
   doc.put("events_total", nevents_);
 
   if (count > 0) {
     float rate = (nevents_ - last_report_nevents_) / count;
     doc.put("events_rate", rate);
   }
 
   last_report_time_ = now; 
   last_report_nevents_ = nevents_;
 
   outputUpdate(doc);
 }

void dqmservices::DQMMonitoringService::evLumi ( GlobalContext const & iContext )

Definition at line 35 of file DQMMonitoringService.cc.

References asciidump::doc, fjr2json::lumi, edm::LuminosityBlockID::luminosityBlock(), edm::GlobalContext::luminosityBlockID(), outputUpdate(), edm::LuminosityBlockID::run(), and DTTTrigCorrFirst::run.

Referenced by DQMMonitoringService().

                                                                {
   unsigned int run = iContext.luminosityBlockID().run();
   unsigned int lumi = iContext.luminosityBlockID().luminosityBlock();
 
   ptree doc;
   doc.put("cmssw_run", run);
   doc.put("cmssw_lumi", lumi);
   outputUpdate(doc);
 }

void dqmservices::DQMMonitoringService::keepAlive ( )

Definition at line 87 of file DQMMonitoringService.cc.

References mstream_.

                                      {
   if (!mstream_)
     return;
 
   *mstream_ << "\n";
   mstream_->flush();
 }

void dqmservices::DQMMonitoringService::outputUpdate ( ptree & doc )

Definition at line 73 of file DQMMonitoringService.cc.

References mstream_, NULL, and cond::rpcobgas::time.

Referenced by evEvent(), and evLumi().

                                                   {
   if (!mstream_)
     return;
 
   try {
     doc.put("update_timestamp", std::time(NULL));
 
     write_json(*mstream_, doc, false);
     mstream_->flush();
   } catch (...) {
     // pass
   }
 }