/[PAMELA software]/DarthVader/ToFLevel2/src/ToFCore.cpp
ViewVC logotype

Contents of /DarthVader/ToFLevel2/src/ToFCore.cpp

Parent Directory Parent Directory | Revision Log Revision Log


Revision 1.26 - (show annotations) (download)
Fri Sep 7 21:14:20 2007 UTC (17 years, 5 months ago) by mocchiut
Branch: MAIN
Changes since 1.25: +9 -4 lines
Close MySQL connection before start the main loop in core routines

1 //
2 // C/C++ headers
3 //
4 #include <fstream>
5 #include <string.h>
6 //
7 // ROOT headers
8 //
9 #include <TTree.h>
10 #include <TClassEdit.h>
11 #include <TObject.h>
12 #include <TList.h>
13 #include <TArrayI.h>
14 #include <TSystem.h>
15 #include <TSystemDirectory.h>
16 #include <TString.h>
17 #include <TFile.h>
18 #include <TClass.h>
19 #include <TCanvas.h>
20 #include <TH1.h>
21 #include <TH1F.h>
22 #include <TH2D.h>
23 #include <TLatex.h>
24 #include <TPad.h>
25 #include <TSQLServer.h>
26 #include <TSQLRow.h>
27 #include <TSQLResult.h>
28 #include <TClonesArray.h>
29 //
30 // RunInfo header
31 //
32 #include <RunInfo.h>
33 //
34 // YODA headers
35 //
36 #include <PamelaRun.h>
37 #include <physics/trigger/TriggerEvent.h>
38 #include <physics/tof/TofEvent.h>
39 //
40 // This program headers
41 //
42 #include <ToFCore.h>
43 #include <ToFLevel2.h>
44 #include <ToFVerl2.h>
45 //
46 //
47 // Declaration of the core fortran routines
48 //
49 #define tofl2com tofl2com_
50 extern "C" int tofl2com();
51 #define toftrk toftrk_
52 extern "C" int toftrk();
53 #define rdtofcal rdtofcal_
54 extern "C" int rdtofcal(char [], int *);
55
56 //
57 // Tracker classes headers and definitions
58 //
59 #include <TrkLevel2.h>
60 //
61 using namespace std;
62 //
63 //
64 // CORE ROUTINE
65 //
66 //
67 int ToFCore(UInt_t run, TFile *file, TSQLServer *dbc, Int_t ToFargc, char *ToFargv[]){
68 //
69 //
70 // Set these to true to have a very verbose output.
71 //
72 Bool_t verbose = false;
73 Bool_t debug = false;
74 //
75 TString processFolder = Form("ToFFolder_%u",run);
76 if ( ToFargc > 0 ){
77 Int_t i = 0;
78 while ( i < ToFargc ){
79 if ( !strcmp(ToFargv[i],"-processFolder") ) {
80 if ( ToFargc < i+1 ){
81 throw -3;
82 };
83 processFolder = (TString)ToFargv[i+1];
84 i++;
85 };
86 if ( !strcmp(ToFargv[i],"-v") || !strcmp(ToFargv[i],"--verbose") ) {
87 verbose = true;
88 };
89 if ( !strcmp(ToFargv[i],"-g") || !strcmp(ToFargv[i],"--debug") ) {
90 verbose = true;
91 debug = true;
92 };
93 i++;
94 };
95 };
96 //
97 //
98 // Output directory is the working directoy.
99 //
100 const char* outdir = gSystem->DirName(gSystem->DirName(file->GetPath()));
101 //
102 // Variables for level2
103 //
104 TTree *tracker = 0;
105 TTree *toft = 0;
106 UInt_t nevents = 0;
107 Long64_t maxsize = 10000000000LL;
108 TTree::SetMaxTreeSize(maxsize);
109 //
110 // variables needed to reprocess data
111 //
112 TString tofversion;
113 ItoRunInfo *runinfo = 0;
114 TArrayI *runlist = 0;
115 TTree *toftclone = 0;
116 Bool_t reproc = false;
117 Bool_t reprocall = false;
118 UInt_t nobefrun = 0;
119 UInt_t noaftrun = 0;
120 UInt_t numbofrun = 0;
121 stringstream ftmpname;
122 TString fname;
123 UInt_t totfileentries = 0;
124 UInt_t idRun = 0;
125 //
126 // variables needed to handle error signals
127 //
128 Int_t code = 0;
129 Int_t sgnl;
130 //
131 // tof level2 classes
132 //
133 ToFLevel2 *tof = new ToFLevel2();
134 ToFLevel2 *tofclone = new ToFLevel2();
135 //
136 // tracker level2 variables
137 //
138 TrkLevel2 *trk = new TrkLevel2();
139 Int_t nevtrkl2 = 0;
140 //
141 // define variables for opening and reading level0 file
142 //
143 TFile *l0File = 0;
144 TTree *l0tr = 0;
145 TBranch *l0head = 0;
146 TBranch *l0trig = 0;
147 TBranch *l0tof = 0;
148 pamela::EventHeader *eh = 0;
149 pamela::PscuHeader *ph = 0;
150 pamela::trigger::TriggerEvent *trig = 0;
151 pamela::tof::TofEvent *tofEvent = 0;
152 //
153 // Define other basic variables
154 //
155 UInt_t procev = 0;
156 stringstream file2;
157 stringstream file3;
158 stringstream qy;
159 Int_t itr = -1;
160 Int_t totevent = 0;
161 UInt_t atime = 0;
162 UInt_t re = 0;
163 UInt_t jumped = 0;
164 //
165 // Working filename
166 //
167 TString outputfile;
168 stringstream name;
169 name.str("");
170 name << outdir << "/";
171 //
172 // temporary file and folder
173 //
174 TFile *tempfile = 0;
175 TTree *temptof = 0;
176 stringstream tempname;
177 stringstream toffolder;
178 Bool_t myfold = false;
179 tempname.str("");
180 tempname << outdir;
181 tempname << "/" << processFolder.Data();
182 toffolder.str("");
183 toffolder << tempname.str().c_str();
184 tempname << "/toftree_run";
185 tempname << run << ".root";
186 //
187 // variables needed to load magnetic field maps
188 //
189 Int_t ntrkentry = 0;
190 Int_t npmtentry = 0;
191 UInt_t tttrkpar1 = 0;
192 Bool_t trkpar1 = true;
193 UInt_t tttofpar1 = 0;
194 Bool_t tofpar1 = true;
195 //
196 // DB classes
197 //
198 GL_ROOT *glroot = new GL_ROOT();
199 GL_PARAM *glparam = new GL_PARAM();
200 GL_TIMESYNC *dbtime = 0;
201 //
202 // declaring external output and input structures
203 //
204 extern struct ToFInput tofinput_;
205 extern struct ToFOutput tofoutput_;
206 //
207 // Let's start!
208 //
209 //
210 // As a first thing we must check what we have to do: if run = 0 we must process all events in the file has been passed
211 // if run != 0 we must process only that run but first we have to check if the tree ToF already exist in the file
212 // if it exists we are reprocessing data and we must delete that entries, if not we must create it.
213 //
214 if ( run == 0 ) reproc = true;
215 //
216 //
217 // Output file is "outputfile"
218 //
219 if ( !file->IsOpen() ){
220 if ( verbose ) printf(" ToF - ERROR: cannot open file for writing\n");
221 throw -301;
222 };
223 //
224 // Does it contain the Tracker tree?
225 //
226 tracker = (TTree*)file->Get("Tracker");
227 if ( !tracker ) {
228 if ( verbose ) printf(" TOF - ERROR: no tracker tree\n");
229 code = -302;
230 goto closeandexit;
231 };
232 //
233 // get tracker level2 data pointer
234 //
235 tracker->SetBranchAddress("TrkLevel2",&trk);
236 nevtrkl2 = tracker->GetEntries();
237 //
238 // Retrieve GL_RUN variables from the level2 file
239 //
240 tofversion = ToFInfo(false); // we should decide how to handle versioning system
241 //
242 // create an interface to RunInfo called "runinfo"
243 //
244 // ItoRunInfo= interface with RunInfo and GL_RUN
245 runinfo = new ItoRunInfo(file);
246 //
247 // open "Run" tree in level2 file, if not existing return an error (sngl != 0)
248 //
249 sgnl = 0;
250 sgnl = runinfo->Update(run, "TOF",tofversion);
251 if ( sgnl ){
252 if ( verbose ) printf(" TOF - ERROR: RunInfo exited with non-zero status\n");
253 code = sgnl;
254 goto closeandexit;
255 } else {
256 sgnl = 0;
257 };
258 //
259 // number of events in the file BEFORE the first event of our run
260 //
261 nobefrun = runinfo->GetFirstEntry();
262 //
263 // total number of events in the file
264 //
265 totfileentries = runinfo->GetFileEntries();
266 //
267 // first file entry AFTER the last event of our run
268 //
269 noaftrun = runinfo->GetLastEntry() + 1;
270 //
271 // number of run to be processed
272 //
273 numbofrun = runinfo->GetNoRun();
274 UInt_t totnorun = runinfo->GetRunEntries();
275 //
276 // Try to access the ToF tree in the file, if it exists we are reprocessing data if not we are processing a new run
277 //
278 toftclone = (TTree*)file->Get("ToF");
279 //
280 if ( !toftclone ){
281 //
282 // tree does not exist, we are not reprocessing
283 //
284 reproc = false;
285 if ( run == 0 && verbose ) printf(" ToF - WARNING: you are reprocessing data but ToF tree does not exist!\n");
286 if ( runinfo->IsReprocessing() && run != 0 && verbose ) printf(" ToF - WARNING: it seems you are not reprocessing data but ToF\n versioning information already exists in RunInfo.\n");
287
288 } else {
289 //
290 // tree exists, we are reprocessing data. Are we reprocessing a single run or all the file?
291 //
292 toftclone->SetAutoSave(900000000000000LL);
293 reproc = true;
294 //
295 // update versioning information
296 //
297 if ( verbose ) printf("\n Preparing the pre-processing...\n");
298 //
299 if ( run == 0 || totnorun == 1 ){
300 //
301 // we are reprocessing all the file
302 // if we are reprocessing everything we don't need to copy any old event and we can just work with the new tree and delete the old one immediately
303 //
304 reprocall = true;
305 //
306 if ( verbose ) printf("\n ToF - WARNING: Reprocessing all runs\n");
307 //
308 } else {
309 //
310 // we are reprocessing a single run, we must copy to the new tree the events in the file which preceed the first event of the run
311 //
312 reprocall = false;
313 //
314 if ( verbose ) printf("\n ToF - WARNING: Reprocessing run number %u \n",run);
315 //
316 // copying old tree to a new file
317 //
318 gSystem->MakeDirectory(toffolder.str().c_str());
319 myfold = true;
320 tempfile = new TFile(tempname.str().c_str(),"RECREATE");
321 temptof = toftclone->CloneTree(-1,"fast");
322 temptof->SetName("ToF-old");
323 tempfile->Write();
324 tempfile->Close();
325 }
326 //
327 // Delete the old tree from old file and memory
328 //
329 toftclone->Delete("all");
330 //
331 if ( verbose ) printf(" ...done!\n");
332 //
333 };
334 //
335 // create ToF detector tree toft
336 //
337 file->cd();
338 toft = new TTree("ToF-new","PAMELA Level2 ToF data");
339 toft->SetAutoSave(900000000000000LL);
340 tof->Set();//ELENA **TEMPORANEO?**
341 toft->Branch("ToFLevel2","ToFLevel2",&tof);
342 //
343 if ( reproc && !reprocall ){
344 //
345 // open new file and retrieve all tree informations
346 //
347 tempfile = new TFile(tempname.str().c_str(),"READ");
348 toftclone = (TTree*)tempfile->Get("ToF-old");
349 toftclone->SetAutoSave(900000000000000LL);
350 toftclone->SetBranchAddress("ToFLevel2",&tofclone);
351 //
352 if ( nobefrun > 0 ){
353 if ( verbose ) printf("\n Pre-processing: copying events from the old tree before the processed run\n");
354 if ( verbose ) printf(" Copying %u events in the file which are before the beginning of the run %u \n",nobefrun,run);
355 if ( verbose ) printf(" Start copying at event number 0, end copying at event number %u \n",nobefrun);
356 for (UInt_t j = 0; j < nobefrun; j++){
357 //
358 toftclone->GetEntry(j);
359 //
360 // copy tofclone to tof
361 //
362 tof->Clear();
363 memcpy(&tof,&tofclone,sizeof(tofclone));
364 //
365 // Fill entry in the new tree
366 //
367 toft->Fill();
368 //
369 };
370 if ( verbose ) printf(" Finished successful copying!\n");
371 };
372 };
373 //
374 // Get the list of run to be processed, if only one run has to be processed the list will contain one entry only.
375 //
376 runlist = runinfo->GetRunList();
377 //
378 // Loop over the run to be processed
379 //
380 for (UInt_t irun=0; irun < numbofrun; irun++){
381 //
382 // retrieve the first run ID to be processed using the RunInfo list
383 //
384 idRun = runlist->At(irun);
385 if ( verbose ) printf("\n\n\n ####################################################################### \n");
386 if ( verbose ) printf(" PROCESSING RUN NUMBER %u \n",idRun);
387 if ( verbose ) printf(" ####################################################################### \n\n\n");
388 //
389 runinfo->ID_ROOT_L0 = 0;
390 //
391 // store in the runinfo class the GL_RUN variables for our run
392 //
393 sgnl = 0;
394 sgnl = runinfo->GetRunInfo(idRun);
395 if ( sgnl ){
396 if ( verbose ) printf(" TOF - ERROR: RunInfo exited with non-zero status\n");
397 code = sgnl;
398 goto closeandexit;
399 } else {
400 sgnl = 0;
401 };
402 //
403 // now you can access that variables using the RunInfo class this way runinfo->ID_ROOT_L0
404 //
405 if ( runinfo->ID_ROOT_L0 == 0 ){
406 if ( verbose ) printf("\n TOF - ERROR: no run with ID_RUN = %u \n\n Exiting... \n\n",idRun);
407 code = -5;
408 goto closeandexit;
409 };
410 //
411 // prepare the timesync for the db
412 //
413 // if ( !dbc->IsConnected() ) throw -314;
414 dbtime = new GL_TIMESYNC(runinfo->ID_ROOT_L0,"ID",dbc);
415 //
416 // Search in the DB the path and name of the LEVEL0 file to be processed.
417 //
418 // if ( !dbc->IsConnected() ) throw -314;
419 glroot->Query_GL_ROOT(runinfo->ID_ROOT_L0,dbc);
420 //
421 ftmpname.str("");
422 ftmpname << glroot->PATH.Data() << "/";
423 ftmpname << glroot->NAME.Data();
424 fname = ftmpname.str().c_str();
425 //
426 // print out informations
427 //
428 totevent = runinfo->NEVENTS;
429 if ( verbose ) printf("\n LEVEL0 data file: %s \n",fname.Data());
430 if ( verbose ) printf(" RUN HEADER absolute time is: %u \n",runinfo->RUNHEADER_TIME);
431 if ( verbose ) printf(" RUN TRAILER absolute time is: %u \n",runinfo->RUNTRAILER_TIME);
432 if ( verbose ) printf(" %i events to be processed for run %u: from %i to %i \n\n",totevent,idRun,runinfo->EV_FROM,runinfo->EV_FROM+totevent);
433 //
434 // Open Level0 file
435 //
436 l0File = new TFile(fname.Data());
437 if ( !l0File ) {
438 if ( verbose ) printf(" TOF - ERROR: problems opening Level0 file\n");
439 code = -6;
440 goto closeandexit;
441 };
442 l0tr = (TTree*)l0File->Get("Physics");
443 if ( !l0tr ) {
444 if ( verbose ) printf(" TOF - ERROR: no Physics tree in Level0 file\n");
445 l0File->Close();
446 code = -7;
447 goto closeandexit;
448 };
449 l0head = l0tr->GetBranch("Header");
450 if ( !l0head ) {
451 if ( verbose ) printf(" TOF - ERROR: no Header branch in Level0 tree\n");
452 l0File->Close();
453 code = -8;
454 goto closeandexit;
455 };
456 l0trig = l0tr->GetBranch("Trigger");
457 if ( !l0trig ) {
458 if ( verbose ) printf(" TOF - ERROR: no Trigger branch in Level0 tree\n");
459 l0File->Close();
460 code = -300;
461 goto closeandexit;
462 };
463 l0tof = l0tr->GetBranch("Tof");
464 if ( !l0tof ) {
465 if ( verbose ) printf(" TOF - ERROR: no ToF branch in Level0 tree\n");
466 l0File->Close();
467 code = -303;
468 goto closeandexit;
469 };
470 //
471 l0tr->SetBranchAddress("Trigger", &trig);
472 l0tr->SetBranchAddress("Tof", &tofEvent);
473 l0tr->SetBranchAddress("Header", &eh);
474 //
475 nevents = l0tof->GetEntries();
476 //
477 if ( nevents < 1 ) {
478 if ( verbose ) printf(" TOF - ERROR: Level0 file is empty\n\n");
479 l0File->Close();
480 code = -11;
481 goto closeandexit;
482 };
483 //
484 if ( runinfo->EV_TO > nevents-1 ) {
485 if ( verbose ) printf(" TOF - ERROR: too few entries in the registry tree\n");
486 l0File->Close();
487 code = -12;
488 goto closeandexit;
489 };
490 //
491 // Check if we have to load parameter files (or calibration associated to runs and not to events)
492 //
493 // for example let's assume that we could have different magnetic field maps for different runs:
494 //
495 if ( trkpar1 || ( tttrkpar1 != 0 && tttrkpar1 < runinfo->RUNHEADER_TIME ) ){
496 trkpar1 = false;
497 // read from DB infos about Magnetic filed maps
498 // if ( !dbc->IsConnected() ) throw -314;
499 glparam->Query_GL_PARAM(runinfo->RUNHEADER_TIME,1,dbc); // parameters stored in DB in GL_PRAM table
500 tttrkpar1 = glparam->TO_TIME;
501 // ----------------------------
502 // Read the magnetic field
503 // ----------------------------
504 if ( verbose ) printf(" Reading magnetic field maps: \n");
505 trk->LoadField(glparam->PATH+glparam->NAME);
506 if ( verbose ) printf("\n");
507 };
508 //
509 // variable to save information about the tof calibration used
510 //
511 Bool_t defcal = true;
512 //
513 if ( tofpar1 || ( tttofpar1 != 0 && tttofpar1 < runinfo->RUNHEADER_TIME ) ){
514 tofpar1 = false;
515 //
516 // if ( !dbc->IsConnected() ) throw -314;
517 Int_t error=glparam->Query_GL_PARAM(runinfo->RUNHEADER_TIME,201,dbc); // parameters stored in DB in GL_PRAM table
518 if ( error<0 ) {
519 code = error;
520 goto closeandexit;
521 };
522 //
523 if ( verbose ) printf(" Reading ToF parameter file: %s \n",(glparam->PATH+glparam->NAME).Data());
524 //
525 if ( (UInt_t)glparam->TO_TIME != (UInt_t)4294967295UL ) defcal = false;
526 //
527 tttofpar1 = glparam->TO_TIME;
528 Int_t nlen = (Int_t)(glparam->PATH+glparam->NAME).Length();
529 rdtofcal((char *)(glparam->PATH+glparam->NAME).Data(),&nlen);
530 //
531 };
532 //
533 // run over all the events of the run
534 //
535 if ( verbose ) printf("\n Ready to start! \n\n Processed events: \n\n");
536 //
537 if ( dbc ){
538 dbc->Close();
539 // delete dbc;
540 };
541 //
542 jumped = 0;
543 //
544 for ( re = runinfo->EV_FROM; re < (runinfo->EV_FROM+runinfo->NEVENTS); re++){
545 //
546 if ( procev%1000 == 0 && procev > 0 && verbose ) printf(" %iK \n",procev/1000);
547 //
548 l0head->GetEntry(re);
549 //
550 // absolute time of this event
551 //
552 ph = eh->GetPscuHeader();
553 atime = dbtime->DBabsTime(ph->GetOrbitalTime());
554 //
555 tof->Clear();
556 Int_t pmt_id = 0;
557 ToFPMT *t_pmt = new ToFPMT();
558 if(!(tof->PMT))tof->PMT = new TClonesArray("ToFPMT",12); //ELENA
559 TClonesArray &tpmt = *tof->PMT;
560 ToFTrkVar *t_tof = new ToFTrkVar();
561 if(!(tof->ToFTrk))tof->ToFTrk = new TClonesArray("ToFTrkVar",2); //ELENA
562 TClonesArray &t = *tof->ToFTrk;
563 //
564 // paranoid check
565 //
566 if ( atime > runinfo->RUNTRAILER_TIME || atime < runinfo->RUNHEADER_TIME ) {
567 if ( verbose ) printf(" TOF - WARNING: event at time outside the run time window, skipping it\n");
568 jumped++;
569 goto jumpev;
570 };
571 //
572 // retrieve tracker informations, the LEVEL2 entry which correspond to our event will be "itr"
573 //
574 if ( !reprocall ){
575 itr = nobefrun + (re - runinfo->EV_FROM -jumped);
576 } else {
577 itr = runinfo->GetFirstEntry() + (re - runinfo->EV_FROM -jumped);
578 };
579 if ( itr > nevtrkl2 ){ // nevtrkl2 tracker entry number
580 if ( verbose ) printf(" TOF - ERROR: no tracker events with entry = %i in Level2 file\n",itr);
581 l0File->Close();
582 code = -313;
583 goto closeandexit;
584 };
585 //
586 trk->Clear();
587 //
588 tracker->GetEntry(itr);
589 ///
590 //
591 l0tof->GetEntry(re);
592 l0trig->GetEntry(re);
593 ///
594 //
595 procev++;
596 //
597 // start processing
598 //
599 //
600 // Here we will use some procedure to calibrate our data and put some kind of informations in the cinput structure
601
602 for (Int_t gg=0; gg<4;gg++){
603 for (Int_t hh=0; hh<12;hh++){
604 tofinput_.tdc[hh][gg]=tofEvent->tdc[gg][hh];
605 tofinput_.adc[hh][gg]=tofEvent->adc[gg][hh];
606 };
607 };
608
609 for (Int_t hh=0; hh<5;hh++){
610 tofinput_.patterntrig[hh]=trig->patterntrig[hh];
611 };
612 //
613 // Here we have calibrated data, ready to be passed to the FORTRAN routine which will extract common and track-related variables.
614 //
615 npmtentry = 0;
616 //
617 ntrkentry = 0;
618 //
619 // Calculate tracks informations from ToF alone
620 //
621 tofl2com();
622 //
623 memcpy(tof->tof_j_flag,tofoutput_.tof_j_flag,6*sizeof(Int_t));
624 //
625 t_tof->trkseqno = -1;
626 //
627 // and now we must copy from the output structure to the level2 class:
628 //
629 t_tof->npmttdc = 0;
630 //
631 for (Int_t hh=0; hh<12;hh++){
632 for (Int_t kk=0; kk<4;kk++){
633 if ( tofoutput_.tofmask[hh][kk] != 0 ){
634 pmt_id = tof->GetPMTid(kk,hh);
635 t_tof->pmttdc.AddAt(pmt_id,t_tof->npmttdc);
636 t_tof->tdcflag.AddAt(tofoutput_.tdcflagtof[hh][kk],t_tof->npmttdc); // gf: Jan 09/07
637 t_tof->npmttdc++;
638 };
639 };
640 };
641 for (Int_t kk=0; kk<13;kk++){
642 t_tof->beta[kk] = tofoutput_.betatof_a[kk];
643 }
644 //
645 t_tof->npmtadc = 0;
646 for (Int_t hh=0; hh<12;hh++){
647 for (Int_t kk=0; kk<4;kk++){
648 if ( tofoutput_.adctof_c[hh][kk] < 1000 ){
649 t_tof->dedx.AddAt(tofoutput_.adctof_c[hh][kk],t_tof->npmtadc);
650 pmt_id = tof->GetPMTid(kk,hh);
651 t_tof->pmtadc.AddAt(pmt_id,t_tof->npmtadc);
652 t_tof->adcflag.AddAt(tofoutput_.adcflagtof[hh][kk],t_tof->npmtadc); // gf: Jan 09/07
653 t_tof->npmtadc++;
654 };
655 };
656 };
657 //
658 memcpy(t_tof->xtofpos,tofoutput_.xtofpos,sizeof(t_tof->xtofpos));
659 memcpy(t_tof->ytofpos,tofoutput_.ytofpos,sizeof(t_tof->ytofpos));
660 memcpy(t_tof->xtr_tof,tofoutput_.xtr_tof,sizeof(t_tof->xtr_tof));
661 memcpy(t_tof->ytr_tof,tofoutput_.ytr_tof,sizeof(t_tof->ytr_tof));
662 //
663
664 /*
665 cout<<"ToFCore tofl2com"<<endl;
666 cout<<tofoutput_.xtofpos[0]<<" "<<tofoutput_.xtofpos[1]<<" "<<tofoutput_.xtofpos[2]<<endl;
667 cout<<tofoutput_.ytofpos[0]<<" "<<tofoutput_.ytofpos[1]<<" "<<tofoutput_.ytofpos[2]<<endl;
668 cout<<tofoutput_.xtr_tof[0]<<" "<<tofoutput_.xtr_tof[1]<<" "<<tofoutput_.xtr_tof[2]<<" "<<tofoutput_.xtr_tof[3]<<" "<<tofoutput_.xtr_tof[4]<<" "<<tofoutput_.xtr_tof[5]<<endl;
669 cout<<tofoutput_.ytr_tof[0]<<" "<<tofoutput_.ytr_tof[1]<<" "<<tofoutput_.ytr_tof[2]<<" "<<tofoutput_.ytr_tof[3]<<" "<<tofoutput_.ytr_tof[4]<<" "<<tofoutput_.ytr_tof[5]<<endl;
670 */
671
672
673 new(t[ntrkentry]) ToFTrkVar(*t_tof);
674 ntrkentry++;
675 t_tof->Clear();
676 //
677 //
678 //
679 t_pmt->Clear();
680 //
681 for (Int_t hh=0; hh<12;hh++){
682 for (Int_t kk=0; kk<4;kk++){
683 if ( tofoutput_.tdc_c[hh][kk] < 4095 || tofEvent->adc[kk][hh] < 4095 ){
684 //
685 t_pmt->pmt_id = tof->GetPMTid(kk,hh);
686 t_pmt->tdc_tw = tofoutput_.tdc_c[hh][kk];
687 t_pmt->adc = tofEvent->adc[kk][hh];
688 t_pmt->tdc = tofEvent->tdc[kk][hh];
689 //
690 new(tpmt[npmtentry]) ToFPMT(*t_pmt);
691 npmtentry++;
692 t_pmt->Clear();
693 };
694 };
695 };
696 //
697 // Calculate track-related variables
698 //
699 if ( trk->ntrk() > 0 ){
700 //
701 // We have at least one track
702 //
703 //
704 // Run over tracks
705 //
706 for(Int_t nt=0; nt < trk->ntrk(); nt++){
707 //
708 TrkTrack *ptt = trk->GetStoredTrack(nt);
709 //
710 // Copy the alpha vector in the input structure
711 //
712 for (Int_t e = 0; e < 5 ; e++){
713 tofinput_.al_pp[e] = ptt->al[e];
714 };
715 //
716 // Get tracker related variables for this track
717 //
718 toftrk();
719 //
720 // Copy values in the class from the structure (we need to use a temporary class to store variables).
721 //
722 t_tof->npmttdc = 0;
723 for (Int_t hh=0; hh<12;hh++){
724 for (Int_t kk=0; kk<4;kk++){
725 if ( tofoutput_.tofmask[hh][kk] != 0 ){
726 pmt_id = tof->GetPMTid(kk,hh);
727 t_tof->pmttdc.AddAt(pmt_id,t_tof->npmttdc);
728 t_tof->tdcflag.AddAt(tofoutput_.tdcflag[hh][kk],t_tof->npmttdc); // gf: Jan 09/07
729 t_tof->npmttdc++;
730 };
731 };
732 };
733 for (Int_t kk=0; kk<13;kk++){
734 t_tof->beta[kk] = tofoutput_.beta_a[kk];
735 };
736 //
737 t_tof->npmtadc = 0;
738 for (Int_t hh=0; hh<12;hh++){
739 for (Int_t kk=0; kk<4;kk++){
740 if ( tofoutput_.adc_c[hh][kk] < 1000 ){
741 t_tof->dedx.AddAt(tofoutput_.adc_c[hh][kk],t_tof->npmtadc);
742 pmt_id = tof->GetPMTid(kk,hh);
743 t_tof->pmtadc.AddAt(pmt_id,t_tof->npmtadc);
744 t_tof->adcflag.AddAt(tofoutput_.adcflag[hh][kk],t_tof->npmtadc); // gf: Jan 09/07
745 t_tof->npmtadc++;
746 };
747 };
748 };
749 //
750 memcpy(t_tof->xtofpos,tofoutput_.xtofpos,sizeof(t_tof->xtofpos));
751 memcpy(t_tof->ytofpos,tofoutput_.ytofpos,sizeof(t_tof->ytofpos));
752 memcpy(t_tof->xtr_tof,tofoutput_.xtr_tof,sizeof(t_tof->xtr_tof));
753 memcpy(t_tof->ytr_tof,tofoutput_.ytr_tof,sizeof(t_tof->ytr_tof));
754
755 /*
756 cout<<"ToFCore toftrk"<<endl;
757 cout<<tofoutput_.xtofpos[0]<<" "<<tofoutput_.xtofpos[1]<<" "<<tofoutput_.xtofpos[2]<<endl;
758 cout<<tofoutput_.ytofpos[0]<<" "<<tofoutput_.ytofpos[1]<<" "<<tofoutput_.ytofpos[2]<<endl;
759 cout<<tofoutput_.xtr_tof[0]<<" "<<tofoutput_.xtr_tof[1]<<" "<<tofoutput_.xtr_tof[2]<<" "<<tofoutput_.xtr_tof[3]<<" "<<tofoutput_.xtr_tof[4]<<" "<<tofoutput_.xtr_tof[5]<<endl;
760 cout<<tofoutput_.ytr_tof[0]<<" "<<tofoutput_.ytr_tof[1]<<" "<<tofoutput_.ytr_tof[2]<<" "<<tofoutput_.ytr_tof[3]<<" "<<tofoutput_.ytr_tof[4]<<" "<<tofoutput_.ytr_tof[5]<<endl;
761 */
762
763 //
764 // Store the tracker track number in order to be sure to have shyncronized data during analysis
765 //
766 t_tof->trkseqno = nt;
767 //
768 // create a new object for this event with track-related variables
769 //
770 new(t[ntrkentry]) ToFTrkVar(*t_tof);
771 ntrkentry++;
772 t_tof->Clear();
773 //
774 }; // loop on all the tracks
775 };
776 //
777 tof->unpackError = tofEvent->unpackError;
778 if ( defcal ){
779 tof->default_calib = 1;
780 } else {
781 tof->default_calib = 0;
782 };
783 //
784 // Fill the rootple
785 //
786 toft->Fill();
787 //
788 //
789 //
790 delete t_tof;
791 //
792 //
793 //
794 jumpev:
795 debug = false;
796 //
797 };
798 //
799 // Here you may want to clear some variables before processing another run
800 //
801 delete dbtime;
802 }; // process all the runs
803 //
804 if ( verbose ) printf("\n Finished processing data \n");
805 //
806 closeandexit:
807 //
808 // we have finished processing the run(s). If we processed a single run now we must copy all the events after our run from the old tree to the new one and delete the old tree.
809 //
810 if ( !reprocall && reproc && code >= 0 ){
811 if ( totfileentries > noaftrun ){
812 if ( verbose ) printf("\n Post-processing: copying events from the old tree after the processed run\n");
813 if ( verbose ) printf(" Copying %i events in the file which are after the end of the run %i \n",(int)(totfileentries-noaftrun),(int)run);
814 if ( verbose ) printf(" Start copying at event number %i end copying at event number %i \n",(int)noaftrun,(int)totfileentries);
815 for (UInt_t j = noaftrun; j < totfileentries; j++ ){
816 //
817 // Get entry from old tree
818 //
819 toftclone->GetEntry(j);
820 //
821 // copy tofclone to tof
822 //
823 tof->Clear();
824 memcpy(&tof,&tofclone,sizeof(tofclone));
825 //
826 // Fill entry in the new tree
827 //
828 toft->Fill();
829 };
830 if ( verbose ) printf(" Finished successful copying!\n");
831 };
832 };
833 //
834 // Close files, delete old tree(s), write and close level2 file
835 //
836 if ( l0File ) l0File->Close();
837 if ( tempfile ) tempfile->Close();
838 if ( myfold ) gSystem->Unlink(tempname.str().c_str());
839 if ( tracker ) tracker->Delete(); // delete tracker tree from memory only to avoid writing a copy to file!
840 //
841 if ( code < 0 && verbose ) printf("\n TOF - ERROR: an error occurred, try to save anyway...\n");
842 if ( verbose ) printf("\n Writing and closing rootple\n");
843 if ( runinfo ) runinfo->Close();
844 if ( toft ) toft->SetName("ToF");
845 if ( file ){
846 file->cd();
847 file->Write("ToF");
848 };
849 //
850 if ( myfold ) gSystem->Unlink(toffolder.str().c_str());
851 //
852 // the end
853 //
854 if ( verbose ) printf("\n Exiting...\n");
855 if(toft)toft->Delete();
856 //
857 if ( tof ) delete tof;
858 if ( tofclone ) delete tofclone;
859 if ( glroot ) delete glroot;
860 if ( runinfo ) delete runinfo;
861 //
862 if ( code < 0 ) throw code;
863 return(code);
864 }

  ViewVC Help
Powered by ViewVC 1.1.23