|
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
|
#include <set>
#include <sstream>
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Utilities/interface/EDMException.h"
#include "FWCore/Framework/interface/EventSetupRecordIntervalFinder.h"
#include "FWCore/Framework/interface/SourceFactory.h"
namespace edm {
class EmptyESSource : public EventSetupRecordIntervalFinder {
public:
EmptyESSource(ParameterSet const&);
EmptyESSource(EmptyESSource const&) = delete; // stop default
EmptyESSource const& operator=(EmptyESSource const&) = delete; // stop default
// ---------- const member functions ---------------------
// ---------- static member functions --------------------
// ---------- member functions ---------------------------
void setIntervalFor(eventsetup::EventSetupRecordKey const&,
IOVSyncValue const& iTime,
ValidityInterval& oInterval) override;
static void fillDescriptions(ConfigurationDescriptions& descriptions);
private:
void delaySettingRecords() override;
// ---------- member data --------------------------------
std::string recordName_;
std::set<IOVSyncValue> setOfIOV_;
bool iovIsTime_;
};
EmptyESSource::EmptyESSource(ParameterSet const& pset)
: recordName_(pset.getParameter<std::string>("recordName")),
iovIsTime_(!pset.getParameter<bool>("iovIsRunNotTime")) {
std::vector<unsigned int> temp(pset.getParameter<std::vector<unsigned int>>("firstValid"));
for (std::vector<unsigned int>::iterator itValue = temp.begin(), itValueEnd = temp.end(); itValue != itValueEnd;
++itValue) {
if (iovIsTime_) {
setOfIOV_.insert(IOVSyncValue(Timestamp(*itValue)));
} else {
setOfIOV_.insert(IOVSyncValue(EventID(*itValue, 0, 0)));
}
}
//copy_all(temp, inserter(setOfIOV_ , setOfIOV_.end()));
}
void EmptyESSource::delaySettingRecords() {
eventsetup::EventSetupRecordKey recordKey = eventsetup::EventSetupRecordKey::TypeTag::findType(recordName_);
if (recordKey == eventsetup::EventSetupRecordKey()) {
throw edm::Exception(errors::Configuration)
<< " The Record type named \"" << recordName_ << "\" could not be found. Please check the spelling. \n"
<< "If the spelling is fine, then no module in the job requires this Record and therefore EmptyESSource can "
"not function.\n"
"In such a case please either remove the EmptyESSource with label'"
<< descriptionForFinder().label_ << "' from your job or add a module which needs the Record to your job.";
}
findingRecordWithKey(recordKey);
}
void EmptyESSource::setIntervalFor(eventsetup::EventSetupRecordKey const&,
IOVSyncValue const& iTime,
ValidityInterval& oInterval) {
oInterval = ValidityInterval::invalidInterval();
//if no intervals given, fail immediately
if (setOfIOV_.empty()) {
return;
}
std::pair<std::set<IOVSyncValue>::iterator, std::set<IOVSyncValue>::iterator> itFound =
setOfIOV_.equal_range(iTime);
//we have overshot
if (itFound.first == itFound.second) {
if (itFound.first == setOfIOV_.begin()) {
//request is before first valid interval, so fail
return;
}
//go back one step
--itFound.first;
}
if (itFound.first == setOfIOV_.end()) {
return;
}
IOVSyncValue endOfInterval = IOVSyncValue::endOfTime();
if (itFound.second != setOfIOV_.end()) {
if (iovIsTime_) {
endOfInterval = IOVSyncValue(Timestamp(itFound.second->time().value() - 1));
} else {
endOfInterval = IOVSyncValue(itFound.second->eventID().previousRunLastEvent(0));
}
}
oInterval = ValidityInterval(*(itFound.first), endOfInterval);
}
void EmptyESSource::fillDescriptions(ConfigurationDescriptions& descriptions) {
edm::ParameterSetDescription desc;
desc.add<std::string>("recordName")
->setComment(
"The name of the EventSetup Record for which intervals are to be generated.\n The record type must be used "
"by some module in the job else an exception will occur.");
desc.add<bool>("iovIsRunNotTime", true)->setComment("Sets how to interpret integer values used in 'firstValid'");
desc.add<std::vector<unsigned int>>("firstValid")
->setComment(
"Sets the beginning point of an IOV. The end point is assumed to be the next entry in the list. If there "
"are no further entries than 'end of time' is used.");
descriptions.addDefault(desc);
}
} // namespace edm
using edm::EmptyESSource;
DEFINE_FWK_EVENTSETUP_SOURCE(EmptyESSource);
|