#include <DQMMonitoringService.h>

Public Member Functions
void	connect ()

	DQMMonitoringService (const edm::ParameterSet &, edm::ActivityRegistry &)

void	evEvent (StreamID const &)

void	evLumi (GlobalContext const &)

void	keepAlive ()

void	outputLumiUpdate ()

void	outputUpdate (ptree &doc)

void	tryUpdate ()

	~DQMMonitoringService ()

Private Attributes
unsigned long	last_lumi_

long	last_lumi_nevents_

std::chrono::high_resolution_clock::time_point	last_lumi_time_

std::chrono::high_resolution_clock::time_point	last_update_time_

unsigned long	lumi_

boost::asio::local::stream_protocol::iostream	mstream_

long	nevents_

unsigned long	run_

Detailed Description

Definition at line 44 of file DQMMonitoringService.h.

Constructor & Destructor Documentation

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

Definition at line 18 of file DQMMonitoringService.cc.

References EcnaPython_AdcPeg12_S1_10_R170298_1_0_150_Dee0::cerr, evEvent(), evLumi(), last_lumi_, last_lumi_nevents_, last_lumi_time_, lumi_, mstream_, nevents_, submitPVValidationJobs::now, run_, edm::ActivityRegistry::watchPreGlobalBeginLumi(), and edm::ActivityRegistry::watchPreSourceEvent().

                                                                                                  {
     const char* x = std::getenv("DQM2_SOCKET");
     if (x) {
       std::cerr << "Monitoring pipe: " << x << std::endl;
       mstream_.connect(boost::asio::local::stream_protocol::endpoint(x));
     } else {
       std::cerr << "Monitoring file not found, disabling." << std::endl;
     }
 
     // init counters
     nevents_ = 0;
 
     last_lumi_ = 0;
     last_lumi_nevents_ = 0;
     last_lumi_time_ = std::chrono::high_resolution_clock::now();
 
     run_ = 0;
     lumi_ = 0;
 
     ar.watchPreGlobalBeginLumi(this, &DQMMonitoringService::evLumi);
     ar.watchPreSourceEvent(this, &DQMMonitoringService::evEvent);
   }

dqmservices::DQMMonitoringService::~DQMMonitoringService ( )

Definition at line 41 of file DQMMonitoringService.cc.

41 {}

Member Function Documentation

void dqmservices::DQMMonitoringService::connect ( )

Referenced by o2o_db_cfgmap.DbManagerDAQ::update_hashmap().

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

Definition at line 100 of file DQMMonitoringService.cc.

References nevents_, and tryUpdate().

Referenced by DQMMonitoringService().

                                                              {
     nevents_ += 1;
     tryUpdate();
   }

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

Definition at line 84 of file DQMMonitoringService.cc.

References last_lumi_, last_lumi_nevents_, last_lumi_time_, lumi_, edm::LuminosityBlockID::luminosityBlock(), edm::GlobalContext::luminosityBlockID(), nevents_, submitPVValidationJobs::now, outputLumiUpdate(), edm::LuminosityBlockID::run(), and run_.

Referenced by DQMMonitoringService().

                                                                  {
     using std::chrono::duration_cast;
     using std::chrono::milliseconds;
 
     // these might be different than the numbers we want to report
     // rate/stats per lumi are calculated from last_*_ fields
     run_ = iContext.luminosityBlockID().run();
     lumi_ = iContext.luminosityBlockID().luminosityBlock();
 
     outputLumiUpdate();
 
     last_lumi_time_ = std::chrono::high_resolution_clock::now();
     last_lumi_nevents_ = nevents_;
     last_lumi_ = lumi_;
   }

void dqmservices::DQMMonitoringService::keepAlive ( )

Definition at line 123 of file DQMMonitoringService.cc.

References mstream_, and tryUpdate().

                                        {
     if (!mstream_)
       return;
 
     mstream_ << "\n";
     mstream_.flush();
 
     tryUpdate();
   }

void dqmservices::DQMMonitoringService::outputLumiUpdate ( )

Definition at line 43 of file DQMMonitoringService.cc.

References submitPVResolutionJobs::count, last_lumi_, last_lumi_nevents_, last_lumi_time_, lumi_, nevents_, submitPVValidationJobs::now, outputUpdate(), RPCpg::rate(), and run_.

Referenced by evLumi(), and tryUpdate().

                                               {
     using std::chrono::duration_cast;
     using std::chrono::milliseconds;
 
     auto now = std::chrono::high_resolution_clock::now();
 
     ptree doc;
 
     // these might be different than the numbers we want to report
     // rate/stats per lumi are calculated from last_*_ fields
     doc.put("cmssw_run", run_);
     doc.put("cmssw_lumi", lumi_);
     doc.put("events_total", nevents_);
 
     // do statistics for the last (elapsed) ls
     auto lumi_millis = duration_cast<milliseconds>(now - last_lumi_time_).count();
     auto lumi_events = nevents_ - last_lumi_nevents_;
     auto lumi_last = last_lumi_;
 
     if ((lumi_last > 0) && (lumi_millis > 0)) {
       doc.put("lumi_number", lumi_last);
       doc.put("lumi_events", lumi_events);
       doc.put("lumi_duration_ms", lumi_millis);
 
       float rate = ((float)lumi_events * 1000) / lumi_millis;
       doc.put("events_rate", rate);
 
       // also save the history entry
       ptree plumi;
       plumi.put("n", lumi_last);
       plumi.put("nevents", lumi_events);
       plumi.put("nmillis", lumi_millis);
       plumi.put("rate", rate);
 
       std::time_t hkey = std::time(nullptr);
       doc.add_child(fmt::sprintf("extra.lumi_stats.%d", hkey), plumi);
     }
 
     outputUpdate(doc);
   }

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

Definition at line 105 of file DQMMonitoringService.cc.

References last_update_time_, mstream_, and submitPVValidationJobs::now.

Referenced by outputLumiUpdate().

                                                     {
     using std::chrono::duration_cast;
     using std::chrono::milliseconds;
 
     if (!mstream_)
       return;
 
     try {
       last_update_time_ = std::chrono::high_resolution_clock::now();
       doc.put("update_timestamp", std::time(nullptr));
 
       write_json(mstream_, doc, false);
       mstream_.flush();
     } catch (...) {
       // pass
     }
   }

void dqmservices::DQMMonitoringService::tryUpdate ( )

Definition at line 133 of file DQMMonitoringService.cc.

References submitPVResolutionJobs::count, last_update_time_, mstream_, submitPVValidationJobs::now, and outputLumiUpdate().

Referenced by evEvent(), and keepAlive().

                                        {
     using std::chrono::duration_cast;
     using std::chrono::milliseconds;
 
     if (!mstream_)
       return;
 
     // sometimes we don't see any transition for a very long time
     // but we still want updates
     // luckily, keepAlive is called rather often by the input source
     auto now = std::chrono::high_resolution_clock::now();
     auto millis = duration_cast<milliseconds>(now - last_update_time_).count();
     if (millis >= (25 * 1000)) {
       outputLumiUpdate();
     }
   }