ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/UserCode/MitProd/TreeFiller/src/FillMitTree.cc
Revision: 1.53
Committed: Sat Dec 12 22:33:52 2009 UTC (15 years, 4 months ago) by bendavid
Content type: text/plain
Branch: MAIN
CVS Tags: Mit_012i, Mit_012h, Mit_012g, Mit_012f, Mit_012e
Changes since 1.52: +13 -1 lines
Log Message:
Add initial hooks for beginRun call

File Contents

# User Rev Content
1 bendavid 1.53 // $Id: FillMitTree.cc,v 1.52 2009/12/08 11:34:28 loizides Exp $
2 paus 1.1
3 loizides 1.3 #include "MitProd/TreeFiller/interface/FillMitTree.h"
4 paus 1.1 #include "FWCore/MessageLogger/interface/MessageLogger.h"
5 loizides 1.32 #include "FWCore/ParameterSet/interface/ParameterSet.h"
6 paus 1.1 #include "FWCore/ServiceRegistry/interface/Service.h"
7 loizides 1.16 #include "MitProd/ObjectService/interface/ObjectService.h"
8 loizides 1.6 #include "MitProd/TreeFiller/interface/AssociationMaps.h"
9 loizides 1.37 #include "MitProd/TreeFiller/interface/FillerBasicClusters.h"
10 bendavid 1.28 #include "MitProd/TreeFiller/interface/FillerBeamSpot.h"
11 loizides 1.37 #include "MitProd/TreeFiller/interface/FillerCaloJets.h"
12     #include "MitProd/TreeFiller/interface/FillerCaloMet.h"
13 bendavid 1.41 #include "MitProd/TreeFiller/interface/FillerCaloTaus.h"
14 sixie 1.20 #include "MitProd/TreeFiller/interface/FillerCaloTowers.h"
15 loizides 1.37 #include "MitProd/TreeFiller/interface/FillerConversions.h"
16     #include "MitProd/TreeFiller/interface/FillerDecayParts.h"
17 loizides 1.6 #include "MitProd/TreeFiller/interface/FillerElectrons.h"
18 loizides 1.52 #include "MitProd/TreeFiller/interface/FillerEvtSelData.h"
19 sixie 1.22 #include "MitProd/TreeFiller/interface/FillerGenJets.h"
20 bendavid 1.44 #include "MitProd/TreeFiller/interface/FillerGenMet.h"
21 loizides 1.37 #include "MitProd/TreeFiller/interface/FillerMCEventInfo.h"
22     #include "MitProd/TreeFiller/interface/FillerMCParticles.h"
23 loizides 1.48 #include "MitProd/TreeFiller/interface/FillerMCVertexes.h"
24 loizides 1.37 #include "MitProd/TreeFiller/interface/FillerMet.h"
25     #include "MitProd/TreeFiller/interface/FillerMetaInfos.h"
26 loizides 1.45 #include "MitProd/TreeFiller/interface/FillerMetaInfos.h"
27 loizides 1.37 #include "MitProd/TreeFiller/interface/FillerMuons.h"
28     #include "MitProd/TreeFiller/interface/FillerPFCandidates.h"
29 bendavid 1.33 #include "MitProd/TreeFiller/interface/FillerPFJets.h"
30 bendavid 1.34 #include "MitProd/TreeFiller/interface/FillerPFMet.h"
31 bendavid 1.41 #include "MitProd/TreeFiller/interface/FillerPFTaus.h"
32 bendavid 1.8 #include "MitProd/TreeFiller/interface/FillerPhotons.h"
33 loizides 1.48 #include "MitProd/TreeFiller/interface/FillerPixelHits.h"
34 paus 1.13 #include "MitProd/TreeFiller/interface/FillerStableParts.h"
35 loizides 1.51 #include "MitProd/TreeFiller/interface/FillerStripHits.h"
36 loizides 1.37 #include "MitProd/TreeFiller/interface/FillerSuperClusters.h"
37     #include "MitProd/TreeFiller/interface/FillerTracks.h"
38     #include "MitProd/TreeFiller/interface/FillerVertexes.h"
39 loizides 1.35 #include "MitAna/DataTree/interface/Names.h"
40     #include "MitAna/DataTree/interface/BranchTable.h"
41 bendavid 1.49 #include "MitCommon/OptIO/interface/OptInt.h"
42 loizides 1.21
43 paus 1.1 using namespace std;
44     using namespace edm;
45     using namespace mithep;
46    
47 loizides 1.16 mithep::ObjectService *mithep::FillMitTree::os_ = 0;
48    
49 loizides 1.9 //--------------------------------------------------------------------------------------------------
50 loizides 1.7 FillMitTree::FillMitTree(const edm::ParameterSet &cfg) :
51 loizides 1.35 defactive_(cfg.getUntrackedParameter<bool>("defactive",1)),
52 loizides 1.40 brtable_(0),
53 bendavid 1.49 acfnumber_(-1),
54     tws_(new TreeWriter(Names::gkEvtTreeName,0))
55 paus 1.1 {
56 loizides 1.6 // Constructor.
57 loizides 1.15
58 loizides 1.3 if (!configure(cfg)) {
59     throw edm::Exception(edm::errors::Configuration, "FillMitTree::FillMitTree()\n")
60     << "Could not configure fillers." << "\n";
61     }
62 paus 1.1 }
63    
64 loizides 1.9 //--------------------------------------------------------------------------------------------------
65 paus 1.1 FillMitTree::~FillMitTree()
66     {
67 loizides 1.35 // Destructor.
68    
69     delete brtable_;
70 bendavid 1.49 delete tws_;
71 paus 1.1 }
72    
73 loizides 1.9 //--------------------------------------------------------------------------------------------------
74 loizides 1.17 bool FillMitTree::addActiveFiller(BaseFiller *bf)
75     {
76     // Check if filler is active and add it to list of fillers. Otherwise delete it.
77    
78 loizides 1.35 if (!bf)
79     return 0;
80    
81 loizides 1.17 if (bf->Active()) {
82     fillers_.push_back(bf);
83     return 1;
84     }
85    
86     delete bf;
87     bf = 0;
88     return 0;
89     }
90    
91     //--------------------------------------------------------------------------------------------------
92 bendavid 1.53 void FillMitTree::beginRun(edm::Run const &run, edm::EventSetup const &setup)
93     {
94     // Access and copy event content.
95    
96     // first step: Loop over the data fillers of the various components
97     for (std::vector<BaseFiller*>::const_iterator iF = fillers_.begin(); iF != fillers_.end(); ++iF) {
98     (*iF)->FillRunBlock(run,setup);
99     }
100    
101     }
102    
103     //--------------------------------------------------------------------------------------------------
104 loizides 1.3 void FillMitTree::analyze(const edm::Event &event,
105     const edm::EventSetup &setup)
106     {
107     // Access and copy event content.
108 bendavid 1.49
109     //tree writer begin event actions
110     tws_->BeginEvent(kTRUE);
111 loizides 1.3
112 loizides 1.32 // first step: Loop over the data fillers of the various components
113 loizides 1.3 for (std::vector<BaseFiller*>::const_iterator iF = fillers_.begin(); iF != fillers_.end(); ++iF) {
114     (*iF)->FillDataBlock(event,setup);
115     }
116    
117 loizides 1.32 // second step: Loop over the link resolution of the various components
118 loizides 1.3 for (std::vector<BaseFiller*>::const_iterator iF = fillers_.begin(); iF != fillers_.end(); ++iF) {
119     (*iF)->ResolveLinks(event,setup);
120     }
121 loizides 1.38
122 loizides 1.40 if (brtable_) { // only the first FillMitTree object has to deal with the branch table
123     if (acfnumber_==-1) {
124     brtable_->Rehash(brtable_->GetSize());
125     if (0)
126     brtable_->Print();
127     }
128     if (acfnumber_ != tws_->GetFileNumber()) {
129     tws_->StoreObject(brtable_);
130     acfnumber_ = tws_->GetFileNumber();
131     }
132     }
133 bendavid 1.49
134     //tree writer end of event actions
135     tws_->EndEvent(kTRUE);
136    
137 loizides 1.3 }
138    
139 loizides 1.9 //--------------------------------------------------------------------------------------------------
140 loizides 1.3 void FillMitTree::beginJob(const edm::EventSetup &event)
141 paus 1.1 {
142 loizides 1.2 // Access the tree and book branches.
143    
144 loizides 1.40 if (os_==0) { // only the first FillMitTree object has to deal with this
145 loizides 1.16 Service<ObjectService> os;
146     if (!os.isAvailable()) {
147     throw edm::Exception(edm::errors::Configuration, "FillMitTree::beginJob()\n")
148 loizides 1.17 << "Could not get object service. "
149     << "Do you have the ObjectService defined in your config?" << "\n";
150 loizides 1.16 return;
151     }
152     os_ = &(*os);
153 loizides 1.40 brtable_ = new BranchTable;
154     brtable_->SetName(Names::gkBranchTable);
155     brtable_->SetOwner();
156 loizides 1.35 os->add(brtable_, brtable_->GetName());
157 loizides 1.16 }
158    
159 loizides 1.32 // loop over the various components and book the branches
160 paus 1.1 for (std::vector<BaseFiller*>::iterator iF = fillers_.begin(); iF != fillers_.end(); ++iF) {
161 loizides 1.16 edm::LogInfo("FillMitTree::beginJob") << "Booking for " << (*iF)->Name() << endl;
162 loizides 1.48 (*iF)->BookDataBlock(*tws_, event);
163 paus 1.1 }
164 loizides 1.46
165     // call branch ref for the event tree
166 loizides 1.47 if (brtable_ && tws_->GetTree())
167     tws_->GetTree()->BranchRef();
168 bendavid 1.49
169 paus 1.1 }
170    
171 loizides 1.9 //--------------------------------------------------------------------------------------------------
172 loizides 1.3 bool FillMitTree::configure(const edm::ParameterSet &cfg)
173 paus 1.1 {
174 bendavid 1.49
175     // Configure TreeWriter
176     const std::string twsConfigName("TreeWriter");
177     ParameterSet twsConfig;
178     if (cfg.existsAs<ParameterSet>(twsConfigName,0))
179     twsConfig = cfg.getUntrackedParameter<ParameterSet>(twsConfigName);
180    
181     configureTreeWriter(twsConfig);
182    
183 loizides 1.36 // Configure our fillers according to given parameter ("fillers").
184 loizides 1.3
185 bendavid 1.33 std::vector<std::string> pars;
186 loizides 1.36 if (cfg.exists("fillers"))
187     pars=cfg.getUntrackedParameter<vector<string> >("fillers");
188 bendavid 1.33 else
189     cfg.getParameterSetNames(pars, false);
190 loizides 1.32
191     // loop over psets
192     for (unsigned int i = 0; i<pars.size(); ++i) {
193    
194     const string name(pars.at(i));
195    
196 loizides 1.37 string ftype("Filler" + name);
197     if (cfg.existsAs<ParameterSet>(name,0)) {
198     ParameterSet next(cfg.getUntrackedParameter<ParameterSet>(name));
199     if (!next.exists("fillerType")) {
200 loizides 1.42 edm::LogError("FillMitTree") << "Cannot determine fillerType for pset named "
201 loizides 1.37 << name << std::endl;
202     throw edm::Exception(edm::errors::Configuration, "FillMitTree::configure\n")
203 loizides 1.42 << "Cannot determine fillerType for pset named "
204 loizides 1.37 << name << std::endl;
205     }
206     ftype = next.getUntrackedParameter<string>("fillerType");
207 loizides 1.32 }
208 loizides 1.2
209 loizides 1.37 edm::LogInfo("FillMitTree") << "Attempting to configure '" << ftype
210     << "' for '" << name << "'" << std::endl;
211 loizides 1.35
212 loizides 1.32 if (ftype.compare("FillerMetaInfos")==0) {
213     FillerMetaInfos *fillerMetaInfos = new FillerMetaInfos(cfg, name.c_str(), defactive_);
214     addActiveFiller(fillerMetaInfos);
215     continue;
216     }
217 loizides 1.37
218 loizides 1.32 if (ftype.compare("FillerMCParticles")==0) {
219     FillerMCParticles *fillerMCParticles = new FillerMCParticles(cfg, name.c_str(), defactive_);
220     addActiveFiller(fillerMCParticles);
221     continue;
222     }
223 loizides 1.37
224     if (ftype.compare("FillerMCEventInfo")==0) {
225     FillerMCEventInfo *fillerMCEventInfo = new FillerMCEventInfo(cfg, name.c_str(), defactive_);
226     addActiveFiller(fillerMCEventInfo);
227     continue;
228     }
229    
230 loizides 1.48 if (ftype.compare("FillerMCVertexes")==0) {
231     FillerMCVertexes *fillerMCVertexes = new FillerMCVertexes(cfg, name.c_str(), defactive_);
232     addActiveFiller(fillerMCVertexes);
233     continue;
234     }
235    
236 loizides 1.52 if (ftype.compare("FillerEvtSelData")==0) {
237     FillerEvtSelData *fillerEvtSelData = new FillerEvtSelData(cfg, name.c_str(), defactive_);
238     addActiveFiller(fillerEvtSelData);
239     continue;
240     }
241    
242 loizides 1.32 if (ftype.compare("FillerBeamSpot")==0) {
243     FillerBeamSpot *fillerBeamSpot = new FillerBeamSpot(cfg, name.c_str(), defactive_);
244     addActiveFiller(fillerBeamSpot);
245     continue;
246     }
247 loizides 1.52
248 loizides 1.32 if (ftype.compare("FillerVertexes")==0) {
249     FillerVertexes *fillerVertexes = new FillerVertexes(cfg, name.c_str(), defactive_);
250     addActiveFiller(fillerVertexes);
251     continue;
252     }
253    
254     if (ftype.compare("FillerCaloTowers")==0) {
255     FillerCaloTowers *fillerCaloTowers = new FillerCaloTowers(cfg, name.c_str(), defactive_);
256     addActiveFiller(fillerCaloTowers);
257     continue;
258     }
259    
260     if (ftype.compare("FillerGenJets")==0) {
261     FillerGenJets *fillerGenJets = new FillerGenJets(cfg, name.c_str(), defactive_);
262     addActiveFiller(fillerGenJets);
263     continue;
264     }
265    
266     if (ftype.compare("FillerCaloJets")==0) {
267     FillerCaloJets *fillerCaloJets = new FillerCaloJets(cfg, name.c_str(), defactive_);
268     addActiveFiller(fillerCaloJets);
269     continue;
270     }
271 bendavid 1.34
272     if (ftype.compare("FillerMet")==0) {
273     FillerMet *fillerMet = new FillerMet(cfg, name.c_str(), defactive_);
274     addActiveFiller(fillerMet);
275     continue;
276     }
277 bendavid 1.44
278     if (ftype.compare("FillerGenMet")==0) {
279     FillerGenMet *fillerGenMet = new FillerGenMet(cfg, name.c_str(), defactive_);
280     addActiveFiller(fillerGenMet);
281     continue;
282     }
283 bendavid 1.34
284 loizides 1.32 if (ftype.compare("FillerCaloMet")==0) {
285     FillerCaloMet *fillerCaloMet = new FillerCaloMet(cfg, name.c_str(), defactive_);
286     addActiveFiller(fillerCaloMet);
287     continue;
288 bendavid 1.34 }
289    
290     if (ftype.compare("FillerPFMet")==0) {
291     FillerPFMet *fillerPFMet = new FillerPFMet(cfg, name.c_str(), defactive_);
292     addActiveFiller(fillerPFMet);
293     continue;
294 loizides 1.32 }
295    
296     if (ftype.compare("FillerBasicClusters")==0) {
297     FillerBasicClusters *fillerBasicClusters =
298     new FillerBasicClusters(cfg, name.c_str(), defactive_);
299     addActiveFiller(fillerBasicClusters);
300     continue;
301     }
302    
303     if (ftype.compare("FillerSuperClusters")==0) {
304     FillerSuperClusters *fillerSuperClusters =
305     new FillerSuperClusters(cfg, name.c_str(), defactive_);
306     addActiveFiller(fillerSuperClusters);
307     continue;
308     }
309    
310 loizides 1.48 if (ftype.compare("FillerPixelHits")==0) {
311     FillerPixelHits *fillerPixelHits =
312     new FillerPixelHits(cfg, name.c_str(), defactive_);
313     addActiveFiller(fillerPixelHits);
314     continue;
315     }
316    
317 loizides 1.51 if (ftype.compare("FillerStripHits")==0) {
318     FillerStripHits *fillerStripHits =
319     new FillerStripHits(cfg, name.c_str(), defactive_);
320     addActiveFiller(fillerStripHits);
321     continue;
322     }
323    
324 loizides 1.32 if (ftype.compare("FillerTracks")==0) {
325     FillerTracks *fillerTracks = new FillerTracks(cfg, name.c_str(), defactive_);
326     addActiveFiller(fillerTracks);
327     continue;
328     }
329    
330     if (ftype.compare("FillerMuons")==0) {
331     FillerMuons *fillerMuons = new FillerMuons(cfg, name.c_str(), defactive_);
332     addActiveFiller(fillerMuons);
333     continue;
334     }
335    
336     if (ftype.compare("FillerElectrons")==0) {
337     FillerElectrons *fillerElectrons = new FillerElectrons(cfg, name.c_str(), defactive_);
338     addActiveFiller(fillerElectrons);
339     continue;
340     }
341    
342     if (ftype.compare("FillerConversions")==0) {
343     FillerConversions *fillerConversions = new FillerConversions(cfg, name.c_str(), defactive_);
344     addActiveFiller(fillerConversions);
345     continue;
346     }
347    
348     if (ftype.compare("FillerPhotons")==0) {
349     FillerPhotons *fillerPhotons = new FillerPhotons(cfg, name.c_str(), defactive_);
350     addActiveFiller(fillerPhotons);
351     continue;
352     }
353    
354     if (ftype.compare("FillerStableParts")==0) {
355     FillerStableParts *fillerStableParts = new FillerStableParts(cfg, name.c_str(), defactive_);
356     addActiveFiller(fillerStableParts);
357     continue;
358     }
359    
360     if (ftype.compare("FillerDecayParts")==0) {
361     FillerDecayParts *fillerDecayParts = new FillerDecayParts(cfg, name.c_str(), defactive_);
362     addActiveFiller(fillerDecayParts);
363     continue;
364     }
365 bendavid 1.33
366     if (ftype.compare("FillerPFCandidates")==0) {
367 loizides 1.35 FillerPFCandidates *fillerPFCands = new FillerPFCandidates(cfg, name.c_str(), defactive_);
368     addActiveFiller(fillerPFCands);
369 bendavid 1.33 continue;
370     }
371 loizides 1.32
372 bendavid 1.33 if (ftype.compare("FillerPFJets")==0) {
373     FillerPFJets *fillerPFJets = new FillerPFJets(cfg, name.c_str(), defactive_);
374     addActiveFiller(fillerPFJets);
375     continue;
376     }
377 bendavid 1.41
378     if (ftype.compare("FillerCaloTaus")==0) {
379     FillerCaloTaus *fillerCaloTaus = new FillerCaloTaus(cfg, name.c_str(), defactive_);
380     addActiveFiller(fillerCaloTaus);
381     continue;
382     }
383    
384     if (ftype.compare("FillerPFTaus")==0) {
385     FillerPFTaus *fillerPFTaus = new FillerPFTaus(cfg, name.c_str(), defactive_);
386     addActiveFiller(fillerPFTaus);
387     continue;
388     }
389 bendavid 1.33
390 loizides 1.32 edm::LogError("FillMitTree")
391     << "Unknown fillerType " << ftype << " for pset named " << name << std::endl;
392     throw edm::Exception(edm::errors::Configuration, "FillMitTree::configure\n")
393     << "Unknown fillerType " << ftype << " for pset named " << name << std::endl;
394     }
395 paus 1.13
396 loizides 1.3 return 1;
397 paus 1.1 }
398    
399 loizides 1.9 //--------------------------------------------------------------------------------------------------
400 bendavid 1.49 bool FillMitTree::configureTreeWriter(const edm::ParameterSet &cfg)
401     {
402 loizides 1.50 // Configure tree writer with options from config file.
403 bendavid 1.49
404     tws_->SetPrefix(cfg.getUntrackedParameter<string>("fileName","mit-test"));
405     tws_->SetBaseURL(cfg.getUntrackedParameter<string>("pathName","."));
406     tws_->SetMaxSize((Long64_t)cfg.getUntrackedParameter<unsigned>("maxSize",1024)*1024*1024);
407     tws_->SetCompressLevel(cfg.getUntrackedParameter<unsigned>("compLevel",9));
408     tws_->SetDefaultSL(cfg.getUntrackedParameter<unsigned>("splitLevel",99));
409     tws_->SetDefaultBrSize(cfg.getUntrackedParameter<unsigned>("brSize",16*1024));
410    
411     if (OptInt::IsActivated()) {
412     OptInt::SetZipMode(cfg.getUntrackedParameter<unsigned>("zipMode",99));
413     OptInt::SetGzipFraction(cfg.getUntrackedParameter<double>("gZipThres",1.0));
414     OptInt::SetBzipFraction(cfg.getUntrackedParameter<double>("bZipThres",-1.0));
415     OptInt::SetLzoFraction(cfg.getUntrackedParameter<double>("lzoThres",-1.0));
416     OptInt::SetLzmaFraction(cfg.getUntrackedParameter<double>("lzmaThres",0.95));
417     OptInt::SetVerbose(cfg.getUntrackedParameter<unsigned>("optIOVerbose",0));
418    
419     } else {
420    
421     if (cfg.exists("zipMode") || cfg.exists("bZipThres") ||
422     cfg.exists("gZipThres") || cfg.exists("lzoThres") ||
423     cfg.exists("lzmaThres")) {
424 loizides 1.50 edm::LogError("FillMitTree") <<
425     "OptIO interface not properly pre-loaded, ignoring given settings." << std::endl;
426 bendavid 1.49 }
427     }
428    
429     return 1;
430     }
431    
432     //--------------------------------------------------------------------------------------------------
433 paus 1.1 void FillMitTree::endJob()
434     {
435 loizides 1.2 // Delete fillers.
436    
437     for (std::vector<BaseFiller*>::iterator iF = fillers_.begin(); iF != fillers_.end(); ++iF) {
438     delete *iF;
439     }
440    
441 bendavid 1.49 tws_->Clear();
442    
443 paus 1.1 edm::LogInfo("FillMitTree::endJob") << "Ending Job" << endl;
444     }