DQMMonitoringService.h

Go to the documentation of this file.

#ifndef DQMServices_StreamerIO_DQMMonitoringService_h
#define DQMServices_StreamerIO_DQMMonitoringService_h
 
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/ServiceRegistry/interface/ActivityRegistry.h"
#include "DataFormats/Provenance/interface/EventID.h"
#include "DataFormats/Provenance/interface/LuminosityBlockID.h"
#include "DataFormats/Provenance/interface/Timestamp.h"
#include "DataFormats/Provenance/interface/ModuleDescription.h"
#include "DataFormats/Provenance/interface/ParameterSetID.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ServiceRegistry/interface/StreamContext.h"
#include "FWCore/ServiceRegistry/interface/GlobalContext.h"
#include "FWCore/Utilities/interface/StreamID.h"
#include <filesystem>
 
#include <string>
#include <vector>
#include <map>
#include <queue>
#include <sstream>
#include <chrono>
#include <unordered_map>
 
#include <filesystem>
#include <boost/format.hpp>
#include <boost/property_tree/json_parser.hpp>
#include <boost/property_tree/ptree.hpp>
#include <boost/asio.hpp>
 
/*
 * This service is very similar to the FastMonitoringService in the HLT,
 * except that it is used for monitoring online DQM applications
 */
 
namespace dqmservices {
 
  using boost::property_tree::ptree;
 
  using edm::GlobalContext;
  using edm::StreamContext;
  using edm::StreamID;
 
  class DQMMonitoringService {
  public:
    DQMMonitoringService(const edm::ParameterSet&, edm::ActivityRegistry&);
    ~DQMMonitoringService();
 
    void connect();
    void keepAlive();
 
    void outputLumiUpdate();
    void outputUpdate(ptree& doc);
 
    void evLumi(GlobalContext const&);
    void evEvent(StreamID const&);
 
    void tryUpdate();
 
  private:
    boost::asio::local::stream_protocol::iostream mstream_;
 
    // global number of events processed
    long nevents_;
 
    // time point, number of events and the lumi number at the time we switched to
    // it
    unsigned long last_lumi_;  // last lumi (we report stats for it, after we
                               // switch to the next one)
    std::chrono::high_resolution_clock::time_point last_lumi_time_;
    std::chrono::high_resolution_clock::time_point last_update_time_;
    long last_lumi_nevents_;
 
    unsigned long run_;   // current run
    unsigned long lumi_;  // current lumi
  };
 
}  // namespace dqmservices
 
#endif