]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - PHOS/AliPHOSReconstructor.cxx
Creation of TClonesArray in constructor only, instead of per-event.
[u/mrichter/AliRoot.git] / PHOS / AliPHOSReconstructor.cxx
index f8ac67d97dc88fe26e9918ecfe2386cb161cfe9d..8cd835e431e9f752193a2cf48d6633a8cf4949e2 100644 (file)
@@ -16,8 +16,8 @@
 /* $Id$ */
 
 //_________________________________________________________________________
-//*--
-//*-- Yves Schutz (SUBATECH) 
+//--
+//-- Yves Schutz (SUBATECH) 
 // Reconstruction class. Redesigned from the old AliReconstructionner class and 
 // derived from STEER/AliReconstructor. 
 // 
@@ -30,6 +30,7 @@
 #include "AliAltroMapping.h"
 #include "AliESDEvent.h"
 #include "AliESDCaloCluster.h"
+#include "AliESDCaloCells.h"
 #include "AliPHOSReconstructor.h"
 #include "AliPHOSClusterizerv1.h"
 #include "AliPHOSTrackSegmentMakerv1.h"
@@ -47,6 +48,7 @@
 #include "AliPHOSRecParticle.h"
 #include "AliPHOSRawDecoder.h"
 #include "AliPHOSRawDecoderv1.h"
+#include "AliPHOSRawDecoderv2.h"
 #include "AliPHOSRawDigiProducer.h"
 #include "AliPHOSPulseGenerator.h"
 
@@ -55,10 +57,12 @@ ClassImp(AliPHOSReconstructor)
 Bool_t AliPHOSReconstructor::fgDebug = kFALSE ; 
 AliPHOSRecoParam* AliPHOSReconstructor::fgkRecoParamEmc =0;  // EMC rec. parameters
 AliPHOSRecoParam* AliPHOSReconstructor::fgkRecoParamCpv =0;  // CPV rec. parameters
+TClonesArray*     AliPHOSReconstructor::fgDigitsArray = 0;   // Array of PHOS digits
+TObjArray*        AliPHOSReconstructor::fgEMCRecPoints = 0;   // Array of EMC rec.points
 
 //____________________________________________________________________________
 AliPHOSReconstructor::AliPHOSReconstructor() :
-  fGeom(NULL)
+  fGeom(NULL),fClusterizer(NULL),fTSM(NULL),fPID(NULL)
 {
   // ctor
 
@@ -72,7 +76,12 @@ AliPHOSReconstructor::AliPHOSReconstructor() :
     fgkRecoParamCpv = AliPHOSRecoParamCpv::GetCpvDefaultParameters();
   }
 
-  fGeom = AliPHOSGeometry::GetInstance("IHEP","");
+  fGeom        = AliPHOSGeometry::GetInstance("IHEP","");
+  fClusterizer = new AliPHOSClusterizerv1      (fGeom);
+  fTSM         = new AliPHOSTrackSegmentMakerv1(fGeom);
+  fPID         = new AliPHOSPIDv1              (fGeom);
+  fgDigitsArray = new TClonesArray("AliPHOSDigit",100);
+  fgEMCRecPoints= new TObjArray(100) ;
 }
 
 //____________________________________________________________________________
@@ -80,6 +89,11 @@ AliPHOSReconstructor::AliPHOSReconstructor() :
 {
   // dtor
   delete fGeom;
+  delete fClusterizer;
+  delete fTSM;
+  delete fPID;
+  delete fgDigitsArray;
+  delete fgEMCRecPoints;
 } 
 
 //____________________________________________________________________________
@@ -90,13 +104,12 @@ void AliPHOSReconstructor::Reconstruct(TTree* digitsTree, TTree* clustersTree) c
   // segment maker needs access to the AliESDEvent object to retrieve the tracks reconstructed by 
   // the global tracking.
 
