|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
#include "DQM/EcalCommon/interface/EcalDQMonitor.h"
#include "DQM/EcalCommon/interface/EcalDQMCommonUtils.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/Framework/interface/LuminosityBlock.h"
#include "FWCore/Framework/interface/Run.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/ParameterSet/interface/ParameterSetDescription.h"
#include "Geometry/EcalMapping/interface/EcalMappingRcd.h"
#include "Geometry/Records/interface/CaloGeometryRecord.h"
#include "Geometry/Records/interface/CaloTopologyRecord.h"
#include "Geometry/Records/interface/IdealGeometryRecord.h"
#include "FWCore/Framework/interface/ConsumesCollector.h"
#include <ctime>
#include <sstream>
namespace ecaldqm {
EcalDQMonitor::EcalDQMonitor(edm::ParameterSet const &_ps)
: workers_(),
moduleName_(_ps.getUntrackedParameter<std::string>("moduleName")),
verbosity_(_ps.getUntrackedParameter<int>("verbosity")) {
std::vector<std::string> workerNames(_ps.getUntrackedParameter<std::vector<std::string>>("workers"));
edm::ParameterSet const &workerParams(_ps.getUntrackedParameterSet("workerParameters"));
edm::ParameterSet const &commonParams(_ps.getUntrackedParameterSet("commonParameters"));
std::for_each(workerNames.begin(), workerNames.end(), [&](std::string const &name) {
if (verbosity_ > 0)
edm::LogInfo("EcalDQM") << moduleName_ << ": Setting up " << name << std::endl;
try {
DQWorker *worker(WorkerFactoryStore::singleton()->getWorker(
name, verbosity_, commonParams, workerParams.getUntrackedParameterSet(name)));
if (worker->onlineMode())
worker->setTime(time(nullptr));
workers_.push_back(worker);
} catch (std::exception &) {
edm::LogError("EcalDQM") << "Worker " << name << " not defined";
throw;
}
});
}
EcalDQMonitor::~EcalDQMonitor() noexcept(false) {
if (verbosity_ > 2)
edm::LogInfo("EcalDQM") << moduleName_ << ": Deleting workers";
executeOnWorkers_([](DQWorker *worker) { delete worker; }, "Dtor");
}
/*static*/
void EcalDQMonitor::fillDescriptions(edm::ParameterSetDescription &_desc) {
_desc.addUntracked<std::string>("moduleName", "Ecal Monitor Module");
_desc.addUntracked<std::vector<std::string>>("workers");
_desc.addUntracked<int>("verbosity", 0);
edm::ParameterSetDescription commonParameters;
commonParameters.addUntracked<bool>("onlineMode", false);
commonParameters.addUntracked<bool>("willConvertToEDM", true);
_desc.addUntracked("commonParameters", commonParameters);
}
void EcalDQMonitor::ecaldqmBeginRun(edm::Run const &_run, edm::EventSetup const &_es) {
executeOnWorkers_(
[&_run, &_es](DQWorker *worker) {
if (worker->onlineMode())
worker->setTime(time(nullptr));
worker->setRunNumber(_run.run());
worker->beginRun(_run, _es);
},
"beginRun");
if (verbosity_ > 0)
edm::LogInfo("EcalDQM") << moduleName_ << "::ecaldqmBeginRun";
}
void EcalDQMonitor::ecaldqmEndRun(edm::Run const &_run, edm::EventSetup const &_es) {
executeOnWorkers_(
[&_run, &_es](DQWorker *worker) {
if (worker->onlineMode())
worker->setTime(time(nullptr));
worker->setRunNumber(_run.run());
worker->endRun(_run, _es);
},
"endRun");
if (verbosity_ > 0)
edm::LogInfo("EcalDQM") << moduleName_ << "::ecaldqmEndRun";
}
void EcalDQMonitor::ecaldqmBeginLuminosityBlock(edm::LuminosityBlock const &_lumi, edm::EventSetup const &_es) const {
executeOnWorkers_(
[&_lumi, &_es](DQWorker *worker) {
if (worker->onlineMode())
worker->setTime(time(nullptr));
worker->setLumiNumber(_lumi.luminosityBlock());
worker->beginLuminosityBlock(_lumi, _es);
},
"beginLumi");
if (verbosity_ > 1)
edm::LogInfo("EcalDQM") << moduleName_ << "::ecaldqmBeginLuminosityBlock";
}
void EcalDQMonitor::ecaldqmEndLuminosityBlock(edm::LuminosityBlock const &_lumi, edm::EventSetup const &_es) {
executeOnWorkers_(
[&_lumi, &_es](DQWorker *worker) {
if (worker->onlineMode())
worker->setTime(time(nullptr));
worker->setLumiNumber(_lumi.luminosityBlock());
worker->endLuminosityBlock(_lumi, _es);
},
"endLumi");
if (verbosity_ > 2)
edm::LogInfo("EcalDQM") << moduleName_ << "::ecaldqmEndLuminosityBlock";
}
} // namespace ecaldqm
|