]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - PHOS/AliPHOSSDigitizer.cxx
Elaborating split mode to write data only to the split files
[u/mrichter/AliRoot.git] / PHOS / AliPHOSSDigitizer.cxx
index 0c692bd62668119dd3bfa60e5d59d95994996dff..18d3e71d93fec3336b1102ce426fc9cf4b48ea70 100644 (file)
@@ -13,6 +13,7 @@
  * provided "as is" without express or implied warranty.                  *
  **************************************************************************/
 
+
 /* $Id$ */
 
 //_________________________________________________________________________
 #include "TROOT.h"
 #include "TFolder.h"
 #include "TBenchmark.h"
+#include "TGeometry.h"
+
 // --- Standard library ---
 #include <iomanip.h>
 
 // --- AliRoot header files ---
 #include "AliRun.h"
+#include "AliHeader.h"
 #include "AliPHOSDigit.h"
+#include "AliPHOSGeometry.h"
 #include "AliPHOSGetter.h"
 #include "AliPHOSHit.h"
 #include "AliPHOSSDigitizer.h"
 
-
 ClassImp(AliPHOSSDigitizer)
 
            
 //____________________________________________________________________________ 
-  AliPHOSSDigitizer::AliPHOSSDigitizer():TTask("","") 
-{
+  AliPHOSSDigitizer::AliPHOSSDigitizer():TTask("","") {
   // ctor
-  fA             = 0;
-  fB             = 10000000.;
-  fPrimThreshold = 0.01 ;
-  fSDigitsInRun  = 0 ; 
+  InitParameters() ;
+  fDefaultInit = kTRUE ; 
 }
 
 //____________________________________________________________________________ 
-AliPHOSSDigitizer::AliPHOSSDigitizer(const char * headerFile, const char * sDigitsTitle):TTask(sDigitsTitle, headerFile)
+AliPHOSSDigitizer::AliPHOSSDigitizer(const char * headerFile, const char * sDigitsTitle, const Bool_t toSplit):
+TTask(sDigitsTitle, headerFile)
 {
   // ctor
-  fA             = 0;
-  fB             = 10000000.;
-  fPrimThreshold = 0.01 ;
-  fSDigitsInRun  = 0 ; 
+  InitParameters() ; 
+  fToSplit = toSplit ;
   Init();
+  fDefaultInit = kFALSE ; 
 }
 
+//____________________________________________________________________________ 
+AliPHOSSDigitizer::~AliPHOSSDigitizer()
+{
+  // dtor
+  
+  fSplitFile = 0 ; 
+}
 
 //____________________________________________________________________________ 
 void AliPHOSSDigitizer::Init()
@@ -105,21 +113,55 @@ void AliPHOSSDigitizer::Init()
   
   if( strcmp(GetTitle(), "") == 0 )
     SetTitle("galice.root") ;
-  
-  AliPHOSGetter * gime = AliPHOSGetter::GetInstance(GetTitle(), GetName()) ;     
+
+  AliPHOSGetter * gime = AliPHOSGetter::GetInstance(GetTitle(), GetName(),fToSplit) ;  
   if ( gime == 0 ) {
-    cerr << "ERROR: AliPHOSSDigitizer::Init -> Could not obtain the Getter object !" << endl ; 
+    cerr << "ERROR: AliPHOSSDigitizer::Init -> Could not obtain the Getter object !" 
+        << endl ; 
     return ;
   } 
   
-  //add Task to //YSAlice/tasks/SDiditizer/PHOS
-  TTask * aliceSD  = (TTask*)gROOT->FindObjectAny("YSAlice/tasks/SDigitizer") ; 
-  TTask * phosSD   = (TTask*)aliceSD->GetListOfTasks()->FindObject("PHOS") ;
-  if ( ! phosSD->GetListOfTasks()->FindObject(GetName()) ) 
-    phosSD->Add(this) ; 
-  // create a folder on the white board //YSAlice/WhiteBoard/SDigits/PHOS/headerFile/sdigitsTitle
-  gime->Post(GetTitle(), "S",  GetName() ) ; 
-    
+  gime->PostSDigits( GetName(), GetTitle() ) ; 
+
+  fSplitFile = 0 ;
+  if(fToSplit){
+    // construct the name of the file as /path/PHOS.SDigits.root
+    // First - extract full path if necessary
+    TString sDigitsFileName(GetTitle()) ;
+    Ssiz_t islash = sDigitsFileName.Last('/') ;
+    if(islash<sDigitsFileName.Length())
+      sDigitsFileName.Remove(islash+1,sDigitsFileName.Length()) ;
+    else
+      sDigitsFileName="" ;
+    // Next - append the file name 
+    sDigitsFileName+="PHOS.SDigits." ;
+    if((strcmp(GetName(),"Default")!=0)&&(strcmp(GetName(),"")!=0)){
+      sDigitsFileName+=GetName() ;
+      sDigitsFileName+="." ;
+    }
+    sDigitsFileName+="root" ;
+    // Finally - check if the file already opened or open the file
+    fSplitFile = static_cast<TFile*>(gROOT->GetFile(sDigitsFileName.Data()));   
+    if(!fSplitFile)
+      fSplitFile =  TFile::Open(sDigitsFileName.Data(),"update") ;
+  }
+
+  TString sdname(GetName() );
+  sdname.Append(":") ;
+  sdname.Append(GetTitle() ) ;
+  SetName(sdname) ;
+  gime->PostSDigitizer(this) ;
+}
+
+//____________________________________________________________________________ 
+void AliPHOSSDigitizer::InitParameters()
+{ 
+  fA             = 0;
+  fB             = 10000000.;
+  fPrimThreshold = 0.01 ;
+  fSDigitsInRun  = 0 ;
+  fSplitFile     = 0 ; 
+  fToSplit       = kFALSE ;
 }
 
 //____________________________________________________________________________
