|
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
|
#include "FWCore/Sources/interface/ProducerSourceBase.h"
#include "CondCore/CondDB/interface/Time.h"
#include "FWCore/ParameterSet/interface/ConfigurationDescriptions.h"
#include "FWCore/ParameterSet/interface/ParameterSetDescription.h"
#include <string>
namespace cond {
class EmptyIOVSource : public edm::ProducerSourceBase {
public:
EmptyIOVSource(edm::ParameterSet const&, edm::InputSourceDescription const&);
~EmptyIOVSource() override;
static void fillDescriptions(edm::ConfigurationDescriptions& descriptions);
private:
void produce(edm::Event& e) override;
bool setRunAndEventInfo(edm::EventID& id,
edm::TimeValue_t& time,
edm::EventAuxiliary::ExperimentType& eType) override;
void initialize(edm::EventID& id, edm::TimeValue_t& time, edm::TimeValue_t& interval) override;
private:
TimeType m_timeType;
Time_t m_firstValid;
Time_t m_lastValid;
Time_t m_interval;
Time_t m_current;
};
} // namespace cond
#include "FWCore/Utilities/interface/EDMException.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Framework/interface/IOVSyncValue.h"
//#include "DataFormats/Provenance/interface/EventID.h"
//#include <iostream>
namespace cond {
//allowed parameters: firstRun, firstTime, lastRun, lastTime,
//common paras: timetype,interval
EmptyIOVSource::EmptyIOVSource(edm::ParameterSet const& pset, edm::InputSourceDescription const& desc)
: edm::ProducerSourceBase(pset, desc, true),
m_timeType(time::timeTypeFromName(pset.getParameter<std::string>("timetype"))),
m_firstValid(pset.getParameter<unsigned long long>("firstValue")),
m_lastValid(pset.getParameter<unsigned long long>("lastValue")),
m_interval(pset.getParameter<unsigned long long>("interval")) {
m_current = m_firstValid;
}
EmptyIOVSource::~EmptyIOVSource() {}
void EmptyIOVSource::produce(edm::Event&) {}
bool EmptyIOVSource::setRunAndEventInfo(edm::EventID& id,
edm::TimeValue_t& time,
edm::EventAuxiliary::ExperimentType& eType) {
if (m_current <= m_lastValid) {
if (m_timeType == cond::runnumber) {
id = edm::EventID(m_current, id.luminosityBlock(), 1);
} else if (m_timeType == cond::timestamp) {
time = m_current;
} else if (m_timeType == cond::lumiid) {
edm::LuminosityBlockID l(m_current);
id = edm::EventID(l.run(), l.luminosityBlock(), 1);
//std::cout<<"run "<<l.run()<<std::endl;
//std::cout<<"luminosityBlock "<<l.luminosityBlock()<<std::endl;
}
}
bool ok = !(m_lastValid < m_current);
m_current += m_interval;
return ok;
}
void EmptyIOVSource::initialize(edm::EventID& id, edm::TimeValue_t& time, edm::TimeValue_t& interval) {
if (m_timeType == cond::runnumber) {
id = edm::EventID(m_firstValid, id.luminosityBlock(), 1);
interval = 0LL;
} else if (m_timeType == cond::timestamp) {
time = m_firstValid;
interval = m_interval;
} else if (m_timeType == cond::lumiid) {
edm::LuminosityBlockID l(m_firstValid);
id = edm::EventID(l.run(), l.luminosityBlock(), 1);
interval = 0LL;
}
}
void EmptyIOVSource::fillDescriptions(edm::ConfigurationDescriptions& descriptions) {
edm::ParameterSetDescription desc;
desc.setComment("Creates runs, lumis and events containing no products.");
ProducerSourceBase::fillDescription(desc);
desc.add<std::string>("timetype");
desc.add<unsigned long long>("firstValue")->setComment("The first run number to use or the first time");
desc.add<unsigned long long>("lastValue")->setComment("The last run number to use or the last time");
desc.add<unsigned long long>("interval");
descriptions.add("source", desc);
}
} // namespace cond
#include "FWCore/Framework/interface/InputSourceMacros.h"
using cond::EmptyIOVSource;
DEFINE_FWK_INPUT_SOURCE(EmptyIOVSource);
|