PCL of diamond sampic offset calibration

CalibPPS/TimingCalibration/plugins/BuildFile.xml

@@ -6,4 +6,5 @@
   <use name="CondFormats/PPSObjects"/>
   <use name="Geometry/Records"/>
   <use name="Geometry/VeryForwardGeometryBuilder"/>
+  <use name="CondFormats/DataRecord"/>
 </library>

CalibPPS/TimingCalibration/plugins/PPSDiamondSampicTimingCalibrationPCLHarvester.cc

@@ -0,0 +1,272 @@
+// -*- C++ -*-
+//
+// Package:    CalibPPS/TimingCalibration/PPSDiamondSampicTimingCalibrationPCLHarvester
+// Class:      PPSDiamondSampicTimingCalibrationPCLHarvester
+//
+/**\class PPSDiamondSampicTimingCalibrationPCLHarvester PPSDiamondSampicTimingCalibrationPCLHarvester.cc CalibPPS/TimingCalibration/PPSDiamondSampicTimingCalibrationPCLHarvester/plugins/PPSDiamondSampicTimingCalibrationPCLHarvester.cc
+
+ Description: Harvester of the DiamondSampicCalibration PCL which produces sqlite file with a new calibration
+
+ Implementation:
+     [Notes on implementation]
+*/
+//
+// Original Author:  Christopher Misan
+//         Created:  Mon, 26 Jul 2021 16:36:13 GMT
+//
+//
+
+#include "DQMServices/Core/interface/DQMEDHarvester.h"
+
+#include "FWCore/Framework/interface/Frameworkfwd.h"
+#include "FWCore/Framework/interface/MakerMacros.h"
+#include "FWCore/Framework/interface/ESHandle.h"
+#include "FWCore/Framework/interface/EventSetup.h"
+#include "FWCore/ParameterSet/interface/ParameterSet.h"
+#include "FWCore/ServiceRegistry/interface/Service.h"
+
+#include <boost/property_tree/json_parser.hpp>
+#include <boost/property_tree/ptree.hpp>
+
+#include "Geometry/VeryForwardGeometryBuilder/interface/CTPPSGeometry.h"
+#include "Geometry/Records/interface/VeryForwardRealGeometryRecord.h"
+
+#include "CalibPPS/TimingCalibration/interface/TimingCalibrationStruct.h"
+#include "CondCore/DBOutputService/interface/PoolDBOutputService.h"
+
+#include "DataFormats/CTPPSDetId/interface/CTPPSDiamondDetId.h"
+#include "CondFormats/PPSObjects/interface/PPSTimingCalibration.h"
+#include "CondFormats/DataRecord/interface/PPSTimingCalibrationRcd.h"
+
+namespace pt = boost::property_tree;
+
+struct Histograms_PPSDiamondSampicTimingCalibrationPCLWorker {
+  std::unordered_map<uint32_t, dqm::reco::MonitorElement*> timeHisto;
+  std::unordered_map<uint32_t, dqm::reco::MonitorElement*> db;
+  std::unordered_map<uint32_t, dqm::reco::MonitorElement*> sampic;
+  std::unordered_map<uint32_t, dqm::reco::MonitorElement*> channel;
+};
+
+class PPSDiamondSampicTimingCalibrationPCLHarvester : public DQMEDHarvester {
+public:
+  PPSDiamondSampicTimingCalibrationPCLHarvester(const edm::ParameterSet&);
+  void beginRun(const edm::Run&, const edm::EventSetup&) override;
+  static void fillDescriptions(edm::ConfigurationDescriptions&);
+
+private:
+  void dqmEndJob(DQMStore::IBooker&, DQMStore::IGetter&) override;
+  void calibJson(DQMStore::IGetter& iGetter);
+  void calibDb(DQMStore::IGetter& iGetter);
+
+  edm::ESGetToken<CTPPSGeometry, VeryForwardRealGeometryRecord> geomEsToken_;
+  edm::ESGetToken<PPSTimingCalibration, PPSTimingCalibrationRcd> timingCalibrationToken_;
+  edm::ESHandle<PPSTimingCalibration> hTimingCalib_;
+  std::vector<CTPPSDiamondDetId> detids_;
+  const std::string dqmDir_;
+  const unsigned int min_entries_;
+  const std::string jsonCalibFile_;
+};
+
+//------------------------------------------------------------------------------
+
+PPSDiamondSampicTimingCalibrationPCLHarvester::PPSDiamondSampicTimingCalibrationPCLHarvester(
+    const edm::ParameterSet& iConfig)
+    : geomEsToken_(esConsumes<edm::Transition::BeginRun>()),
+      dqmDir_(iConfig.getParameter<std::string>("dqmDir")),
+      min_entries_(iConfig.getParameter<unsigned int>("minEntries")),
+      jsonCalibFile_(iConfig.getParameter<std::string>("jsonCalibFile")) {
+  if (jsonCalibFile_.empty())
+    timingCalibrationToken_ = esConsumes<edm::Transition::BeginRun>(
+        edm::ESInputTag(iConfig.getParameter<std::string>("timingCalibrationTag")));
+}
+
+//------------------------------------------------------------------------------
+
+void PPSDiamondSampicTimingCalibrationPCLHarvester::beginRun(const edm::Run& iRun, const edm::EventSetup& iSetup) {
+  if (jsonCalibFile_.empty())
+    hTimingCalib_ = iSetup.getHandle(timingCalibrationToken_);
+  const auto& geom = iSetup.getData(geomEsToken_);
+  for (auto it = geom.beginSensor(); it != geom.endSensor(); ++it) {
+    if (!CTPPSDiamondDetId::check(it->first))
+      continue;
+    const CTPPSDiamondDetId detid(it->first);
+    detids_.emplace_back(detid);
+  }
+}
+
+//------------------------------------------------------------------------------
+
+void PPSDiamondSampicTimingCalibrationPCLHarvester::calibJson(DQMStore::IGetter& iGetter) {
+  Histograms_PPSDiamondSampicTimingCalibrationPCLWorker hists;
+  std::string ch_name;
+
+  pt::ptree node;
+  pt::read_json(jsonCalibFile_, node);
+  const std::string formula = node.get<std::string>("formula");
+
+  for (const auto& detid : detids_) {
+    detid.channelName(ch_name);
+    const auto chid = detid.rawId();
+
+    hists.db[chid] = iGetter.get(dqmDir_ + "/" + ch_name + "db");
+    hists.sampic[chid] = iGetter.get(dqmDir_ + "/" + ch_name + "sampic");
+    hists.channel[chid] = iGetter.get(dqmDir_ + "/" + ch_name + "channel");
+
+    int db = hists.db[chid]->getIntValue();
+    int sampic = hists.sampic[chid]->getIntValue();
+    int channel = hists.channel[chid]->getIntValue();
+
+    if (!node.get_child_optional("parameters." + std::to_string(db))) {
+      edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+          << "db " << db << " not present in calibration";
+      continue;
+    }
+
+    int ct = 0;
+    for (pt::ptree::value_type& par : node.get_child("parameters." + std::to_string(db))) {
+      double new_time_offset;
+      if (ct == 16 * (1 - sampic) + channel) {  //flip the calibration - sampic 1 is first in json
+        double old_time_offset = par.second.get<double>("time_offset");
+        hists.timeHisto[chid] = iGetter.get(dqmDir_ + "/" + ch_name);
+
+        if (hists.timeHisto[chid] == nullptr) {
+          edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+              << "Failed to retrieve time monitor for detid" << detid;
+          par.second.put<double>("time_offset", old_time_offset);
+          continue;
+        }
+
+        if (min_entries_ > 0 && hists.timeHisto[chid]->getEntries() < min_entries_) {
+          edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+              << "Not enough entries for channel (" << detid << "): " << hists.timeHisto[chid]->getEntries() << " < "
+              << min_entries_ << ". Skipping calibration.";
+          par.second.put<double>("time_offset", old_time_offset);
+          continue;
+        }
+        new_time_offset = old_time_offset - hists.timeHisto[chid]->getMean();
+        par.second.put<double>("time_offset", new_time_offset);
+        break;
+      }
+      ct++;
+    }
+  }
+  pt::write_json("adc_offsets_prec.cal.json", node);
+}
+
+//------------------------------------------------------------------------------
+
+void PPSDiamondSampicTimingCalibrationPCLHarvester::calibDb(DQMStore::IGetter& iGetter) {
+  PPSTimingCalibration calib = *hTimingCalib_;
+
+  // book the parameters containers
+  PPSTimingCalibration::ParametersMap params;
+  PPSTimingCalibration::TimingMap time_info;
+
+  Histograms_PPSDiamondSampicTimingCalibrationPCLWorker hists;
+  std::string ch_name;
+  const std::string& formula = calib.formula();
+
+  for (const auto& detid : detids_) {
+    detid.channelName(ch_name);
+    const auto chid = detid.rawId();
+
+    hists.db[chid] = iGetter.get(dqmDir_ + "/" + ch_name + "db");
+    if (hists.db[chid] == nullptr) {
+      edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+          << "Failed to retrieve db for detid: " << detid;
+      continue;
+    }
+
+    hists.sampic[chid] = iGetter.get(dqmDir_ + "/" + ch_name + "sampic");
+    if (hists.sampic[chid] == nullptr) {
+      edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+          << "Failed to retrieve sampic for detid: " << detid;
+      continue;
+    }
+
+    hists.channel[chid] = iGetter.get(dqmDir_ + "/" + ch_name + "channel");
+    if (hists.channel[chid] == nullptr) {
+      edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+          << "Failed to retrieve channel hwId for detid: " << detid;
+      continue;
+    }
+
+    int db = hists.db[chid]->getIntValue();
+    int sampic = hists.sampic[chid]->getIntValue();
+    int channel = hists.channel[chid]->getIntValue();
+
+    PPSTimingCalibration::Key key;
+    key.db = db;
+    key.sampic = sampic;
+    key.channel = channel;
+
+    double timeOffset = calib.timeOffset(db, sampic, channel);
+    double timePrecision = calib.timePrecision(db, sampic, channel);
+    if (timeOffset == 0 && timePrecision == 0) {
+      edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+          << "No calibration found for db: " << db << " sampic: " << sampic << " channel: " << channel;
+      continue;
+    }
+
+    int cell_ct = 0;
+    while (!calib.parameters(db, sampic, channel, cell_ct).empty()) {
+      auto parameters = calib.parameters(db, sampic, channel, cell_ct);
+      key.cell = cell_ct;
+      params[key] = parameters;
+      cell_ct++;
+    }
+
+    key.cell = -1;
+
+    time_info[key] = {timeOffset, timePrecision};
+    hists.timeHisto[chid] = iGetter.get(dqmDir_ + "/" + ch_name);
+    if (hists.timeHisto[chid] == nullptr) {
+      edm::LogWarning("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+          << "Failed to retrieve time monitor for detid: " << detid;
+      continue;
+    }
+
+    if (min_entries_ > 0 && hists.timeHisto[chid]->getEntries() < min_entries_) {
+      edm::LogInfo("PPSDiamondSampicTimingCalibrationPCLHarvester:dqmEndJob")
+          << "Not enough entries (" << detid << "): " << hists.timeHisto[chid]->getEntries() << " < " << min_entries_
+          << ". Skipping calibration.";
+      continue;
+    }
+
+    double new_time_offset = timeOffset - hists.timeHisto[chid]->getMean();
+    time_info[key] = {new_time_offset, timePrecision};
+  }
+
+  auto calibPPS = PPSTimingCalibration(formula, params, time_info);
+  // write the object
+  edm::Service<cond::service::PoolDBOutputService> poolDbService;
+  poolDbService->writeOne(&calibPPS, poolDbService->currentTime(), "PPSTimingCalibrationRcd");
+}
+
+//------------------------------------------------------------------------------
+
+void PPSDiamondSampicTimingCalibrationPCLHarvester::dqmEndJob(DQMStore::IBooker& iBooker, DQMStore::IGetter& iGetter) {
+  iBooker.cd();
+  iBooker.setCurrentFolder(dqmDir_);
+  if (jsonCalibFile_.empty())
+    calibDb(iGetter);
+  else
+    calibJson(iGetter);
+}
+
+//------------------------------------------------------------------------------
+
+void PPSDiamondSampicTimingCalibrationPCLHarvester::fillDescriptions(edm::ConfigurationDescriptions& descriptions) {
+  edm::ParameterSetDescription desc;
+  desc.add<std::string>("timingCalibrationTag", "GlobalTag:DiamondSampicCalibration")
+      ->setComment("input tag for timing calibration retrieval");
+  desc.add<std::string>("dqmDir", "AlCaReco/PPSDiamondSampicTimingCalibrationPCL")
+      ->setComment("input path for the various DQM plots");
+  desc.add<unsigned int>("minEntries", 1)->setComment("minimal number of hits to extract calibration");
+  desc.add<std::string>("jsonCalibFile", "")
+      ->setComment(
+          "input path for json file containing calibration, if none, calibration will be obtained from db instead");
+  descriptions.add("PPSDiamondSampicTimingCalibrationPCLHarvester", desc);
+}
+
+DEFINE_FWK_MODULE(PPSDiamondSampicTimingCalibrationPCLHarvester);