@@ -136,142 +178,88 @@ void AliPHOSSDigitizer::Exec(Option_t *option)
 
   if(strstr(option,"tim"))
     gBenchmark->Start("PHOSSDigitizer");
-
-  //Check, if this branch already exits
-  TObjArray * lob = (TObjArray*)gAlice->TreeS()->GetListOfBranches() ;
-  TIter next(lob) ; 
-  TBranch * branch = 0 ;  
-  Bool_t phosfound = kFALSE, sdigitizerfound = kFALSE ; 
-  
-  while ( (branch = (TBranch*)next()) && (!phosfound || !sdigitizerfound) ) {
-    if ( (strcmp(branch->GetName(), "PHOS")==0) && (strcmp(branch->GetTitle(), GetName())==0) ) 
-      phosfound = kTRUE ;
-    
-    else if ( (strcmp(branch->GetName(), "AliPHOSSDigitizer")==0) && (strcmp(branch->GetTitle(), GetName())==0) ) 
-      sdigitizerfound = kTRUE ; 
-  }
-
-  if ( phosfound || sdigitizerfound ) {
-    cerr << "WARNING: AliPHOSSDigitizer::Exec -> SDigits and/or SDigitizer branch with name " << GetName() 
-        << " already exits" << endl ;
-    return ; 
-  }   
-
-    
-  AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ; 
-
-  TClonesArray * hits = gime->Hits() ; 
-
-  Int_t nevents = (Int_t) gAlice->TreeE()->GetEntries() ; 
   
