dqmservices::DQMMonitoringService Class Reference

#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

DQMMonitoringService()

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

Definition at line 17 of file DQMMonitoringService.cc.

                                                                                                 {
    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);
  }

References beam_dqm_sourceclient-live_cfg::cerr, evEvent(), evLumi(), last_lumi_, last_lumi_nevents_, last_lumi_time_, lumi_, mstream_, nevents_, fileCollector::now, run_, edm::ActivityRegistry::watchPreGlobalBeginLumi(), and edm::ActivityRegistry::watchPreSourceEvent().

~DQMMonitoringService()

dqmservices::DQMMonitoringService::~DQMMonitoringService

(

)

Definition at line 40 of file DQMMonitoringService.cc.

{}

Member Function Documentation

connect()

void dqmservices::DQMMonitoringService::connect

(

)

Referenced by o2o_db_cfgmap.DbManagerDAQ::update_hashmap().

evEvent()

void dqmservices::DQMMonitoringService::evEvent

(

StreamID const &

iContext

)

Definition at line 99 of file DQMMonitoringService.cc.

                                                             {
    nevents_ += 1;
    tryUpdate();
  }

References nevents_, and tryUpdate().

Referenced by DQMMonitoringService().

evLumi()

void dqmservices::DQMMonitoringService::evLumi

(

GlobalContext const &

iContext

)

Definition at line 83 of file DQMMonitoringService.cc.

                                                                 {
    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_;
  }

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

Referenced by DQMMonitoringService().

keepAlive()

void dqmservices::DQMMonitoringService::keepAlive

(

)

Definition at line 122 of file DQMMonitoringService.cc.

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

References mstream_, and tryUpdate().

outputLumiUpdate()

void dqmservices::DQMMonitoringService::outputLumiUpdate

(

)

Definition at line 42 of file DQMMonitoringService.cc.

                                              {
    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(str(boost::format("extra.lumi_stats.%d") % hkey), plumi);
    }
 
    outputUpdate(doc);
  }

References common_cff::doc, dqmMemoryStats::float, dqm-mbProfile::format, last_lumi_, last_lumi_nevents_, last_lumi_time_, lumi_, nevents_, fileCollector::now, outputUpdate(), RPCpg::rate(), run_, str, and ntuplemaker::time.

Referenced by evLumi(), and tryUpdate().

outputUpdate()

void dqmservices::DQMMonitoringService::outputUpdate

(

ptree &

doc

)

Definition at line 104 of file DQMMonitoringService.cc.

                                                    {
    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
    }
  }

References common_cff::doc, last_update_time_, mstream_, fileCollector::now, and ntuplemaker::time.

Referenced by outputLumiUpdate().

tryUpdate()

void dqmservices::DQMMonitoringService::tryUpdate

(

)

Definition at line 132 of file DQMMonitoringService.cc.

                                       {
    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();
    }
  }

References last_update_time_, mstream_, fileCollector::now, and outputLumiUpdate().

Referenced by evEvent(), and keepAlive().

Member Data Documentation

last_lumi_

unsigned long dqmservices::DQMMonitoringService::last_lumi_

private

Definition at line 68 of file DQMMonitoringService.h.

Referenced by DQMMonitoringService(), evLumi(), and outputLumiUpdate().

last_lumi_nevents_

long dqmservices::DQMMonitoringService::last_lumi_nevents_

private

Definition at line 72 of file DQMMonitoringService.h.

Referenced by DQMMonitoringService(), evLumi(), and outputLumiUpdate().

last_lumi_time_

std::chrono::high_resolution_clock::time_point dqmservices::DQMMonitoringService::last_lumi_time_

private

Definition at line 70 of file DQMMonitoringService.h.

Referenced by DQMMonitoringService(), evLumi(), and outputLumiUpdate().

last_update_time_

std::chrono::high_resolution_clock::time_point dqmservices::DQMMonitoringService::last_update_time_

private

Definition at line 71 of file DQMMonitoringService.h.

Referenced by outputUpdate(), and tryUpdate().

lumi_

unsigned long dqmservices::DQMMonitoringService::lumi_

private

Definition at line 75 of file DQMMonitoringService.h.

Referenced by DQMMonitoringService(), evLumi(), and outputLumiUpdate().

mstream_

boost::asio::local::stream_protocol::iostream dqmservices::DQMMonitoringService::mstream_

private

Definition at line 61 of file DQMMonitoringService.h.

Referenced by DQMMonitoringService(), keepAlive(), outputUpdate(), and tryUpdate().

nevents_

long dqmservices::DQMMonitoringService::nevents_

private

Definition at line 64 of file DQMMonitoringService.h.

Referenced by DQMMonitoringService(), evEvent(), evLumi(), and outputLumiUpdate().

run_

unsigned long dqmservices::DQMMonitoringService::run_

private

Definition at line 74 of file DQMMonitoringService.h.

Referenced by DQMMonitoringService(), evLumi(), and outputLumiUpdate().