Skip to content

Commit

Permalink
Merge pull request #35096 from mmusich/migrateCondToolsRunInfoToEsCon…
Browse files Browse the repository at this point in the history
…sumes

Migrate `CondTools/RunInfo` to esConsumes
  • Loading branch information
cmsbuild committed Sep 6, 2021
2 parents d8eeab9 + 48f9dcf commit 19d89cf
Show file tree
Hide file tree
Showing 9 changed files with 127 additions and 147 deletions.
22 changes: 16 additions & 6 deletions CondTools/RunInfo/interface/BTransitionAnalyzer.h
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,11 @@ namespace cond {
class BTransitionAnalyzer : public edm::one::EDAnalyzer<edm::one::WatchRuns> {
public:
BTransitionAnalyzer(const edm::ParameterSet& pset)
: m_currentThreshold(pset.getUntrackedParameter<double>("currentThreshold", 18000.)) {}
: m_currentThreshold(pset.getUntrackedParameter<double>("currentThreshold", 18000.)),
m_RunInfoToken(esConsumes<edm::Transition::EndRun>()),
m_ESToken(esConsumes<edm::Transition::EndRun>()),
m_ESTokenB0T(esConsumes<edm::Transition::EndRun>(edm::ESInputTag("", "0T"))),
m_ESTokenB38T(esConsumes<edm::Transition::EndRun>(edm::ESInputTag("", "38T"))) {}
#ifdef __INTEL_COMPILER
virtual ~BTransitionAnalyzer() = default;
#endif
Expand All @@ -28,9 +32,8 @@ namespace cond {
void beginRun(edm::Run const&, edm::EventSetup const&) final{};
void analyze(edm::Event const&, edm::EventSetup const&) final{};
void endRun(edm::Run const& run, edm::EventSetup const& eventSetup) final {
edm::ESHandle<RunInfo> runInfoHandle;
edm::ESHandle<RunInfo> runInfoHandle = eventSetup.getHandle(m_RunInfoToken);
edm::ESHandle<T> payloadHandle, payloadRefHandle;
eventSetup.get<RunInfoRcd>().get(runInfoHandle);
double avg_current = (double)runInfoHandle->m_avg_current;
double current_default = -1;
std::string bOnLabel = std::string("38T");
Expand All @@ -40,13 +43,16 @@ namespace cond {
<< " A for run: " << run.run()
<< " with the corresponding threshold: " << m_currentThreshold << " A."
<< std::endl;
if (avg_current != current_default && avg_current <= m_currentThreshold)
if (avg_current != current_default && avg_current <= m_currentThreshold) {
bFieldLabel = bOffLabel;
payloadHandle = eventSetup.getHandle(m_ESTokenB0T);
} else {
payloadHandle = eventSetup.getHandle(m_ESTokenB38T);
}
edm::LogInfo("BTransitionAnalyzer")
<< "The magnet was " << (bFieldLabel == bOnLabel ? "ON" : "OFF") << " during run " << run.run()
<< ".\nLoading the product for the corrisponding label " << bFieldLabel << std::endl;
eventSetup.get<R>().get(bFieldLabel, payloadHandle);
eventSetup.get<R>().get(payloadRefHandle);
payloadRefHandle = eventSetup.getHandle(m_ESToken);
edm::Service<cond::service::PoolDBOutputService> mydbservice;
if (mydbservice.isAvailable()) {
if (!equalPayloads(payloadHandle, payloadRefHandle)) {
Expand All @@ -68,6 +74,10 @@ namespace cond {

private:
double m_currentThreshold;
const edm::ESGetToken<RunInfo, RunInfoRcd> m_RunInfoToken;
const edm::ESGetToken<T, R> m_ESToken;
const edm::ESGetToken<T, R> m_ESTokenB0T;
const edm::ESGetToken<T, R> m_ESTokenB38T;
};
} //namespace cond
#endif //BTRANSITIONANALYZER_H
41 changes: 23 additions & 18 deletions CondTools/RunInfo/plugins/FillInfoESAnalyzer.cc
Original file line number Diff line number Diff line change
@@ -1,42 +1,47 @@
#include <string>
#include <iostream>
#include <map>
#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "CondFormats/RunInfo/interface/FillInfo.h"
#include "CondFormats/DataRecord/interface/FillInfoRcd.h"

namespace edmtest {
class FillInfoESAnalyzer : public edm::EDAnalyzer {
class FillInfoESAnalyzer : public edm::one::EDAnalyzer<> {
private:
const edm::ESGetToken<FillInfo, FillInfoRcd> m_FillInfoToken;

public:
explicit FillInfoESAnalyzer(edm::ParameterSet const& p) { std::cout << "FillInfoESAnalyzer" << std::endl; }
explicit FillInfoESAnalyzer(int i) { std::cout << "FillInfoESAnalyzer " << i << std::endl; }
~FillInfoESAnalyzer() override { std::cout << "~FillInfoESAnalyzer " << std::endl; }
explicit FillInfoESAnalyzer(edm::ParameterSet const& p) : m_FillInfoToken(esConsumes()) {
edm::LogPrint("FillInfoESAnalyzer") << "FillInfoESAnalyzer" << std::endl;
}
explicit FillInfoESAnalyzer(int i) {
edm::LogPrint("FillInfoESAnalyzer") << "FillInfoESAnalyzer " << i << std::endl;
}
~FillInfoESAnalyzer() override { edm::LogPrint("FillInfoESAnalyzer") << "~FillInfoESAnalyzer " << std::endl; }
void analyze(const edm::Event& e, const edm::EventSetup& c) override;
};

void FillInfoESAnalyzer::analyze(const edm::Event& e, const edm::EventSetup& context) {
std::cout << "###FillInfoESAnalyzer::analyze" << std::endl;
std::cout << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
std::cout << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::LogPrint("FillInfoESAnalyzer") << "###FillInfoESAnalyzer::analyze" << std::endl;
edm::LogPrint("FillInfoESAnalyzer") << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
edm::LogPrint("FillInfoESAnalyzer") << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::eventsetup::EventSetupRecordKey recordKey(
edm::eventsetup::EventSetupRecordKey::TypeTag::findType("FillInfoRcd"));
if (recordKey.type() == edm::eventsetup::EventSetupRecordKey::TypeTag()) {
//record not found
std::cout << "Record \"FillInfoRcd"
<< "\" does not exist " << std::endl;
edm::LogPrint("FillInfoESAnalyzer") << "Record \"FillInfoRcd"
<< "\" does not exist " << std::endl;
}
edm::ESHandle<FillInfo> sum;
std::cout << "got eshandle" << std::endl;
context.get<FillInfoRcd>().get(sum);
std::cout << "got context" << std::endl;
edm::LogPrint("FillInfoESAnalyzer") << "got eshandle" << std::endl;
edm::ESHandle<FillInfo> sum = context.getHandle(m_FillInfoToken);
edm::LogPrint("FillInfoESAnalyzer") << "got context" << std::endl;
const FillInfo* summary = sum.product();
std::cout << "got FillInfo* " << std::endl;
std::cout << "print result" << std::endl;
std::cout << *summary;
edm::LogPrint("FillInfoESAnalyzer") << "got FillInfo* " << std::endl;
edm::LogPrint("FillInfoESAnalyzer") << "print result" << std::endl;
edm::LogPrint("FillInfoESAnalyzer") << *summary;
}
DEFINE_FWK_MODULE(FillInfoESAnalyzer);
} // namespace edmtest
39 changes: 21 additions & 18 deletions CondTools/RunInfo/plugins/LHCInfoESAnalyzer.cc
Original file line number Diff line number Diff line change
@@ -1,42 +1,45 @@
#include <string>
#include <iostream>
#include <map>
#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "CondFormats/RunInfo/interface/LHCInfo.h"
#include "CondFormats/DataRecord/interface/LHCInfoRcd.h"

namespace edmtest {
class LHCInfoESAnalyzer : public edm::EDAnalyzer {
class LHCInfoESAnalyzer : public edm::one::EDAnalyzer<> {
private:
const edm::ESGetToken<LHCInfo, LHCInfoRcd> m_LHCInfoToken;

public:
explicit LHCInfoESAnalyzer(edm::ParameterSet const& p) { std::cout << "LHCInfoESAnalyzer" << std::endl; }
explicit LHCInfoESAnalyzer(int i) { std::cout << "LHCInfoESAnalyzer " << i << std::endl; }
~LHCInfoESAnalyzer() override { std::cout << "~LHCInfoESAnalyzer " << std::endl; }
explicit LHCInfoESAnalyzer(edm::ParameterSet const& p) : m_LHCInfoToken(esConsumes()) {
edm::LogPrint("LHCInfoESAnalyzer") << "LHCInfoESAnalyzer" << std::endl;
}
explicit LHCInfoESAnalyzer(int i) { edm::LogPrint("LHCInfoESAnalyzer") << "LHCInfoESAnalyzer " << i << std::endl; }
~LHCInfoESAnalyzer() override { edm::LogPrint("LHCInfoESAnalyzer") << "~LHCInfoESAnalyzer " << std::endl; }
void analyze(const edm::Event& e, const edm::EventSetup& c) override;
};

void LHCInfoESAnalyzer::analyze(const edm::Event& e, const edm::EventSetup& context) {
std::cout << "###LHCInfoESAnalyzer::analyze" << std::endl;
std::cout << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
std::cout << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::LogPrint("LHCInfoESAnalyzer") << "###LHCInfoESAnalyzer::analyze" << std::endl;
edm::LogPrint("LHCInfoESAnalyzer") << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
edm::LogPrint("LHCInfoESAnalyzer") << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::eventsetup::EventSetupRecordKey recordKey(
edm::eventsetup::EventSetupRecordKey::TypeTag::findType("LHCInfoRcd"));
if (recordKey.type() == edm::eventsetup::EventSetupRecordKey::TypeTag()) {
//record not found
std::cout << "Record \"LHCInfoRcd"
<< "\" does not exist " << std::endl;
edm::LogPrint("LHCInfoESAnalyzer") << "Record \"LHCInfoRcd"
<< "\" does not exist " << std::endl;
}
edm::ESHandle<LHCInfo> sum;
std::cout << "got eshandle" << std::endl;
context.get<LHCInfoRcd>().get(sum);
std::cout << "got context" << std::endl;
edm::LogPrint("LHCInfoESAnalyzer") << "got eshandle" << std::endl;
edm::ESHandle<LHCInfo> sum = context.getHandle(m_LHCInfoToken);
edm::LogPrint("LHCInfoESAnalyzer") << "got context" << std::endl;
const LHCInfo* summary = sum.product();
std::cout << "got LHCInfo* " << std::endl;
std::cout << "print result" << std::endl;
std::cout << *summary;
edm::LogPrint("LHCInfoESAnalyzer") << "got LHCInfo* " << std::endl;
edm::LogPrint("LHCInfoESAnalyzer") << "print result" << std::endl;
edm::LogPrint("LHCInfoESAnalyzer") << *summary;
}
DEFINE_FWK_MODULE(LHCInfoESAnalyzer);
} // namespace edmtest
69 changes: 24 additions & 45 deletions CondTools/RunInfo/plugins/RunInfoESAnalyzer.cc
Original file line number Diff line number Diff line change
Expand Up @@ -2,75 +2,54 @@
#include <string>
#include <iostream>
#include <map>
#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/MakerMacros.h"

#include "FWCore/Framework/interface/EventSetup.h"

#include "CondFormats/RunInfo/interface/RunInfo.h"

#include "CondFormats/DataRecord/interface/RunSummaryRcd.h"

using namespace std;

namespace edmtest {
class RunInfoESAnalyzer : public edm::EDAnalyzer {
class RunInfoESAnalyzer : public edm::one::EDAnalyzer<> {
private:
const edm::ESGetToken<RunInfo, RunInfoRcd> m_RunInfoToken;

public:
explicit RunInfoESAnalyzer(edm::ParameterSet const& p) { std::cout << "RunInfoESAnalyzer" << std::endl; }
explicit RunInfoESAnalyzer(int i) { std::cout << "RunInfoESAnalyzer " << i << std::endl; }
~RunInfoESAnalyzer() override { std::cout << "~RunInfoESAnalyzer " << std::endl; }
// virtual void beginJob();
// virtual void beginRun(const edm::Run&, const edm::EventSetup& context);
explicit RunInfoESAnalyzer(edm::ParameterSet const& p) : m_RunInfoToken(esConsumes()) {
edm::LogPrint("RunInfoESAnalyzer") << "RunInfoESAnalyzer" << std::endl;
}
explicit RunInfoESAnalyzer(int i) { edm::LogPrint("RunInfoESAnalyzer") << "RunInfoESAnalyzer " << i << std::endl; }
~RunInfoESAnalyzer() override { edm::LogPrint("RunInfoESAnalyzer") << "~RunInfoESAnalyzer " << std::endl; }
void analyze(const edm::Event& e, const edm::EventSetup& c) override;

private:
};

/* void
RunInfoESAnalyzer::beginRun(const edm::Run&, const edm::EventSetup& context){
std::cout<<"###RunInfoESAnalyzer::beginRun"<<std::endl;
edm::ESHandle<RunInfo> RunInfo_lumiarray;
std::cout<<"got eshandle"<<std::endl;
context.get<RunInfoRcd>().get(RunInfo_lumiarray);
std::cout<<"got data"<<std::endl;
}
void
RunInfoESAnalyzer::beginJob(){
std::cout<<"###RunInfoESAnalyzer::beginJob"<<std::endl;
}
*/
void RunInfoESAnalyzer::analyze(const edm::Event& e, const edm::EventSetup& context) {
using namespace edm::eventsetup;
std::cout << "###RunInfoESAnalyzer::analyze" << std::endl;
edm::LogPrint("RunInfoESAnalyzer") << "###RunInfoESAnalyzer::analyze" << std::endl;

// Context is not used.
std::cout << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
std::cout << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::LogPrint("RunInfoESAnalyzer") << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
edm::LogPrint("RunInfoESAnalyzer") << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::eventsetup::EventSetupRecordKey recordKey(
edm::eventsetup::EventSetupRecordKey::TypeTag::findType("RunInfoRcd"));
if (recordKey.type() == edm::eventsetup::EventSetupRecordKey::TypeTag()) {
//record not found
std::cout << "Record \"RunInfoRcd"
<< "\" does not exist " << std::endl;
edm::LogPrint("RunInfoESAnalyzer") << "Record \"RunInfoRcd"
<< "\" does not exist " << std::endl;
}
edm::ESHandle<RunInfo> sum;
std::cout << "got eshandle" << std::endl;
context.get<RunInfoRcd>().get(sum);
std::cout << "got context" << std::endl;
edm::LogPrint("RunInfoESAnalyzer") << "got eshandle" << std::endl;
edm::ESHandle<RunInfo> sum = context.getHandle(m_RunInfoToken);
edm::LogPrint("RunInfoESAnalyzer") << "got context" << std::endl;
const RunInfo* summary = sum.product();
std::cout << "got RunInfo* " << std::endl;

std::cout << "print result" << std::endl;
edm::LogPrint("RunInfoESAnalyzer") << "got RunInfo* " << std::endl;
edm::LogPrint("RunInfoESAnalyzer") << "print result" << std::endl;
summary->printAllValues();
/* std::vector<std::string> subdet = summary->getSubdtIn();
std::cout<<"subdetector in the run "<< std::endl;
/*
std::vector<std::string> subdet = summary->getSubdtIn();
edm::LogPrint("RunInfoESAnalyzer")<<"subdetector in the run "<< std::endl;
for (size_t i=0; i<subdet.size(); i++){
std::cout<<"--> " << subdet[i] << std::endl;
edm::LogPrint("RunInfoESAnalyzer")<<"--> " << subdet[i] << std::endl;
}
*/
}
Expand Down
64 changes: 24 additions & 40 deletions CondTools/RunInfo/plugins/RunSummaryESAnalyzer.cc
Original file line number Diff line number Diff line change
Expand Up @@ -2,75 +2,59 @@
#include <string>
#include <iostream>
#include <map>
#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/MakerMacros.h"

#include "FWCore/Framework/interface/EventSetup.h"

#include "CondFormats/RunInfo/interface/RunSummary.h"

#include "CondFormats/DataRecord/interface/RunSummaryRcd.h"

using namespace std;

namespace edmtest {
class RunSummaryESAnalyzer : public edm::EDAnalyzer {
class RunSummaryESAnalyzer : public edm::one::EDAnalyzer<> {
private:
const edm::ESGetToken<RunSummary, RunSummaryRcd> m_RunSummaryToken;

public:
explicit RunSummaryESAnalyzer(edm::ParameterSet const& p) { std::cout << "RunSummaryESAnalyzer" << std::endl; }
explicit RunSummaryESAnalyzer(int i) { std::cout << "RunSummaryESAnalyzer " << i << std::endl; }
~RunSummaryESAnalyzer() override { std::cout << "~RunSummaryESAnalyzer " << std::endl; }
// virtual void beginJob();
// virtual void beginRun(const edm::Run&, const edm::EventSetup& context);
explicit RunSummaryESAnalyzer(edm::ParameterSet const& p) : m_RunSummaryToken(esConsumes()) {
edm::LogPrint("RunSummaryESAnalyzer") << "RunSummaryESAnalyzer" << std::endl;
}
explicit RunSummaryESAnalyzer(int i) {
edm::LogPrint("RunSummaryESAnalyzer") << "RunSummaryESAnalyzer " << i << std::endl;
}
~RunSummaryESAnalyzer() override { edm::LogPrint("RunSummaryESAnalyzer") << "~RunSummaryESAnalyzer " << std::endl; }
void analyze(const edm::Event& e, const edm::EventSetup& c) override;

private:
};

/* void
RunSummaryESAnalyzer::beginRun(const edm::Run&, const edm::EventSetup& context){
std::cout<<"###RunSummaryESAnalyzer::beginRun"<<std::endl;
edm::ESHandle<RunSummary> RunSummary_lumiarray;
std::cout<<"got eshandle"<<std::endl;
context.get<RunSummaryRcd>().get(RunSummary_lumiarray);
std::cout<<"got data"<<std::endl;
}
void
RunSummaryESAnalyzer::beginJob(){
std::cout<<"###RunSummaryESAnalyzer::beginJob"<<std::endl;
}
*/
void RunSummaryESAnalyzer::analyze(const edm::Event& e, const edm::EventSetup& context) {
using namespace edm::eventsetup;
std::cout << "###RunSummaryESAnalyzer::analyze" << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << "###RunSummaryESAnalyzer::analyze" << std::endl;

// Context is not used.
std::cout << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
std::cout << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << " I AM IN RUN NUMBER " << e.id().run() << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << " ---EVENT NUMBER " << e.id().event() << std::endl;
edm::eventsetup::EventSetupRecordKey recordKey(
edm::eventsetup::EventSetupRecordKey::TypeTag::findType("RunSummaryRcd"));
if (recordKey.type() == edm::eventsetup::EventSetupRecordKey::TypeTag()) {
//record not found
std::cout << "Record \"RunSummaryRcd"
<< "\" does not exist " << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << "Record \"RunSummaryRcd"
<< "\" does not exist " << std::endl;
}
edm::ESHandle<RunSummary> sum;
std::cout << "got eshandle" << std::endl;
context.get<RunSummaryRcd>().get(sum);
std::cout << "got context" << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << "got eshandle" << std::endl;
edm::ESHandle<RunSummary> sum = context.getHandle(m_RunSummaryToken);
edm::LogPrint("RunSummaryESAnalyzer") << "got context" << std::endl;
const RunSummary* summary = sum.product();
std::cout << "got RunSummary* " << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << "got RunSummary* " << std::endl;

std::cout << "print result" << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << "print result" << std::endl;
summary->printAllValues();
std::vector<std::string> subdet = summary->getSubdtIn();
std::cout << "subdetector in the run " << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << "subdetector in the run " << std::endl;
for (size_t i = 0; i < subdet.size(); i++) {
std::cout << "--> " << subdet[i] << std::endl;
edm::LogPrint("RunSummaryESAnalyzer") << "--> " << subdet[i] << std::endl;
}
}
DEFINE_FWK_MODULE(RunSummaryESAnalyzer);
Expand Down

0 comments on commit 19d89cf

Please sign in to comment.