+  //Check, if this branch already exits
+  AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ;
+  if(gime->BranchExists("SDigits") ) 
+    return;   
+
+  TString sdname(GetName()) ;
+  sdname.Remove(sdname.Index(GetTitle())-1) ;
+   
+  Int_t nevents = gime->MaxEvent() ; 
   Int_t ievent ;
   for(ievent = 0; ievent < nevents; ievent++){
-    gAlice->GetEvent(ievent) ;
-    gAlice->SetEvent(ievent) ;
-    
-    if(gAlice->TreeH()==0){
-      cerr << "ERROR: AliPHOSSDigitizer::Exec There is no Hit Tree" << endl;
-      return ;
-    }
-    
-    //set address of the hits 
-    TBranch * branch = gAlice->TreeH()->GetBranch("PHOS");
-    if (branch) 
-      branch->SetAddress(&hits);
-    else{
-      cerr << "ERROR: AliPHOSSDigitizer::Exec -> No branch PHOS in TreeH " << endl ;
-      cerr << "                                 Do nothing " << endl ;
-      return ;
-    }
-
-    TClonesArray * sdigits = gime->SDigits(GetName()) ;
-
+    gime->Event(ievent,"H") ;
+    const TClonesArray * hits = gime->Hits() ;
+    TClonesArray * sdigits = gime->SDigits(sdname.Data()) ;
     sdigits->Clear();
     Int_t nSdigits = 0 ;
     
-    
     //Now make SDigits from hits, for PHOS it is the same, so just copy    
-    Int_t itrack ;
-    for (itrack=0; itrack < gAlice->GetNtrack(); itrack++){
-  
-      //=========== Get the PHOS branch from Hits Tree for the Primary track itrack
-      branch->GetEntry(itrack,0);
+    Int_t nPrim =  static_cast<Int_t>((gAlice->TreeH())->GetEntries()) ; 
+    // Attention nPrim is the number of primaries tracked by Geant 
+    // and this number could be different to the number of Primaries in TreeK;
+    Int_t iprim ;
+    for (iprim = 0 ; iprim < nPrim ; iprim ++) { 
+      //=========== Get the PHOS branch from Hits Tree for the Primary iprim
+      gime->Track(iprim) ;
       Int_t i;
       for ( i = 0 ; i < hits->GetEntries() ; i++ ) {
-       const AliPHOSHit * hit = gime->Hit(i) ;
+       AliPHOSHit * hit = dynamic_cast<AliPHOSHit *>(hits->At(i)) ;
        // Assign primary number only if contribution is significant
-
+       
        if( hit->GetEnergy() > fPrimThreshold)
-         new((*sdigits)[nSdigits]) AliPHOSDigit( hit->GetPrimary(), hit->GetId(), Digitize( hit->GetEnergy() ) ) ;
+         new((*sdigits)[nSdigits]) AliPHOSDigit(hit->GetPrimary(),hit->GetId(),
+                                                Digitize(hit->GetEnergy()), hit->GetTime()) ;
        else
-         new((*sdigits)[nSdigits]) AliPHOSDigit( -1               , hit->GetId(), Digitize( hit->GetEnergy() ) ) ;
-       
-       nSdigits++ ;  
+         new((*sdigits)[nSdigits]) AliPHOSDigit( -1              , hit->GetId(), 
+                                                 Digitize(hit->GetEnergy()), hit->GetTime()) ;
+       nSdigits++ ;    
        
-      } 
-
-    } // loop over tracks
+      }
+      
+    } // loop over iprim
     
     sdigits->Sort() ;
     
     nSdigits = sdigits->GetEntriesFast() ;
+    fSDigitsInRun += nSdigits ;  
     sdigits->Expand(nSdigits) ;
+    
     Int_t i ;
     for (i = 0 ; i < nSdigits ; i++) { 
-      AliPHOSDigit * digit = (AliPHOSDigit *) sdigits->At(i) ; 
+      AliPHOSDigit * digit = dynamic_cast<AliPHOSDigit *>(sdigits->At(i)) ; 
       digit->SetIndexInList(i) ;     
     }
 
-    if(gAlice->TreeS() == 0)
-      gAlice->MakeTree("S") ;
+    //Now write SDigits
     
