DummyCondDBWriter.h

Go to the documentation of this file.

#ifndef CalibTracker_SiStripESProducer_DummyCondDBWriter_h
#define CalibTracker_SiStripESProducer_DummyCondDBWriter_h

// user include files
#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/Run.h"
#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "CondCore/DBOutputService/interface/PoolDBOutputService.h"

#include "FWCore/Utilities/interface/Exception.h"

#include <string>

template <typename TObject, typename TObjectO, typename TRecord>
class DummyCondDBWriter : public edm::EDAnalyzer {
public:
  explicit DummyCondDBWriter(const edm::ParameterSet& iConfig);
  ~DummyCondDBWriter() override;
  void analyze(const edm::Event& e, const edm::EventSetup& es) override{};

  void endRun(const edm::Run& run, const edm::EventSetup& es) override;

private:
  edm::ParameterSet iConfig_;
  unsigned long long cacheID;
};

template <typename TObject, typename TObjectO, typename TRecord>
DummyCondDBWriter<TObject, TObjectO, TRecord>::DummyCondDBWriter(const edm::ParameterSet& iConfig)
    : iConfig_(iConfig), cacheID(0) {
  edm::LogInfo("DummyCondDBWriter") << "DummyCondDBWriter constructor for typename " << typeid(TObject).name()
                                    << " and record " << typeid(TRecord).name() << std::endl;
}

template <typename TObject, typename TObjectO, typename TRecord>
DummyCondDBWriter<TObject, TObjectO, TRecord>::~DummyCondDBWriter() {
  edm::LogInfo("DummyCondDBWriter") << "DummyCondDBWriter::~DummyCondDBWriter()" << std::endl;
}

template <typename TObject, typename TObjectO, typename TRecord>
void DummyCondDBWriter<TObject, TObjectO, TRecord>::endRun(const edm::Run& run, const edm::EventSetup& es) {
  std::string rcdName = iConfig_.getParameter<std::string>("record");
  std::string labelName = iConfig_.getUntrackedParameter<std::string>("label", "");

  if (cacheID == es.get<TRecord>().cacheIdentifier()) {
    edm::LogInfo("DummyCondDBWriter") << "not needed to store objects with Record " << rcdName << " at run "
                                      << run.run() << std::endl;
    return;
  }
  cacheID = es.get<TRecord>().cacheIdentifier();

  edm::ESHandle<TObject> esobj;
  es.get<TRecord>().get(labelName, esobj);
  TObjectO* obj = new TObjectO(*(esobj.product()));
  cond::Time_t Time_;

  //And now write  data in DB
  edm::Service<cond::service::PoolDBOutputService> dbservice;
  if (dbservice.isAvailable()) {
    std::string openIovAt = iConfig_.getUntrackedParameter<std::string>("OpenIovAt", "beginOfTime");
    if (openIovAt == "beginOfTime")
      Time_ = dbservice->beginOfTime();
    else if (openIovAt == "currentTime")
      Time_ = dbservice->currentTime();
    else
      Time_ = iConfig_.getUntrackedParameter<uint32_t>("OpenIovAtTime", 1);

    dbservice->writeOne(obj, Time_, rcdName);
  } else {
    edm::LogError("SiStripFedCablingBuilder") << "Service is unavailable" << std::endl;
  }
}

#endif