]> git.uio.no Git - u/mrichter/AliRoot.git/blob - HLT/src/AliLevel3.cxx
Added writeout path
[u/mrichter/AliRoot.git] / HLT / src / AliLevel3.cxx
1 //$Id$
2
3 // Author: Anders Vestbo <mailto:vestbo$fi.uib.no>, Uli Frankenfeld <mailto:franken@fi.uib.no>
4 //*-- Copyright &copy ASV
5
6 #include <TFile.h>
7 #include <TDirectory.h>
8 #include <TClonesArray.h>
9 #include <TStopwatch.h>
10 #include <iostream.h>
11
12 #include "AliL3Logging.h"
13 #include "AliLevel3.h"
14 #include "AliL3ConfMapper.h"
15 #include "AliL3Vertex.h"
16 #include "AliL3VertexFinder.h"
17 #include "AliL3TrackMerger.h"
18 #include "AliL3GlobalMerger.h"
19 #include "AliL3InterMerger.h"
20 #include "AliL3ConfMapPoint.h"
21 #include "AliL3ConfMapTrack.h"
22 #include "AliL3Transform.h"
23 #include "AliL3ClustFinderNew.h"
24 #include "AliL3DigitData.h"
25 #include "AliL3TrackArray.h"
26 #include "AliL3MemHandler.h"
27 #ifdef use_aliroot
28 #include "AliL3FileHandler.h"
29 #endif
30 #include "AliL3Benchmark.h"
31
32 #include "AliL3DigitData.h"
33 #include "AliL3TrackSegmentData.h"
34 #include "AliL3SpacePointData.h"
35 #include "AliL3VertexData.h"
36
37 //_____________________________________________________________
38 //
39 //  AliLevel3
40 //
41 //  Interface class for Level3 tracker.
42 //  Tracking is done by calling constructor with input,output 
43 //  given as argument. 
44 //  You must always remember to set the tracking parameters. E.g.:
45 // 
46 //  AliLevel3 *level3 = new AliLevel3(inputfile,outputfile);
47 //  level3->SetTrackerParam(); //Sets default tracking parameters
48 //  level3->ProcessSector(2,2);  //Does tracking on sector 2 (actually 2+38)
49 //Begin_Html
50 /*
51 <img src="tpcsectorsnb.gif">
52 */
53 //End_Html
54
55 ClassImp(AliLevel3)
56
57 AliLevel3::AliLevel3(){
58   fInputFile=0;
59   fOutputFile=0;
60   Init();
61 }
62
63 AliLevel3::AliLevel3(Char_t *infile,Char_t *outfile){
64   //Constructor. Calls constructor of the tracker, vertexfinder and merger classes.
65
66   fOutputFile = new TFile(outfile,"NEW");
67   
68   if(!fOutputFile->IsOpen())
69     {
70     LOG(AliL3Log::kWarning, "AliLevel3::AliLevel3","File Open")
71     <<"Delete your old "<<outfile<<" file!"<<ENDLOG;
72     }
73   fInputFile = new TFile(infile,"READ");
74   
75   if(!fInputFile->IsOpen())
76     {
77     LOG(AliL3Log::kError,"AliLevel3::AliLevel3","File Open")
78     <<"Inputfile "<<infile<<" does not exist"<<ENDLOG;
79     return;
80     }
81   
82   Init();
83 }
84
85 AliLevel3::AliLevel3(TFile *in, TFile *out){
86   fOutputFile = out;
87   fInputFile  =  in;
88   if(!in){
89     LOG(AliL3Log::kError,"AliLevel3::AliLevel3","File Open")
90     <<"Pointer to InFile 0x0!"<<ENDLOG;
91     return;
92   }  
93   if(!out){
94     LOG(AliL3Log::kError,"AliLevel3::AliLevel3","File Open")
95     <<"Pointer to OutFile 0x0!"<<ENDLOG;
96     return;
97   }  
98   
99   if(!fOutputFile->IsOpen())
100     {
101     LOG(AliL3Log::kWarning,"AliLevel3::AliLevel3","File Open")
102     <<"no output file!"<<ENDLOG;
103       return;
104     }
105   if(!fInputFile->IsOpen())
106     {
107     LOG(AliL3Log::kError,"AliLevel3::AliLevel3","File Open")
108     <<"Inputfile does not exist"<<ENDLOG;
109       return;
110     }
111   Init();
112 }
113
114 void AliLevel3::Init(){
115   fWriteOut = kFALSE;
116   fGlobalMerger=0;
117   fTransformer = new AliL3Transform();
118   fDoRoi = kFALSE;
119   fDoNonVertex = kFALSE;
120   fClusterDeconv = kTRUE;
121   fEta[0] = 0.;
122   fEta[1] = 0.9;
123   fUseBinary =kFALSE;
124   SetPath("");
125   fFindVertex =kFALSE;
126   fEvent=0;
127   if(1){
128     fNPatch = 1;   //number of patches change row in process
129     fRow[0][0] = 0;     // first row
130     fRow[0][1] = 175;   // last row
131   }
132   if(0){
133     fNPatch = 2;   //number of patches change row in process
134     fRow[0][0] = 0;     // first row
135     fRow[0][1] = 54;
136     fRow[1][0] = 55;
137     fRow[1][1] = 175;   // last row
138   }
139   if(0){
140     fNPatch = 5;   //number of patches change row in process
141     fRow[0][0] = 0;     // first row
142     fRow[0][1] = 45;
143     fRow[1][0] = 46;
144     fRow[1][1] = 77;
145     fRow[2][0] = 78;
146     fRow[2][1] = 109;
147     fRow[3][0] = 110;
148     fRow[3][1] = 141;
149     fRow[4][0] = 142;
150     fRow[4][1] = 175;   // last row
151   }
152   if(0){
153     fNPatch = 6;   //number of patches change row in process
154     fRow[0][0] = 0;     // first row
155     fRow[0][1] = 31;
156     fRow[1][0] = 32;
157     fRow[1][1] = 63;
158     fRow[2][0] = 64;
159     fRow[2][1] = 91;
160     fRow[3][0] = 92;
161     fRow[3][1] = 119;
162     fRow[4][0] = 120;
163     fRow[4][1] = 143;   
164     fRow[5][0] = 144;
165     fRow[5][1] = 175;   // last row 
166   }
167   fVertexFinder = new AliL3VertexFinder();
168   fVertex = new AliL3Vertex();
169   fTracker = new AliL3ConfMapper();
170   fTrackMerger = new AliL3TrackMerger(fNPatch);
171   fInterMerger = new AliL3InterMerger();
172   #ifdef use_aliroot
173   fFileHandler = new AliL3FileHandler();
174   fFileHandler->SetAliInput(fInputFile);
175   #else
176   fFileHandler = new AliL3MemHandler();
177   #endif
178   fBenchmark = new AliL3Benchmark();
179 }
180
181 void AliLevel3::DoBench(char* name){
182   fBenchmark->Analyze(name);
183 }
184
185 void AliLevel3::DoMc(char* file){
186 #ifdef use_aliroot
187   if(!fFileHandler->IsDigit())
188     fFileHandler->SetMCOutput(file);
189 #endif
190 }
191
192 AliLevel3::~AliLevel3(){
193   //Destructor
194   if(fVertexFinder)  delete fVertexFinder;
195   if(fVertex)  delete fVertex;
196   if(fTracker) delete fTracker;
197   if(fTransformer) delete fTransformer;
198   if(fTrackMerger) delete fTrackMerger;
199   if(fInterMerger) delete fInterMerger;
200   if(fFileHandler) delete fFileHandler;
201 }
202
203 void AliLevel3::SetTrackerParam(Int_t phi_segments, Int_t eta_segments,
204                                 Int_t trackletlength, Int_t tracklength,
205                                 Int_t rowscopetracklet, Int_t rowscopetrack,
206                                 Double_t min_pt_fit, Double_t maxangle,
207                                 Double_t goodDist, Double_t hitChi2Cut,
208                                 Double_t goodHitChi2, Double_t trackChi2Cut,
209                                 Int_t maxdist,Double_t maxphi,Double_t maxeta,Bool_t vertexconstraint)
210 {
211   //Set parameters input to the tracker
212   //If no arguments are given, default parameters will be used
213   
214   fTracker->SetNSegments(phi_segments,eta_segments);
215   fTracker->SetMaxDca(min_pt_fit);
216   fTracker->SetTrackCuts(hitChi2Cut,goodHitChi2,trackChi2Cut,maxdist,vertexconstraint);
217   fTracker->SetTrackletCuts(maxangle,goodDist,vertexconstraint);
218   if(vertexconstraint)
219     fTracker->MainVertexSettings(trackletlength,tracklength,rowscopetracklet,rowscopetrack,maxphi,maxeta);
220   else
221     fTracker->NonVertexSettings(trackletlength,tracklength,rowscopetracklet,rowscopetrack);
222   
223   fTracker->SetParamDone(true);
224 }
225
226 void AliLevel3::ProcessEvent(Int_t first,Int_t last,Int_t event){
227   //Do tracking on all slices in region [first,last]
228   //Slices numbering in TPC goes from 0-35, which means that 1 slice
229   //corresponds to inner+outer sector.E.g. slice 2 corresponds to
230   //inner=2 + outer=38.
231   fGlobalMerger= new AliL3GlobalMerger(first,last);  
232   fEvent=event;
233   for(Int_t i=first; i<=last; i++){
234     ProcessSlice(i);
235     fGlobalMerger->SetVertex(fVertex);
236     fGlobalMerger->SetTransformer(fTransformer);
237     fGlobalMerger->InitSlice(i);
238     fGlobalMerger->FillTracks(fNTrackData,fTrackData);
239     fFileHandler->Free();   //free the memory
240     fNTrackData=0;
241     fTrackData=0;
242   }
243   fBenchmark->Start("Global Merger");
244   //fGlobalMerger->AddAllTracks();
245   //fGlobalMerger->Merge();
246   fGlobalMerger->SlowMerge();
247   fBenchmark->Stop("Global Merger");
248
249   if(fWriteOut) WriteResults(); 
250   delete fGlobalMerger; fGlobalMerger = 0;
251 }
252
253 void AliLevel3::ProcessSlice(Int_t slice){
254   char name[256];
255   Bool_t UseCF = kFALSE;
256 #ifdef use_aliroot
257   UseCF = fFileHandler->IsDigit();
258 #endif
259   const Int_t maxpoints=100000;
260   const Int_t pointsize = maxpoints * sizeof(AliL3SpacePointData);
261   AliL3MemHandler *memory = new AliL3MemHandler();
262
263   fTrackMerger->Reset();
264   fTrackMerger->SetTransformer(fTransformer);
265   fTrackMerger->SetRows(fRow[0]);
266   for(Int_t patch=fNPatch-1;patch>=0;patch--){
267     fFileHandler->Init(slice,patch,fRow[patch]);
268     fFileHandler->Init(fTransformer);
269     UInt_t npoints=0;
270     AliL3SpacePointData *points =0;
271     UInt_t ndigits=0;
272     AliL3DigitRowData *digits =0;
273     if(UseCF){
274       if(fUseBinary){
275         if(!fDoRoi){ 
276           if(1){     //Binary to Memory
277             fFileHandler->Free();
278             sprintf(name,"%sdigits_%d_%d.raw",fPath,slice,patch);
279             if(!fFileHandler->SetBinaryInput(name)) return;
280             digits= (AliL3DigitRowData *)fFileHandler->CompBinary2Memory(ndigits);
281             fFileHandler->CloseBinaryInput(); 
282           }
283
284           if(0){     //Binary to Memory with Benchmark 
285             fFileHandler->Free();
286             sprintf(name,"%sdigits_%d_%d.raw",fPath,slice,patch);
287             if(!memory->SetBinaryInput(name)) return;
288             UInt_t compsize=memory->GetFileSize();
289             UInt_t *comp=(UInt_t *)memory->Allocate(compsize);
290             memory->CompBinary2CompMemory(ndigits,comp);
291             memory->CloseBinaryInput();
292             UInt_t datasize=memory->GetMemorySize(ndigits,comp);
293             digits=(AliL3DigitRowData *)fFileHandler->Allocate(datasize);
294             fBenchmark->Start("Unpacker"); 
295             fFileHandler->CompMemory2Memory(ndigits,digits,comp); 
296             fBenchmark->Stop("Unpacker");
297             memory->Free();
298           }
299   
300           if(0){     //Binary to Memory with Random
301             fFileHandler->Free();
302             fFileHandler->ResetRandom();
303             fFileHandler->SetRandomCluster(100);
304             fFileHandler->SetNGenerate(100);
305             sprintf(name,"%sdigits_%d_%d.raw",fPath,slice,patch);
306             if(!memory->SetBinaryInput(name)) return;
307             UInt_t compsize=memory->GetFileSize();
308             UInt_t *comp=(UInt_t *)memory->Allocate(compsize);
309             memory->CompBinary2CompMemory(ndigits,comp);
310             memory->CloseBinaryInput();
311             UInt_t dsize=memory->GetMemorySize(ndigits,comp);
312             UInt_t rsize=fFileHandler->GetRandomSize();       
313             digits=(AliL3DigitRowData*)fFileHandler->Allocate(dsize+rsize);
314             fBenchmark->Start("Unpacker");
315             fFileHandler->CompMemory2Memory(ndigits,digits,comp); 
316             fBenchmark->Stop("Unpacker");
317             memory->Free();
318           }
319         }
320
321         else{     //Binary to Memory with Roi
322           fFileHandler->Free();
323           Int_t sli[2]={0,0};
324           fFileHandler->SetROI(fEta,sli);
325           sprintf(name,"%sdigits_%d_%d.raw",fPath,slice,patch);
326           if(!memory->SetBinaryInput(name)) return;
327           UInt_t compsize=memory->GetFileSize();
328           UInt_t *comp=(UInt_t *)memory->Allocate(compsize);
329           memory->CompBinary2CompMemory(ndigits,comp);
330           memory->CloseBinaryInput();
331           UInt_t datasize=memory->GetMemorySize(ndigits,comp);
332           digits=(AliL3DigitRowData *)fFileHandler->Allocate(datasize);
333           fBenchmark->Start("Unpacker"); 
334           datasize = fFileHandler->CompMemory2Memory(ndigits,digits,comp); 
335           fBenchmark->Stop("Unpacker"); 
336           memory->Free();
337         }
338       }//end UseBinary
339       else{
340 #ifdef use_aliroot
341         fBenchmark->Start("Dummy Unpacker");
342         sprintf(name,"digits_%d_%d.raw",slice,patch);
343         fBenchmark->Stop("Dummy Unpacker");
344
345         if(0){    //Ali to Binary
346           fFileHandler->SetBinaryOutput(name);
347           fFileHandler->AliDigits2CompBinary();
348           fFileHandler->CloseBinaryOutput();
349         }
350   
351         if(1){     //Ali to Memory
352           digits=(AliL3DigitRowData *)fFileHandler->AliDigits2Memory(ndigits,fEvent);
353           if(fWriteOut){   //Memory to Binary
354             fFileHandler->SetBinaryOutput(name);
355             fFileHandler->Memory2CompBinary(ndigits,digits);
356             fFileHandler->CloseBinaryOutput();
357           }
358         }
359 #endif
360       }//end else UseBinary
361
362       points = (AliL3SpacePointData *) memory->Allocate(pointsize);
363   
364       fClusterFinder = new AliL3ClustFinderNew(fTransformer);
365       fClusterFinder->InitSlice(slice,patch,fRow[patch][0],fRow[patch][1]
366                                 ,maxpoints);
367       fClusterFinder->SetDeconv(fClusterDeconv);
368       fClusterFinder->SetXYError(0.2);
369       fClusterFinder->SetZError(0.3);
370       fClusterFinder->SetOutputArray(points);
371       fClusterFinder->Read(ndigits,digits);
372       fBenchmark->Start("Cluster Finder");
373       fClusterFinder->ProcessDigits();
374       fBenchmark->Stop("Cluster Finder");
375       npoints = fClusterFinder->GetNumberOfClusters();
376       delete fClusterFinder;
377       fClusterFinder =0;
378       fFileHandler->Free();
379       LOG(AliL3Log::kInformational,"AliLevel3::ProcessSlice","Cluster Finder")
380         <<AliL3Log::kDec<<"Found "<<npoints<<" Points"<<ENDLOG;
381     
382     
383     }//end UseCF
384     else{// if not use Clusterfinder
385       if(fUseBinary){//Binary to Memory
386         memory->Free();
387         sprintf(name,"/%spoints_%d_%d.raw",fPath,slice,patch);
388         if(!memory->SetBinaryInput(name)) return;
389         points = (AliL3SpacePointData *) memory->Allocate();
390         memory->Binary2Memory(npoints,points);
391         memory->CloseBinaryInput();
392         LOG(AliL3Log::kInformational,"AliLevel3::ProcessSlice","Read Cluster")
393         <<AliL3Log::kDec<<"Found "<<npoints<<" Points in File"<<ENDLOG;
394       }
395 #ifdef use_aliroot
396       else{
397         points = fFileHandler->AliPoints2Memory(npoints);
398       }
399 #endif
400       fBenchmark->Start("Dummy Unpacker");
401       fBenchmark->Stop("Dummy Unpacker");
402       fBenchmark->Start("Dummy CF");
403       fBenchmark->Stop("Dummy CF");
404     }
405    
406     if(patch == fNPatch-1){
407       // Vertex
408       if(fFindVertex){
409       // Vertex Finder
410       
411         fBenchmark->Start("Vertex Finder Read");
412         fVertexFinder->Reset();
413         fVertexFinder->Read(npoints,points);
414         fBenchmark->Stop("Vertex Finder Read"); 
415         fBenchmark->Start("Vertex Finder");
416         fVertexFinder->Analyze();
417         AliL3VertexData vertex[1];
418         fVertexFinder->Write(vertex);
419         fVertex->Read(vertex);
420         fBenchmark->Stop("Vertex Finder"); 
421       }
422       else{
423         //use 0,0,0 for vertex
424         fVertex->SetZero();
425       }
426       fTrackMerger->SetVertex(fVertex);
427     }
428     fTracker->InitSector(slice,fRow[patch]);//,fEta);
429     fTracker->SetVertex(fVertex);
430     fBenchmark->Start("Tracker Read Hits");
431     fTracker->ReadHits(npoints,points);
432     fBenchmark->Stop("Tracker Read Hits");
433     fBenchmark->Start("MainVertexTracking A"); 
434     fTracker->MainVertexTracking();
435     //fTracker->MainVertexTracking_a();
436     fBenchmark->Stop("MainVertexTracking A");
437     //fBenchmark->Start("MainVertexTracking B"); 
438     //fTracker->MainVertexTracking_b();
439     //fBenchmark->Stop("MainVertexTracking B");
440     fBenchmark->Start("Tracking fit");
441     if(fDoNonVertex)
442       fTracker->NonVertexTracking();//Do a second pass for nonvertex tracks
443     fTracker->FillTracks();
444     fBenchmark->Stop("Tracking fit");
445
446     if(fWriteOut) 
447        WriteSpacePoints(npoints, points, slice, patch); //do after Tracking
448
449     //free memory
450     if(UseCF)
451       memory->Free();
452     else
453       fFileHandler->Free();
454
455     UInt_t ntracks0 =0;
456     AliL3TrackSegmentData *trackdata0  = 
457          (AliL3TrackSegmentData *) memory->Allocate(fTracker->GetTracks());
458     memory->TrackArray2Memory(ntracks0,trackdata0,fTracker->GetTracks());
459     /*
460     //write tracks
461     if(fWriteOut){
462       sprintf(name,"%stracks_tr_%d_%d.raw",fWriteOutPath,slice,patch);
463       memory->SetBinaryOutput(name);
464       memory->Memory2Binary(ntracks0,trackdata0);
465       memory->CloseBinaryOutput();
466     }
467     */
468     fInterMerger->Reset();
469     fInterMerger->SetTransformer(fTransformer);
470     fInterMerger->Init(fRow[patch],patch);
471
472     fInterMerger->FillTracks(ntracks0,trackdata0);
473     fBenchmark->Start("Inter Merger");
474     // fInterMerger->Merge();
475 //    fInterMerger->SlowMerge();
476     
477     fBenchmark->Stop("Inter Merger");
478     /*
479     //write inter merged tracks
480     if(fWriteOut){
481       sprintf(name,"%stracks_im_%d_%d.raw",fWriteOutPath,slice,patch);
482       WriteTracks(name,fInterMerger,'i'); //write output of intermerger
483       }
484     */
485     memory->Free();
486     
487     UInt_t ntracks1 =0;
488     AliL3TrackSegmentData *trackdata1 =
489       (AliL3TrackSegmentData *) memory->Allocate(fInterMerger->GetInTracks(0));
490     memory->TrackArray2Memory(ntracks1,trackdata1,fInterMerger->GetInTracks(0));
491
492     fTrackMerger->InitSector(slice,patch);
493     fTrackMerger->FillTracks(ntracks1,trackdata1);
494
495     memory->Free();
496   }
497   fBenchmark->Start("Patch Merger");
498 //  fTrackMerger->SlowMerge();
499   fTrackMerger->AddAllTracks();
500   //fTrackMerger->Merge();
501   fBenchmark->Stop("Patch Merger");
502   /*
503   //write merged tracks
504   if(fWriteOut){
505     sprintf(name,"%stracks_tm_%d.raw",fWriteOutPath,slice);
506     WriteTracks(name,fTrackMerger,'o'); //write output of trackmerger
507   }
508   */
509   fTrackData = (AliL3TrackSegmentData *) 
510                          fFileHandler->Allocate(fTrackMerger->GetOutTracks());
511
512   fFileHandler->TrackArray2Memory(fNTrackData,fTrackData,
513                                                 fTrackMerger->GetOutTracks());
514
515   delete memory;
516 }
517
518 void AliLevel3::WriteSpacePoints(UInt_t npoints,AliL3SpacePointData *points,
519                                                       Int_t slice,Int_t patch){
520   char name[256];
521   sprintf(name,"%spoints_%d_%d.raw",fWriteOutPath,slice,patch);
522   AliL3MemHandler * memory = new AliL3MemHandler();
523   memory->SetBinaryOutput(name);
524   memory->Transform(npoints,points,slice,fTransformer);
525   memory->Memory2Binary(npoints,points);
526   memory->CloseBinaryOutput();
527   delete  memory;
528 }
529
530
531 Int_t AliLevel3::WriteTracks(char *filename,AliL3Merger *merger,char opt){
532   AliL3MemHandler *memory = new AliL3MemHandler();
533   memory->SetBinaryOutput(filename);
534   if(opt=='a'||opt=='i'){  //add intracks
535     for(Int_t i=0;i<merger->GetNIn();i++){
536       AliL3TrackArray *tr=merger->GetInTracks(i);
537       memory->TrackArray2Binary(tr);
538     }
539   }
540
541   if(opt=='o'||opt=='a'){
542     AliL3TrackArray *tr=merger->GetOutTracks();
543     memory->TrackArray2Binary(tr);
544   }
545
546   memory->CloseBinaryOutput();
547  
548   return 1;
549 }
550
551 void AliLevel3::WriteResults()
552 {
553   //Write the resulting tracks to outputfile
554   Char_t fname[256];
555   sprintf(fname,"%stracks.raw",fWriteOutPath);
556   WriteTracks(fname,fGlobalMerger,'a');
557   //WriteTracks("tracks.raw",fGlobalMerger,'a');
558   sprintf(fname,"%stracks_gl.raw",fWriteOutPath);
559   WriteTracks(fname,fGlobalMerger,'o');
560   //WriteTracks("tracks_gl.raw",fGlobalMerger,'o');
561 }