-    //Make (if necessary) branches    
-    char * file =0;
-    if(gSystem->Getenv("CONFIG_SPLIT_FILE")){ //generating file name
-      file = new char[strlen(gAlice->GetBaseFile())+20] ;
-      sprintf(file,"%s/PHOS.SDigits.root",gAlice->GetBaseFile()) ;
-    }
-    
-    TDirectory *cwd = gDirectory;
+    if((gAlice->TreeS() == 0)|| (fSplitFile))  
+      gAlice->MakeTree("S", fSplitFile);
     
+    if(fSplitFile)
+      fSplitFile->cd() ;
+
     //First list of sdigits
-    Int_t bufferSize = 32000 ;    
+    Int_t bufferSize = 32000 ;
     TBranch * sdigitsBranch = gAlice->TreeS()->Branch("PHOS",&sdigits,bufferSize);
-    sdigitsBranch->SetTitle(GetName());
-    if (file) {
-      sdigitsBranch->SetFile(file);
-      TIter next( sdigitsBranch->GetListOfBranches());
-      TBranch * subbr;
-      while ((subbr=(TBranch*)next())) {
-       subbr->SetFile(file);
-      }   
-      cwd->cd();
-    } 
-      
+    sdigitsBranch->SetTitle(sdname);
+    
     //Next - SDigitizer
     Int_t splitlevel = 0 ;
     AliPHOSSDigitizer * sd = this ;
     TBranch * sdigitizerBranch = gAlice->TreeS()->Branch("AliPHOSSDigitizer","AliPHOSSDigitizer",
-                                              &sd,bufferSize,splitlevel); 
-    sdigitizerBranch->SetTitle(GetName());
-    if (file) {
-      sdigitizerBranch->SetFile(file);
-      TIter next( sdigitizerBranch->GetListOfBranches());
-      TBranch * subbr ;
-      while ((subbr=(TBranch*)next())) {
-       subbr->SetFile(file);
-      }   
-      cwd->cd();
-      delete file;
-    }
-
+                                                        &sd,bufferSize,splitlevel);
+    sdigitizerBranch->SetTitle(sdname);
+    
     sdigitsBranch->Fill() ;
     sdigitizerBranch->Fill() ;
-    gAlice->TreeS()->Write(0,TObject::kOverwrite) ;
-    
+
+    gAlice->TreeS()->AutoSave() ;
+        
     if(strstr(option,"deb"))
       PrintSDigits(option) ;
-    
   }
   
   if(strstr(option,"tim")){
@@ -281,9 +269,8 @@ void AliPHOSSDigitizer::Exec(Option_t *option)
         <<  gBenchmark->GetCpuTime("PHOSSDigitizer")/nevents << " seconds per event " << endl ;
     cout << endl ;
   }
-  
-  
 }
