CMS 3D CMS Logo

All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
EDProducerBase.cc
Go to the documentation of this file.
1 // -*- C++ -*-
2 //
3 // Package: FWCore/Framework
4 // Class : limited::EDProducerBase
5 //
6 // Implementation:
7 // [Notes on implementation]
8 //
9 // Original Author: Chris Jones
10 // Created: Thu, 02 May 2013 21:56:04 GMT
11 //
12 
13 // system include files
14 
15 // user include files
23 
26 
27 
28 //
29 // constants, enums and typedefs
30 //
31 namespace edm {
32  namespace limited {
33  //
34  // static data member definitions
35  //
36 
37  //
38  // constructors and destructor
39  //
41  ProducerBase(),
42  moduleDescription_(),
43  previousParentages_(),
44  previousParentageIds_(),
45  queue_(pset.getUntrackedParameter<unsigned int>("concurrencyLimit")){ }
46 
48  {
49  }
50 
51  bool
53  ActivityRegistry* act,
54  ModuleCallingContext const* mcc) {
55  Event e(ep, moduleDescription_, mcc);
56  e.setConsumer(this);
57  const auto streamIndex = e.streamID().value();
58  e.setProducer(this,&previousParentages_[streamIndex]);
59  EventSignalsSentry sentry(act,mcc);
60  this->produce(e.streamID(), e, c);
61  commit_(e, &previousParentageIds_[streamIndex]);
62  return true;
63  }
64 
65  void
67  auto const nStreams = iPrealloc.numberOfStreams();
68  previousParentages_.reset(new std::vector<BranchID>[nStreams]);
69  previousParentageIds_.reset( new ParentageID[nStreams]);
70  preallocStreams(nStreams);
71  preallocate(iPrealloc);
72  }
73 
74  void
76  this->beginJob();
77  }
78 
79  void
81  this->endJob();
82  }
83 
84  void
86  ModuleCallingContext const* mcc) {
87  Run r(rp, moduleDescription_, mcc);
88  r.setConsumer(this);
89  Run const& cnstR = r;
90  this->doBeginRun_(cnstR, c);
91  this->doBeginRunSummary_(cnstR, c);
92  r.setProducer(this);
93  this->doBeginRunProduce_(r,c);
94  commit_(r);
95  }
96 
97  void
99  ModuleCallingContext const* mcc) {
100  Run r(rp, moduleDescription_, mcc);
101  r.setConsumer(this);
102  r.setProducer(this);
103  Run const& cnstR = r;
104  this->doEndRunProduce_(r, c);
105  this->doEndRunSummary_(r,c);
106  this->doEndRun_(cnstR, c);
107  commit_(r);
108  }
109 
110  void
112  ModuleCallingContext const* mcc) {
113  LuminosityBlock lb(lbp, moduleDescription_, mcc);
114  lb.setConsumer(this);
115  LuminosityBlock const& cnstLb = lb;
116  this->doBeginLuminosityBlock_(cnstLb, c);
117  this->doBeginLuminosityBlockSummary_(cnstLb, c);
118  lb.setProducer(this);
119  this->doBeginLuminosityBlockProduce_(lb, c);
120  commit_(lb);
121  }
122 
123  void
125  ModuleCallingContext const* mcc) {
126  LuminosityBlock lb(lbp, moduleDescription_, mcc);
127  lb.setConsumer(this);
128  lb.setProducer(this);
129  LuminosityBlock const& cnstLb = lb;
130  this->doEndLuminosityBlockProduce_(lb, c);
131  this->doEndLuminosityBlockSummary_(cnstLb,c);
132  this->doEndLuminosityBlock_(cnstLb, c);
133  commit_(lb);
134  }
135 
136  void
138  doBeginStream_(id);
139  }
140  void
142  doEndStream_(id);
143  }
144  void
146  RunPrincipal const& rp,
147  EventSetup const& c,
148  ModuleCallingContext const* mcc)
149  {
150  Run r(rp, moduleDescription_, mcc);
151  r.setConsumer(this);
152  this->doStreamBeginRun_(id, r, c);
153  }
154  void
156  RunPrincipal const& rp,
157  EventSetup const& c,
158  ModuleCallingContext const* mcc) {
159  Run r(rp, moduleDescription_, mcc);
160  r.setConsumer(this);
161  this->doStreamEndRun_(id, r, c);
162  this->doStreamEndRunSummary_(id, r, c);
163  }
164  void
166  LuminosityBlockPrincipal const& lbp,
167  EventSetup const& c,
168  ModuleCallingContext const* mcc) {
169  LuminosityBlock lb(lbp, moduleDescription_, mcc);
170  lb.setConsumer(this);
171  this->doStreamBeginLuminosityBlock_(id,lb, c);
172  }
173 
174  void
176  LuminosityBlockPrincipal const& lbp,
177  EventSetup const& c,
178  ModuleCallingContext const* mcc) {
179  LuminosityBlock lb(lbp, moduleDescription_, mcc);
180  lb.setConsumer(this);
181  this->doStreamEndLuminosityBlock_(id,lb, c);
182  this->doStreamEndLuminosityBlockSummary_(id,lb, c);
183  }
184 
185 
186 
187  void
189  //respondToOpenInputFile(fb);
190  }
191 
192  void
194  //respondToCloseInputFile(fb);
195  }
196 
197  void EDProducerBase::preallocStreams(unsigned int) {}
202  void EDProducerBase::doStreamEndRun_(StreamID id, Run const& rp, EventSetup const& c) {}
207 
208 
209  void EDProducerBase::doBeginRun_(Run const& rp, EventSetup const& c) {}
210  void EDProducerBase::doEndRun_(Run const& rp, EventSetup const& c) {}
213 
218 
223 
224  void
227  desc.setUnknown();
228  descriptions.addDefault(desc);
229  }
230 
231  void
233  edmodule_mightGet_config(iConfig);
234  }
235 
236  static const std::string kBaseType("EDProducer");
237 
238  const std::string&
240  return kBaseType;
241  }
242 
243  }
244 }
virtual void produce(StreamID, Event &, EventSetup const &) const =0
void setProducer(ProducerBase const *iProducer)
Definition: Run.cc:79
void setConsumer(EDConsumerBase const *iConsumer)
static void fillDescriptions(ConfigurationDescriptions &descriptions)
virtual void doStreamBeginLuminosityBlock_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
static const std::string & baseType()
virtual void doEndRunSummary_(Run const &rp, EventSetup const &c)
static void prevalidate(ConfigurationDescriptions &descriptions)
virtual void doStreamEndRunSummary_(StreamID id, Run const &rp, EventSetup const &c)
virtual void doEndLuminosityBlock_(LuminosityBlock const &lb, EventSetup const &c)
void setConsumer(EDConsumerBase const *iConsumer)
Definition: Event.cc:42
void doBeginLuminosityBlock(LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)
virtual void doStreamEndRun_(StreamID id, Run const &rp, EventSetup const &c)
virtual void doStreamBeginRun_(StreamID id, Run const &rp, EventSetup const &c)
virtual void doBeginRun_(Run const &rp, EventSetup const &c)
void doStreamBeginLuminosityBlock(StreamID id, LuminosityBlockPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *)
void addDefault(ParameterSetDescription const &psetDescription)
static const std::string kBaseType("EDAnalyzer")
void doBeginStream(StreamID id)
void edmodule_mightGet_config(ConfigurationDescriptions &iDesc)
void doRespondToCloseInputFile(FileBlock const &fb)
virtual void doEndStream_(StreamID id)
void doStreamEndLuminosityBlock(StreamID id, LuminosityBlockPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *)
ModuleDescription moduleDescription_
void doEndRun(RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)
std::unique_ptr< ParentageID[]> previousParentageIds_
virtual void doStreamEndLuminosityBlockSummary_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
void doEndLuminosityBlock(LuminosityBlockPrincipal const &lbp, EventSetup const &c, ModuleCallingContext const *)
unsigned int value() const
Definition: StreamID.h:46
virtual void doBeginLuminosityBlock_(LuminosityBlock const &lbp, EventSetup const &c)
void setProducer(ProducerBase const *iProd, std::vector< BranchID > *previousParentage, std::vector< BranchID > *gotBranchIDsFromAcquire=0)
Definition: Event.cc:66
virtual void doBeginRunSummary_(Run const &rp, EventSetup const &c)
void setProducer(ProducerBase const *iProducer)
virtual void doEndLuminosityBlockSummary_(LuminosityBlock const &lb, EventSetup const &c)
virtual void preallocate(PreallocationConfiguration const &)
virtual void preallocStreams(unsigned int)
EDProducerBase(ParameterSet const &pset)
virtual void doBeginLuminosityBlockProduce_(LuminosityBlock &lbp, EventSetup const &c)
HLT enums.
void doStreamEndRun(StreamID id, RunPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *)
bool doEvent(EventPrincipal const &ep, EventSetup const &c, ActivityRegistry *, ModuleCallingContext const *)
StreamID streamID() const
Definition: Event.h:95
virtual void doStreamEndLuminosityBlock_(StreamID id, LuminosityBlock const &lbp, EventSetup const &c)
virtual void doBeginLuminosityBlockSummary_(LuminosityBlock const &rp, EventSetup const &c)
virtual void doEndLuminosityBlockProduce_(LuminosityBlock &lbp, EventSetup const &c)
void doBeginRun(RunPrincipal const &rp, EventSetup const &c, ModuleCallingContext const *)
virtual void doBeginRunProduce_(Run &rp, EventSetup const &c)
void commit_(P &iPrincipal)
Definition: ProducerBase.h:107
void doPreallocate(PreallocationConfiguration const &)
std::unique_ptr< std::vector< BranchID >[]> previousParentages_
virtual void doBeginStream_(StreamID id)
virtual void doEndRunProduce_(Run &rp, EventSetup const &c)
void setConsumer(EDConsumerBase const *iConsumer)
Definition: Run.h:50
virtual void doEndRun_(Run const &rp, EventSetup const &c)
void doRespondToOpenInputFile(FileBlock const &fb)
void doStreamBeginRun(StreamID id, RunPrincipal const &ep, EventSetup const &c, ModuleCallingContext const *)
Definition: Run.h:43