Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Migrate CondTools/RunInfo to esConsumes #35096

Merged
merged 1 commit into from
Sep 6, 2021
Merged

Migrate CondTools/RunInfo to esConsumes #35096

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
22 changes: 16 additions & 6 deletions CondTools/RunInfo/interface/BTransitionAnalyzer.h
View file
Open in desktop
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
View file
Open in desktop
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
View file
Open in desktop
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
View file
Open in desktop
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
View file
Open in desktop
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