+
 //__________________________________________________________________
 void AliPHOSSDigitizer::SetSDigitsBranch(const char * title )
 {
@@ -292,8 +279,10 @@ void AliPHOSSDigitizer::SetSDigitsBranch(const char * title )
   TString stitle(title) ;
 
   // check if branch with title already exists
-  TBranch * sdigitsBranch    =  (TBranch*)gAlice->TreeS()->GetListOfBranches()->FindObject("PHOS") ; 
-  TBranch * sdigitizerBranch =  (TBranch*)gAlice->TreeS()->GetListOfBranches()->FindObject("AliPHOSSDigitizer") ;
+  TBranch * sdigitsBranch    = 
+    static_cast<TBranch*>(gAlice->TreeS()->GetListOfBranches()->FindObject("PHOS")) ; 
+  TBranch * sdigitizerBranch =  
+    static_cast<TBranch*>(gAlice->TreeS()->GetListOfBranches()->FindObject("AliPHOSSDigitizer")) ;
   const char * sdigitsTitle    = sdigitsBranch ->GetTitle() ;  
   const char * sdigitizerTitle = sdigitizerBranch ->GetTitle() ;
   if ( stitle.CompareTo(sdigitsTitle)==0 || stitle.CompareTo(sdigitizerTitle)==0 ){
@@ -307,15 +296,59 @@ void AliPHOSSDigitizer::SetSDigitsBranch(const char * title )
     
   // Post to the WhiteBoard
   AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ; 
-  gime->Post(GetTitle(), "S", GetName()) ; 
+  gime->PostSDigits( title, GetTitle()) ; 
 }
 
+// //__________________________________________________________________
+// void AliPHOSSDigitizer::SetSplitFile(const TString splitFileName) 
+// {
+//   // Diverts the SDigits in a file separate from the hits file
+  
+//   TDirectory * cwd = gDirectory ;
+  
+//   if ( !(gAlice->GetTreeSFileName() == splitFileName) ) {
+//     if (gAlice->GetTreeSFile() ) 
+//       gAlice->GetTreeSFile()->Close() ; 
+//   }
+  
+//   fSplitFile = gAlice->InitTreeFile("S",splitFileName.Data());
+//   fSplitFile->cd() ; 
+//   gAlice->Write(0, TObject::kOverwrite);
+  
+//   TTree *treeE  = gAlice->TreeE();
+//   if (!treeE) {
+//     cerr << "ERROR: AliPHOSSDigitizer::SetSPlitFile -> No TreeE found "<<endl;
+//     abort() ;
+//   }      
+  
+//   // copy TreeE
+//     AliHeader *header = new AliHeader();
+//     treeE->SetBranchAddress("Header", &header);
+//     treeE->SetBranchStatus("*",1);
+//     TTree *treeENew =  treeE->CloneTree();
+//     treeENew->Write(0, TObject::kOverwrite);
+  
+
+//   // copy AliceGeom
+//     TGeometry *AliceGeom = static_cast<TGeometry*>(cwd->Get("AliceGeom"));
+//     if (!AliceGeom) {
+//       cerr << "ERROR: AliPHOSSDigitizer::SetSPlitFile -> AliceGeom was not found in the input file "<<endl;
+//       abort() ;
+//     }
+//     AliceGeom->Write(0, TObject::kOverwrite);
+
+//   gAlice->MakeTree("S",fSplitFile);
+//   cwd->cd() ; 
+//   cout << "INFO: AliPHOSSDigitizer::SetSPlitMode -> SDigits will be stored in " << splitFileName.Data() << endl ; 
+
+// }
+
 //__________________________________________________________________
 void AliPHOSSDigitizer::Print(Option_t* option)const
 {
   // Prints parameters of SDigitizer
   cout << "------------------- "<< GetName() << " -------------" << endl ;
-  cout << "   Writing SDigitis to branch with title  " << GetName() << endl ;
+  cout << "   Writing SDigits to branch with title  " << GetName() << endl ;
   cout << "   with digitization parameters  A = " << fA << endl ;
   cout << "                                 B = " << fB << endl ;
   cout << "   Threshold for Primary assignment= " << fPrimThreshold << endl ; 
@@ -334,38 +367,67 @@ Bool_t AliPHOSSDigitizer::operator==( AliPHOSSDigitizer const &sd )const
     return kFALSE ;
 }
 //__________________________________________________________________
+//__________________________________________________________________
 void AliPHOSSDigitizer::PrintSDigits(Option_t * option)
 {
   // Prints list of digits produced in the current pass of AliPHOSDigitizer
 
+
   AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ; 
-  TClonesArray * sdigits = gime->SDigits(GetName()) ; 
+  TString sdname(GetName()) ;
+  sdname.Remove(sdname.Index(GetTitle())-1) ;
+  const TClonesArray * sdigits = gime->SDigits(sdname.Data()) ; 
 
-  cout << "AliPHOSSDigitizer: event "<<gAlice->GetEvNumber() << endl ;
-  cout << "       Number of entries in SDigits list  " << sdigits->GetEntriesFast() << endl ;
+  cout << "AliPHOSSDigitiser: event " << gAlice->GetEvNumber() << endl ;
+  cout << "      Number of entries in SDigits list " << sdigits->GetEntriesFast() << endl ;
   cout << endl ;
-
-  fSDigitsInRun +=  sdigits->GetEntriesFast() ; 
-  
-  if(strstr(option,"all")){// print all digits
+  if(strstr(option,"all")||strstr(option,"EMC")){
     
     //loop over digits
     AliPHOSDigit * digit;
-    cout << "SDigit Id " << " Amplitude " <<  " Index "  <<  " Nprim " << " Primaries list " <<  endl;    
+    cout << "EMC sdigits " << endl ;
+    cout << "Digit Id    Amplitude     Index     Nprim  Primaries list " <<  endl;      
+    Int_t maxEmc = gime->PHOSGeometry()->GetNModules()*gime->PHOSGeometry()->GetNCristalsInModule() ;
     Int_t index ;
-    for (index = 0 ; index < sdigits->GetEntries() ; index++) {
-      digit = (AliPHOSDigit * )  sdigits->At(index) ;
-      cout << setw(8)  <<  digit->GetId() << " "  <<   setw(3)  <<  digit->GetAmp() <<   "  "  
-          << setw(6)  <<  digit->GetIndexInList() << "  "   
-          << setw(5)  <<  digit->GetNprimary() <<"  ";
+    for (index = 0 ; (index < sdigits->GetEntriesFast()) && 
+        ((dynamic_cast<AliPHOSDigit *> (sdigits->At(index)))->GetId() <= maxEmc) ; index++) {
+      digit = dynamic_cast<AliPHOSDigit *>( sdigits->At(index) ) ;
+      if(digit->GetNprimary() == 0) continue;
+      cout << setw(6)  <<  digit->GetId() << "   "  <<         setw(10)  <<  digit->GetAmp() <<   "    "  
+          << setw(6)  <<  digit->GetIndexInList() << "    "   
+          << setw(5)  <<  digit->GetNprimary() <<"    ";
       
       Int_t iprimary;
       for (iprimary=0; iprimary<digit->GetNprimary(); iprimary++)
-       cout << setw(5)  <<  digit->GetPrimary(iprimary+1) << "  ";
+       cout << setw(5)  <<  digit->GetPrimary(iprimary+1) << "    ";
       cout << endl;     
-    }
+    }    
+    cout << endl;
+  }
+
+  if(strstr(option,"all")||strstr(option,"CPV")){
     
+    //loop over CPV digits
+    AliPHOSDigit * digit;
+    cout << "CPV sdigits " << endl ;
+    cout << "Digit Id    Amplitude     Index     Nprim  Primaries list " <<  endl;      
+    Int_t maxEmc = gime->PHOSGeometry()->GetNModules()*gime->PHOSGeometry()->GetNCristalsInModule() ;
+    Int_t index ;
+    for (index = 0 ; index < sdigits->GetEntriesFast(); index++) {
+      digit = dynamic_cast<AliPHOSDigit *>( sdigits->At(index) ) ;
+      if(digit->GetId() > maxEmc){
+       cout << setw(6)  <<  digit->GetId() << "   "  <<        setw(10)  <<  digit->GetAmp() <<   "    "  
+            << setw(6)  <<  digit->GetIndexInList() << "    "   
+            << setw(5)  <<  digit->GetNprimary() <<"    ";
+       
+       Int_t iprimary;
+       for (iprimary=0; iprimary<digit->GetNprimary(); iprimary++)
+         cout << setw(5)  <<  digit->GetPrimary(iprimary+1) << "    ";
+       cout << endl;    
+      }    
+    }
   }
+
 }
 
 //____________________________________________________________________________