-  AliPHOSClusterizerv1 clu(fGeom);
-  clu.SetInput(digitsTree);
-  clu.SetOutput(clustersTree);
+  fClusterizer->SetInput(digitsTree);
+  fClusterizer->SetOutput(clustersTree);
   if ( Debug() ) 
-    clu.Digits2Clusters("deb all") ; 
+    fClusterizer->Digits2Clusters("deb all") ; 
   else 
-    clu.Digits2Clusters("") ;
+    fClusterizer->Digits2Clusters("") ;
 }
 
 //____________________________________________________________________________
@@ -107,42 +120,57 @@ void AliPHOSReconstructor::FillESD(TTree* digitsTree, TTree* clustersTree,
   // then it creates AliESDtracks out of them and
   // write tracks to the ESD
 
-  AliPHOSTrackSegmentMaker *tsm = new AliPHOSTrackSegmentMakerv1(fGeom);
-  AliPHOSPID               *pid = new AliPHOSPIDv1              (fGeom);
 
   // do current event; the loop over events is done by AliReconstruction::Run()
-  tsm->SetESD(esd) ; 
-  tsm->SetInput(clustersTree);
+  fTSM->SetESD(esd) ; 
+  fTSM->SetInput(clustersTree);
   if ( Debug() ) 
-    tsm->Clusters2TrackSegments("deb all") ;
+    fTSM->Clusters2TrackSegments("deb all") ;
   else 
-    tsm->Clusters2TrackSegments("") ;
+    fTSM->Clusters2TrackSegments("") ;
   
-  pid->SetInput(clustersTree, tsm->GetTrackSegments()) ; 
-  pid->SetESD(esd) ; 
+  fPID->SetInput(clustersTree, fTSM->GetTrackSegments()) ; 
+  fPID->SetESD(esd) ; 
   if ( Debug() ) 
-    pid->TrackSegments2RecParticles("deb all") ;
+    fPID->TrackSegments2RecParticles("deb all") ;
   else 
-    pid->TrackSegments2RecParticles("") ;
+    fPID->TrackSegments2RecParticles("") ;
 
-
-  // This function creates AliESDtracks from AliPHOSRecParticles
-  //         and
-  // writes them to the ESD
-
-  TClonesArray *recParticles  = pid->GetRecParticles();
-  Int_t nOfRecParticles = recParticles->GetEntries();
+  TClonesArray *recParticles  = fPID->GetRecParticles();
+  Int_t nOfRecParticles = recParticles->GetEntriesFast();
   
   esd->SetNumberOfPHOSClusters(nOfRecParticles) ; 
   esd->SetFirstPHOSCluster(esd->GetNumberOfCaloClusters()) ;
-
+  
   AliDebug(2,Form("%d rec. particles, option %s",nOfRecParticles,GetOption()));
+  
+  // Read digits array
+
+  TBranch *branch = digitsTree->GetBranch("PHOS");
+  if (!branch) { 
+    AliError("can't get the branch with the PHOS digits !");
+    return;
+  }
+  branch->SetAddress(&fgDigitsArray);
+  branch->GetEntry(0);
+
+  // Get the clusters array
+
+  TBranch *emcbranch = clustersTree->GetBranch("PHOSEmcRP");
+  if (!emcbranch) { 
+    AliError("can't get the branch with the PHOS EMC clusters !");
+    return;
+  }
+
+  emcbranch->SetAddress(&fgEMCRecPoints);
+  emcbranch->GetEntry(0);
 
   //#########Calculate trigger and set trigger info###########
+
   AliPHOSTrigger tr ;
   //   tr.SetPatchSize(1);//create 4x4 patches
-  tr.Trigger();
+  tr.SetSimulation(kFALSE);
+  tr.Trigger(fgDigitsArray);
   
   Float_t maxAmp2x2  = tr.Get2x2MaxAmplitude();
   Float_t maxAmpnxn  = tr.GetnxnMaxAmplitude();
@@ -156,12 +184,15 @@ void AliPHOSReconstructor::FillESD(TTree* digitsTree, TTree* clustersTree,
   Int_t iCrystalEta2x2 = tr.Get2x2CrystalEta();
   Int_t iCrystalEtanxn = tr.GetnxnCrystalEta();
 
-  AliDebug(2, Form("Trigger 2x2 max amp %f, out amp %f, SM %d, iphi %d ieta %d",  maxAmp2x2, ampOutOfPatch2x2, iSM2x2,iCrystalPhi2x2, iCrystalEta2x2));
-  AliDebug(2, Form("Trigger 4x4 max amp %f , out amp %f, SM %d, iphi %d, ieta %d",  maxAmpnxn, ampOutOfPatchnxn, iSMnxn,iCrystalPhinxn, iCrystalEtanxn));
+  AliDebug(2, Form("Trigger 2x2 max amp %f, out amp %f, SM %d, iphi %d ieta %d",  
+                  maxAmp2x2, ampOutOfPatch2x2, iSM2x2,iCrystalPhi2x2, iCrystalEta2x2));
+  AliDebug(2, Form("Trigger 4x4 max amp %f , out amp %f, SM %d, iphi %d, ieta %d",
+                  maxAmpnxn, ampOutOfPatchnxn, iSMnxn,iCrystalPhinxn, iCrystalEtanxn));
 
-  Int_t iRelId2x2 []= {iSM2x2+1,0,iCrystalPhi2x2,iCrystalEta2x2};// PHOS modules in order to calculate AbsId need to be 1-5 not 0-4 as returns trigger.
+  // Attention! PHOS modules in order to calculate AbsId need to be 1-5 not 0-4 as returns trigger.
+  Int_t iRelId2x2 []= {iSM2x2+1,0,iCrystalPhi2x2,iCrystalEta2x2};
   Int_t iAbsId2x2 =-1;
-  Int_t iRelIdnxn []= {iSMnxn+1,0,iCrystalPhinxn,iCrystalEtanxn};// PHOS modules in order to calculate AbsId need to be 1-5 not 0-4 as returns trigger.
+  Int_t iRelIdnxn []= {iSMnxn+1,0,iCrystalPhinxn,iCrystalEtanxn};
   Int_t iAbsIdnxn =-1;
   TVector3    pos2x2(-1,-1,-1);
   TVector3    posnxn(-1,-1,-1);
@@ -188,42 +219,46 @@ void AliPHOSReconstructor::FillESD(TTree* digitsTree, TTree* clustersTree,
   esd->AddPHOSTriggerPosition(triggerPosition);
   esd->AddPHOSTriggerAmplitudes(triggerAmplitudes);
   
-  //######################################
-  
-  // Read digits array
-  TBranch *branch = digitsTree->GetBranch("PHOS");
-  if (!branch) { 
-    AliError("can't get the branch with the PHOS digits !");
-    return;
-  }
-  TClonesArray *fDigitsArr    = new TClonesArray("AliPHOSDigit",100);
-  branch->SetAddress(&fDigitsArr);
-  branch->GetEntry(0);
 
-  // Get the clusters array
-  TBranch *emcbranch = clustersTree->GetBranch("PHOSEmcRP");
-  if (!emcbranch) { 
-    AliError("can't get the branch with the PHOS EMC clusters !");
-    return;
+  //########################################
+  //############# Fill CaloCells ###########
+  //########################################
+
+  Int_t nDigits = fgDigitsArray->GetEntries();
+  Int_t idignew = 0 ;
+  AliDebug(1,Form("%d digits",nDigits));
+
+  const Int_t knEMC = fGeom->GetNModules()*fGeom->GetNPhi()*fGeom->GetNZ();
+  AliESDCaloCells &phsCells = *(esd->GetPHOSCells());
+  phsCells.CreateContainer(nDigits);
+  phsCells.SetType(AliESDCaloCells::kPHOSCell);
+
+  // Add to CaloCells only EMC digits with non-zero energy 
+  for (Int_t idig = 0 ; idig < nDigits ; idig++) {
+    const AliPHOSDigit * dig = (const AliPHOSDigit*)fgDigitsArray->At(idig);
+    if(dig->GetId() <= knEMC && dig->GetEnergy() > 0 ){
+      //printf("i %d; id %d; amp %f; time %e\n",
+      //idignew,dig->GetId(),dig->GetEnergy(), dig->GetTime());
+      phsCells.SetCell(idignew,dig->GetId(), dig->GetEnergy(), dig->GetTime());   
+      idignew++;
+    }
   }
+  phsCells.SetNumberOfCells(idignew);
+  phsCells.Sort();
 
-  TObjArray *fEmcRecPoints = new TObjArray(100) ;
-  emcbranch->SetAddress(&fEmcRecPoints);
-  emcbranch->GetEntry(0);
-
-  //Fill CaloClusters 
-  const Float_t kBigShort = std::numeric_limits<short int>::max() - 1;
-  const Float_t nsec100   = 1e9*100.; // units of 0.01 ns
-  const Float_t gev500    = 500.;     // units of GeV/500
+  //########################################
+  //############## Fill CaloClusters #######
+  //########################################
 
   for (Int_t recpart = 0 ; recpart < nOfRecParticles ; recpart++) {
-    AliPHOSRecParticle * rp = dynamic_cast<AliPHOSRecParticle*>(recParticles->At(recpart));
+    AliPHOSRecParticle  *rp    = dynamic_cast<AliPHOSRecParticle*>(recParticles->At(recpart));
     if (Debug()) 
       rp->Print();
     // Get track segment and EMC rec.point associated with this rec.particle
-    AliPHOSTrackSegment *ts    = static_cast<AliPHOSTrackSegment *>(tsm->GetTrackSegments()->At(rp->GetPHOSTSIndex()));
+    AliPHOSTrackSegment *ts    = static_cast<AliPHOSTrackSegment *>(fTSM->GetTrackSegments()
+                                                                   ->At(rp->GetPHOSTSIndex()));
 
-    AliPHOSEmcRecPoint  *emcRP = static_cast<AliPHOSEmcRecPoint *>(fEmcRecPoints->At(ts->GetEmcIndex()));
+    AliPHOSEmcRecPoint  *emcRP = static_cast<AliPHOSEmcRecPoint *>(fgEMCRecPoints->At(ts->GetEmcIndex()));
     AliESDCaloCluster   *ec    = new AliESDCaloCluster() ; 
     
     Float_t xyz[3];
@@ -232,56 +267,44 @@ void AliPHOSReconstructor::FillESD(TTree* digitsTree, TTree* clustersTree,
     
     AliDebug(2,Form("Global position xyz=(%f,%f,%f)",xyz[0],xyz[1],xyz[2]));
    
-    //Create digits lists
-    Int_t  digitMult  = emcRP->GetDigitsMultiplicity();
-    Int_t *digitsList = emcRP->GetDigitsList();
-    Float_t *rpElist   = emcRP->GetEnergiesList() ;
-    Short_t *amplList  = new Short_t[digitMult];
-    Short_t *timeList  = new Short_t[digitMult];
-    Short_t *digiList  = new Short_t[digitMult];
-
-
-    // Convert Float_t* and Int_t* to Short_t* to save memory
-    for (Int_t iDigit=0; iDigit<digitMult; iDigit++) {
-
-      AliPHOSDigit *digit = static_cast<AliPHOSDigit *>(fDigitsArr->At(digitsList[iDigit]));
-      amplList[iDigit] =
-       (Short_t)(TMath::Min(rpElist[iDigit]*gev500,kBigShort)); // Energy in units of GeV/500
-// We should add here not full energy of digit, but unfolded one, stored in RecPoint
-//       amplList[iDigit] =
-//     (Short_t)(TMath::Min(digit->GetEnergy()*gev500,kBigShort)); // Energy in units of GeV/500
-     timeList[iDigit] =
-       (Short_t)(TMath::Max(-kBigShort,TMath::Min(digit->GetTime()*nsec100,kBigShort))); // time in units of 0.01 ns
-      digiList[iDigit] = (Short_t)(digit->GetId());
+    // Create cell lists
+
+    Int_t     cellMult   = emcRP->GetDigitsMultiplicity();
+    Int_t    *digitsList = emcRP->GetDigitsList();
+    Float_t  *rpElist    = emcRP->GetEnergiesList() ;
+    UShort_t *absIdList  = new UShort_t[cellMult];
+    Double_t *fracList   = new Double_t[cellMult];
+
+    for (Int_t iCell=0; iCell<cellMult; iCell++) {
+      AliPHOSDigit *digit = static_cast<AliPHOSDigit *>(fgDigitsArray->At(digitsList[iCell]));
+      absIdList[iCell] = (UShort_t)(digit->GetId());
+      if (digit->GetEnergy() > 0)
+       fracList[iCell] = rpElist[iCell]/digit->GetEnergy();
+      else
+       fracList[iCell] = 0;
     }
-    
-
 
     //Primaries
     Int_t  primMult  = 0;
     Int_t *primList =  emcRP->GetPrimaries(primMult);
-        
+
     // fills the ESDCaloCluster
     ec->SetClusterType(AliESDCaloCluster::kPHOSCluster);
-    ec->SetPosition(xyz);                 //rec.point position in MARS
-    ec->SetE(rp->Energy());         //total particle energy
+    ec->SetPosition(xyz);                       //rec.point position in MARS
+    ec->SetE(rp->Energy());                     //total particle energy
     ec->SetClusterDisp(emcRP->GetDispersion()); //cluster dispersion
     ec->SetPid(rp->GetPID()) ;                  //array of particle identification
     ec->SetM02(emcRP->GetM2x()) ;               //second moment M2x
     ec->SetM20(emcRP->GetM2z()) ;               //second moment M2z
     ec->SetNExMax(emcRP->GetNExMax());          //number of local maxima
-    ec->SetEmcCpvDistance(ts->GetCpvDistance("r"));                  //Only radius, what about separate x,z????
+    ec->SetEmcCpvDistance(ts->GetCpvDistance("r")); //Only radius, what about separate x,z????
     ec->SetClusterChi2(-1);                     //not yet implemented
-    ec->SetM11(-1) ;                            //not yet implemented
-    //Digits Lists
-    TArrayS arrayAmpList(digitMult,amplList);
-    TArrayS arrayTimeList(digitMult,timeList);
-    TArrayS arrayIndexList(digitMult,digiList);
-    ec->AddDigitAmplitude(arrayAmpList);
-    ec->AddDigitTime(arrayTimeList);
-    ec->AddDigitIndex(arrayIndexList);
+    ec->SetTOF(emcRP->GetTime()); //Time of flight
+
+    //Cells contributing to clusters
+    ec->SetNCells(cellMult);
+    ec->SetCellsAbsId(absIdList);
+    ec->SetCellsAmplitudeFraction(fracList);
 
     //Distance to the nearest bad crystal
     ec->SetDistanceToBadChannel(emcRP->GetDistanceToBadCrystal()); 
@@ -296,18 +319,15 @@ void AliPHOSReconstructor::FillESD(TTree* digitsTree, TTree* clustersTree,
     //ec->AddTracksMatched(arrayTrackMatched);
     
     // add the track to the esd object
+
     esd->AddCaloCluster(ec);
     delete ec;   
-    delete [] amplList;
-    delete [] timeList;
-    delete [] digiList;    
+    delete [] fracList;
+    delete [] absIdList;
   }
-  fDigitsArr   ->Delete();
-  delete fDigitsArr;
-  fEmcRecPoints->Delete();
-  delete fEmcRecPoints;
-  delete tsm;
-  delete pid;
+  fgDigitsArray ->Delete();
+  fgEMCRecPoints->Delete();
+  recParticles  ->Delete();
 }
 
 //____________________________________________________________________________
@@ -338,15 +358,12 @@ void  AliPHOSReconstructor::ConvertDigits(AliRawReader* rawReader, TTree* digits
 
   if(strcmp(fgkRecoParamEmc->DecoderVersion(),"v1")==0) 
     dc=new AliPHOSRawDecoderv1(rawReader,mapping);
-  else
-    dc=new AliPHOSRawDecoder(rawReader,mapping);
-
-  TString option = GetOption();
-  if (option.Contains("OldRCUFormat"))
-    dc->SetOldRCUFormat(kTRUE);
-  else
-    dc->SetOldRCUFormat(kFALSE);
-  
+  else 
+    if(strcmp(fgkRecoParamEmc->DecoderVersion(),"v2")==0) 
+      dc=new AliPHOSRawDecoderv2(rawReader,mapping);
+    else
+      dc=new AliPHOSRawDecoder(rawReader,mapping);
+
   dc->SubtractPedestals(fgkRecoParamEmc->SubtractPedestals());
   
   TClonesArray *digits = new TClonesArray("AliPHOSDigit",1);
@@ -354,40 +371,13 @@ void  AliPHOSReconstructor::ConvertDigits(AliRawReader* rawReader, TTree* digits
   Int_t bufsize = 32000;
   digitsTree->Branch("PHOS", &digits, bufsize);
 
-  AliPHOSRawDigiProducer pr;
+  AliPHOSRawDigiProducer pr(fgkRecoParamEmc,fgkRecoParamCpv);
   pr.MakeDigits(digits,dc);
 
   delete dc ;
 
-  //ADC counts -> GeV
-  if(strcmp(fgkRecoParamEmc->DecoderVersion(),"v1")==0){ //"Energy" calculated as fit
-    for(Int_t i=0; i<digits->GetEntries(); i++) {
-      AliPHOSDigit* digit = (AliPHOSDigit*)digits->At(i);
-      digit->SetEnergy(digit->GetEnergy()*0.005); //We assume here 5 MeV/ADC channel
-      digit->SetTime(digit->GetTime()*1.e-7) ;    //Here we assume sample step==100 ns TO BE FIXED!!!!!!!!!!!!!
-    }
-  }
-  else{ //Digits energy calculated as maximal energy
-    for(Int_t i=0; i<digits->GetEntries(); i++) {
-      AliPHOSDigit* digit = (AliPHOSDigit*)digits->At(i);
-      digit->SetEnergy(digit->GetEnergy()/AliPHOSPulseGenerator::GeV2ADC());
-    }
-  }
-  
-  // Clean up digits below the noise threshold
-  // Assuming the digit noise to be 4 MeV, we suppress digits within
-  // 3-sigma of the noise.
-  // This parameter should be passed via AliPHOSRecoParamEmc later
-
-  const Double_t emcDigitThreshold = 0.012;
-  for(Int_t i=0; i<digits->GetEntries(); i++) {
-    AliPHOSDigit* digit = (AliPHOSDigit*)digits->At(i);
-    if(digit->GetEnergy() < emcDigitThreshold)
-      digits->RemoveAt(i) ;
-  }
-  digits->Compress() ;  
-
   //!!!!for debug!!!
+/*
   Int_t modMax=-111;
   Int_t colMax=-111;
   Int_t rowMax=-111;
@@ -408,7 +398,7 @@ void  AliPHOSReconstructor::ConvertDigits(AliRawReader* rawReader, TTree* digits
 
   AliDebug(1,Form("Digit with max. energy:  modMax %d colMax %d rowMax %d  eMax %f\n\n",
                  modMax,colMax,rowMax,eMax));
-
+*/
   digitsTree->Fill();
   digits->Delete();
   delete digits;