|
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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include <iostream>
#include <sstream>
#include "CondCore/CondDB/interface/ConnectionPool.h"
#include "CalibTracker/SiStripDCS/interface/SiStripDetVOffBuilder.h"
class SiStripDetVOffHandler : public edm::one::EDAnalyzer<> {
public:
explicit SiStripDetVOffHandler(const edm::ParameterSet& iConfig);
~SiStripDetVOffHandler() override;
void analyze(const edm::Event& evt, const edm::EventSetup& evtSetup) override;
void endJob() override;
private:
cond::persistency::ConnectionPool m_connectionPool;
std::string m_condDb;
std::string m_localCondDbFile;
std::string m_targetTag;
int maxTimeBeforeNewIOV_;
std::vector<std::pair<SiStripDetVOff*, cond::Time_t> > newPayloads;
edm::Service<SiStripDetVOffBuilder> modHVBuilder;
};
SiStripDetVOffHandler::SiStripDetVOffHandler(const edm::ParameterSet& iConfig)
: m_connectionPool(),
m_condDb(iConfig.getParameter<std::string>("conditionDatabase")),
m_localCondDbFile(iConfig.getParameter<std::string>("condDbFile")),
m_targetTag(iConfig.getParameter<std::string>("targetTag")),
maxTimeBeforeNewIOV_(iConfig.getUntrackedParameter<int>("maxTimeBeforeNewIOV", 24)) {
m_connectionPool.setParameters(iConfig.getParameter<edm::ParameterSet>("DBParameters"));
m_connectionPool.configure();
// get last IOV from local sqlite file if "conditionDatabase" is empty
if (m_condDb.empty())
m_condDb = m_localCondDbFile;
}
SiStripDetVOffHandler::~SiStripDetVOffHandler() = default;
void SiStripDetVOffHandler::analyze(const edm::Event& evt, const edm::EventSetup& evtSetup) {
// get last payload from condDb
cond::Time_t lastIov = 0;
std::shared_ptr<SiStripDetVOff> lastPayload;
edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
<< "Retrieve last IOV from " << m_condDb;
cond::persistency::Session condDbSession = m_connectionPool.createSession(m_condDb);
condDbSession.transaction().start(true);
if (m_condDb.find("sqlite") == 0 && (!condDbSession.existsDatabase())) {
// Source of last IOV is empty
edm::LogInfo("SiStripDetVOffHandler")
<< "[SiStripDetVOffHandler::" << __func__ << "] "
<< "No information can be retrieved from " << m_condDb << " because the file is empty.\n"
<< "Will assume all HV/LV's are off.";
} else {
cond::persistency::IOVProxy iovProxy = condDbSession.readIov(m_targetTag);
cond::Hash lastPayloadHash = iovProxy.getLast().payloadId;
if (!lastPayloadHash.empty()) {
lastPayload = condDbSession.fetchPayload<SiStripDetVOff>(lastPayloadHash);
lastIov = iovProxy.getLast().since; // move to LastValidatedTime?
}
edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
<< " ... last IOV: " << lastIov << " , "
<< "last Payload: " << lastPayloadHash;
}
condDbSession.transaction().commit();
// build the object!
newPayloads.clear();
modHVBuilder->setLastSiStripDetVOff(lastPayload.get(), lastIov);
modHVBuilder->BuildDetVOffObj();
newPayloads = modHVBuilder->getModulesVOff();
edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
<< "Finished building " << newPayloads.size() << " new payloads.";
// write the payloads to sqlite file
edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
<< "Write new payloads to sqlite file " << m_localCondDbFile;
cond::persistency::Session localFileSession = m_connectionPool.createSession(m_localCondDbFile, true);
localFileSession.transaction().start(false);
if (lastPayload && newPayloads.size() == 1 && *newPayloads[0].first == *lastPayload) {
// if no HV/LV transition was found in this period
edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
<< "No HV/LV transition was found from PVSS query.";
bool forceNewIOV = true;
if (maxTimeBeforeNewIOV_ < 0)
forceNewIOV = false;
else {
auto deltaT = cond::time::to_boost(newPayloads[0].second) - cond::time::to_boost(lastIov);
forceNewIOV = deltaT > boost::posix_time::hours(maxTimeBeforeNewIOV_);
}
if (!forceNewIOV) {
newPayloads.erase(newPayloads.begin());
edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
<< " ... No payload transfered.";
} else {
edm::LogInfo("SiStripDetVOffHandler")
<< "[SiStripDetVOffHandler::" << __func__ << "] "
<< " ... The last IOV is too old. Will start a new IOV from " << newPayloads[0].second << "("
<< boost::posix_time::to_simple_string(cond::time::to_boost(newPayloads[0].second))
<< ") with the same payload.";
}
}
cond::persistency::IOVEditor iovEditor;
if (localFileSession.existsDatabase() && localFileSession.existsIov(m_targetTag)) {
edm::LogWarning("SiStripDetVOffHandler")
<< "[SiStripDetVOffHandler::" << __func__ << "] "
<< "IOV of tag " << m_targetTag << " already exists in sqlite file " << m_localCondDbFile;
iovEditor = localFileSession.editIov(m_targetTag);
} else {
iovEditor = localFileSession.createIov<SiStripDetVOff>(m_targetTag, cond::timestamp);
iovEditor.setDescription("New IOV");
}
for (const auto& payload : newPayloads) {
cond::Hash thePayloadHash = localFileSession.storePayload<SiStripDetVOff>(*payload.first);
iovEditor.insert(payload.second, thePayloadHash);
}
iovEditor.flush();
localFileSession.transaction().commit();
edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] " << newPayloads.size()
<< " payloads written to sqlite file.";
}
void SiStripDetVOffHandler::endJob() {}
// -------------------------------------------------------
typedef SiStripDetVOffHandler SiStripO2ODetVOff;
DEFINE_FWK_MODULE(SiStripO2ODetVOff);
|