|
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
|
#ifndef FWCore_Framework_one_EDProducerBase_h
#define FWCore_Framework_one_EDProducerBase_h
// -*- C++ -*-
//
// Package: FWCore/Framework
// Class : one::EDProducerBase
//
/**\class one::EDProducerBase EDProducerBase.h "FWCore/Framework/interface/one/EDProducerBase.h"
Description: Base class for edm::one::EDProducer<>
Usage:
<usage>
*/
//
// Original Author: Chris Jones
// Created: Thu, 02 May 2013 21:21:21 GMT
//
// system include files
// user include files
#include "FWCore/Framework/interface/ProducerBase.h"
#include "FWCore/Framework/interface/EDConsumerBase.h"
#include "FWCore/Framework/interface/Frameworkfwd.h"
#include "FWCore/Framework/interface/SharedResourcesAcquirer.h"
#include "DataFormats/Provenance/interface/ModuleDescription.h"
#include "DataFormats/Provenance/interface/ParentageID.h"
#include "FWCore/ParameterSet/interface/ParameterSetfwd.h"
#include "FWCore/Concurrency/interface/WaitingTaskHolder.h"
// forward declarations
namespace edm {
class ModuleCallingContext;
class PreallocationConfiguration;
class ActivityRegistry;
class ThinnedAssociationsHelper;
class EventForTransformer;
class ServiceWeakToken;
namespace maker {
template <typename T>
class ModuleHolderT;
}
namespace one {
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;
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;
bool wantsStreamRuns() const noexcept { return false; }
bool wantsStreamLuminosityBlocks() const noexcept { return false; };
virtual SerialTaskQueue* globalRunsQueue();
virtual SerialTaskQueue* globalLuminosityBlocksQueue();
private:
bool doEvent(EventTransitionInfo const&, ActivityRegistry*, ModuleCallingContext const*);
//For now this is a placeholder
/*virtual*/ void preActionBeforeRunEventAsync(WaitingTaskHolder,
ModuleCallingContext const&,
Principal const&) const noexcept {}
void doTransformAsync(WaitingTaskHolder iTask,
size_t iTransformIndex,
EventPrincipal const& iEvent,
ActivityRegistry*,
ModuleCallingContext,
ServiceWeakToken const&) noexcept;
void doPreallocate(PreallocationConfiguration const&);
virtual void preallocRuns(unsigned int);
virtual void preallocLumis(unsigned int);
void doBeginJob();
void doEndJob();
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>"; }
SharedResourcesAcquirer& sharedResourcesAcquirer() { return resourcesAcquirer_; }
virtual void produce(Event&, EventSetup const&) = 0;
virtual void beginJob() {}
virtual void endJob() {}
virtual void preallocThreads(unsigned int) {}
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 doEndRun_(Run const& rp, EventSetup const& c);
virtual void doBeginLuminosityBlock_(LuminosityBlock const& lbp, EventSetup const& c);
virtual void doEndLuminosityBlock_(LuminosityBlock const& lbp, 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; }
bool hasAcquire() const noexcept { return false; }
virtual SharedResourcesAcquirer createAcquirer();
void setModuleDescription(ModuleDescription const& md) { moduleDescription_ = md; }
ModuleDescription moduleDescription_;
std::vector<BranchID> previousParentage_;
ParentageID previousParentageId_;
SharedResourcesAcquirer resourcesAcquirer_;
};
} // namespace one
} // namespace edm
#endif
|