|
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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
|
#ifndef FWCore_Framework_global_EDProducerBase_h
#define FWCore_Framework_global_EDProducerBase_h
// -*- C++ -*-
//
// Package: FWCore/Framework
// Class : EDProducerBase
//
/**\class EDProducerBase EDProducerBase.h "EDProducerBase.h"
Description: [one line class summary]
Usage:
<usage>
*/
//
// Original Author: Chris Jones
// Created: Thu, 18 Jul 2013 11:51:14 GMT
//
// system include files
#include <memory>
// user include files
#include "FWCore/Framework/interface/ProducerBase.h"
#include "FWCore/Framework/interface/EDConsumerBase.h"
#include "FWCore/Framework/interface/Frameworkfwd.h"
#include "DataFormats/Provenance/interface/ModuleDescription.h"
#include "FWCore/ParameterSet/interface/ParameterSetfwd.h"
#include "FWCore/Concurrency/interface/WaitingTaskHolder.h"
// forward declarations
namespace edm {
class ModuleCallingContext;
class PreallocationConfiguration;
class StreamID;
class GlobalSchedule;
class ActivityRegistry;
class ThinnedAssociationsHelper;
class EventForTransformer;
class ServiceWeakToken;
namespace maker {
template <typename T>
class ModuleHolderT;
}
namespace global {
class EDProducerBase : public ProducerBase, public EDConsumerBase {
public:
template <typename T>
friend class edm::maker::ModuleHolderT;
template <typename T>
friend class edm::WorkerT;
typedef EDProducerBase ModuleType;
friend class edm::GlobalSchedule;
EDProducerBase();
~EDProducerBase() override;
static void fillDescriptions(ConfigurationDescriptions& descriptions);
static void prevalidate(ConfigurationDescriptions& descriptions);
static const std::string& baseType();
// Warning: the returned moduleDescription will be invalid during construction
ModuleDescription const& moduleDescription() const { return moduleDescription_; }
virtual bool wantsProcessBlocks() const noexcept = 0;
virtual bool wantsInputProcessBlocks() const noexcept = 0;
virtual bool wantsGlobalRuns() const noexcept = 0;
virtual bool wantsGlobalLuminosityBlocks() const noexcept = 0;
virtual bool wantsStreamRuns() const noexcept = 0;
virtual bool wantsStreamLuminosityBlocks() const noexcept = 0;
private:
bool doEvent(EventTransitionInfo const&, ActivityRegistry*, ModuleCallingContext const*);
void doAcquire(EventTransitionInfo const&, ActivityRegistry*, ModuleCallingContext const*, WaitingTaskHolder&&);
void doTransformAsync(WaitingTaskHolder iTask,
size_t iTransformIndex,
EventPrincipal const& iEvent,
ActivityRegistry*,
ModuleCallingContext,
ServiceWeakToken const&) noexcept;
void doPreallocate(PreallocationConfiguration const&);
void doBeginJob();
void doEndJob();
void doBeginStream(StreamID);
void doEndStream(StreamID);
void doStreamBeginRun(StreamID, RunTransitionInfo const&, ModuleCallingContext const*);
void doStreamEndRun(StreamID, RunTransitionInfo const&, ModuleCallingContext const*);
void doStreamBeginLuminosityBlock(StreamID, LumiTransitionInfo const&, ModuleCallingContext const*);
void doStreamEndLuminosityBlock(StreamID, LumiTransitionInfo const&, ModuleCallingContext const*);
void doBeginProcessBlock(ProcessBlockPrincipal const&, ModuleCallingContext const*);
void doAccessInputProcessBlock(ProcessBlockPrincipal const&, ModuleCallingContext const*);
void doEndProcessBlock(ProcessBlockPrincipal const&, ModuleCallingContext const*);
void doBeginRun(RunTransitionInfo const&, ModuleCallingContext const*);
void doEndRun(RunTransitionInfo const&, ModuleCallingContext const*);
void doBeginLuminosityBlock(LumiTransitionInfo const&, ModuleCallingContext const*);
void doEndLuminosityBlock(LumiTransitionInfo const&, ModuleCallingContext const*);
void doRespondToOpenInputFile(FileBlock const&) {}
void doRespondToCloseInputFile(FileBlock const&) {}
void doRespondToCloseOutputFile() { clearInputProcessBlockCaches(); }
void doRegisterThinnedAssociations(ProductRegistry const&, ThinnedAssociationsHelper&) {}
void registerProductsAndCallbacks(EDProducerBase* module, SignallingProductRegistryFiller* reg) {
registerProducts(module, reg, moduleDescription_);
}
std::string workerType() const { return "WorkerT<EDProducer>"; }
virtual void produce(StreamID, Event&, EventSetup const&) const = 0;
//For now this is a placeholder
/*virtual*/ void preActionBeforeRunEventAsync(WaitingTaskHolder iTask,
ModuleCallingContext const& iModuleCallingContext,
Principal const& iPrincipal) const noexcept {}
virtual void beginJob() {}
virtual void endJob() {}
virtual void preallocStreams(unsigned int);
virtual void preallocRuns(unsigned int);
virtual void preallocRunsSummary(unsigned int);
virtual void preallocLumis(unsigned int);
virtual void preallocLumisSummary(unsigned int);
virtual void preallocate(PreallocationConfiguration const&);
virtual void doBeginStream_(StreamID id);
virtual void doEndStream_(StreamID id);
virtual void doStreamBeginRun_(StreamID id, Run const& rp, EventSetup const& c);
virtual void doStreamEndRun_(StreamID id, Run const& rp, EventSetup const& c);
virtual void doStreamEndRunSummary_(StreamID id, Run const& rp, EventSetup const& c);
virtual void doStreamBeginLuminosityBlock_(StreamID id, LuminosityBlock const& lbp, EventSetup const& c);
virtual void doStreamEndLuminosityBlock_(StreamID id, LuminosityBlock const& lbp, EventSetup const& c);
virtual void doStreamEndLuminosityBlockSummary_(StreamID id, LuminosityBlock const& lbp, EventSetup const& c);
virtual void doBeginProcessBlock_(ProcessBlock const&);
virtual void doAccessInputProcessBlock_(ProcessBlock const&);
virtual void doEndProcessBlock_(ProcessBlock const&);
virtual void doBeginRun_(Run const& rp, EventSetup const& c);
virtual void doBeginRunSummary_(Run const& rp, EventSetup const& c);
virtual void doEndRunSummary_(Run const& rp, EventSetup const& c);
virtual void doEndRun_(Run const& rp, EventSetup const& c);
virtual void doBeginLuminosityBlock_(LuminosityBlock const& lbp, EventSetup const& c);
virtual void doBeginLuminosityBlockSummary_(LuminosityBlock const& rp, EventSetup const& c);
virtual void doEndLuminosityBlockSummary_(LuminosityBlock const& lb, EventSetup const& c);
virtual void doEndLuminosityBlock_(LuminosityBlock const& lb, EventSetup const& c);
virtual void doBeginProcessBlockProduce_(ProcessBlock&);
virtual void doEndProcessBlockProduce_(ProcessBlock&);
virtual void doBeginRunProduce_(Run& rp, EventSetup const& c);
virtual void doEndRunProduce_(Run& rp, EventSetup const& c);
virtual void doBeginLuminosityBlockProduce_(LuminosityBlock& lbp, EventSetup const& c);
virtual void doEndLuminosityBlockProduce_(LuminosityBlock& lbp, EventSetup const& c);
virtual size_t transformIndex_(edm::ProductDescription const& iBranch) const noexcept;
virtual ProductResolverIndex transformPrefetch_(std::size_t iIndex) const noexcept;
virtual void transformAsync_(WaitingTaskHolder iTask,
std::size_t iIndex,
edm::EventForTransformer& iEvent,
edm::ActivityRegistry* iAct,
ServiceWeakToken const& iToken) const noexcept;
virtual void clearInputProcessBlockCaches();
virtual bool hasAccumulator() const noexcept { return false; }
virtual bool hasAcquire() const noexcept { return false; }
virtual void doAcquire_(StreamID, Event const&, edm::EventSetup const&, WaitingTaskHolder&&);
void setModuleDescription(ModuleDescription const& md) { moduleDescription_ = md; }
ModuleDescription moduleDescription_;
std::unique_ptr<std::vector<BranchID>[]> previousParentages_;
std::unique_ptr<std::vector<BranchID>[]> gotBranchIDsFromAcquire_;
std::unique_ptr<ParentageID[]> previousParentageIds_;
};
} // namespace global
} // namespace edm
#endif
|