]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - PHOS/AliPHOSDigitizer.cxx
Elaborating split mode to write data only to the split files
[u/mrichter/AliRoot.git] / PHOS / AliPHOSDigitizer.cxx
index 9edd6e8a07ce99b95c4e73b2505c73eca3720367..bbb894ac1220b6886d001891030e67243af0a290 100644 (file)
@@ -61,6 +61,7 @@
 #include "TROOT.h"
 #include "TFolder.h"
 #include "TObjString.h"
+#include "TGeometry.h"
 #include "TBenchmark.h"
 
 // --- Standard library ---
@@ -69,6 +70,8 @@
 // --- AliRoot header files ---
 
 #include "AliRun.h"
+#include "AliHeader.h"
+#include "AliStream.h"
 #include "AliRunDigitizer.h"
 #include "AliPHOSDigit.h"
 #include "AliPHOS.h"
@@ -85,45 +88,54 @@ ClassImp(AliPHOSDigitizer)
   AliPHOSDigitizer::AliPHOSDigitizer() 
 {
   // ctor
-
-  fPinNoise           = 0.01 ;
-  fEMCDigitThreshold  = 0.01 ;
-  fCPVNoise           = 0.01;
-  fCPVDigitThreshold  = 0.09 ;
-  fTimeResolution     = 0.5e-9 ;
-  fTimeSignalLength   = 1.0e-9 ;
-  fDigitsInRun  = 0 ; 
-  fADCchanelEmc = 0.0015;        // width of one ADC channel in GeV
-  fADCpedestalEmc = 0.005 ;      //
-  fNADCemc = (Int_t) TMath::Power(2,16) ;  // number of channels in EMC ADC
-
-  fADCchanelCpv = 0.0012 ;          // width of one ADC channel in CPV 'popugais'
-  fADCpedestalCpv = 0.012 ;         // 
-  fNADCcpv = (Int_t) TMath::Power(2,12);      // number of channels in CPV ADC
-
-  fTimeThreshold = 0.001*10000000 ; //Means 1 MeV in terms of SDigits amplitude
-  fARD = 0 ;                        // We work in the standalong mode
-}
+  InitParameters() ; 
+  fDefaultInit = kTRUE ;
+  fManager = 0 ;                     // We work in the standalong mode
+  // fHitsFileName    = "" ;
+  // fSDigitsFileName = "" ; 
+ }
 
 //____________________________________________________________________________ 
-AliPHOSDigitizer::AliPHOSDigitizer(const char *headerFile,const char * name)
+AliPHOSDigitizer::AliPHOSDigitizer(const char *headerFile, const char * name, const Bool_t toSplit)
 {
   // ctor
-  SetName(name) ;
+
   SetTitle(headerFile) ;
-  fARD = 0 ;                     // We work in the standalong mode
+  SetName(name) ;
+  fManager = 0 ;                     // We work in the standalong mode
+  fSplitFile= 0 ; 
+  InitParameters() ; 
+  fToSplit = toSplit ;
   Init() ;
-  
+  fDefaultInit = kFALSE ; 
+  //  fSDigitsFileName = headerFile ; 
+  //  AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ; 
+  //  gime->Event(0, "S") ; 
+  //  fHitsFileName = gime->SDigitizer()->GetTitle() ; 
 }
 
 //____________________________________________________________________________ 
-AliPHOSDigitizer::AliPHOSDigitizer(AliRunDigitizer * ard)
+AliPHOSDigitizer::AliPHOSDigitizer(AliRunDigitizer * ard):AliDigitizer(ard)
 {
   // ctor
-  fARD = ard ;
-  SetName("Default");
-  SetTitle("aliroot") ;
-  Init() ;
+  SetTitle(ard->GetInputFileName(0,0)) ;
+  InitParameters() ; 
+  fDefaultInit = kFALSE ; 
+  fSplitFile   = 0 ; 
+
+  if (ard->GetOutputFile()) {
+    SetName(ard->GetOutputFile().Data());
+    fToSplit = kTRUE ;
+  } else {
+    SetName("Default") ;
+    fToSplit = kFALSE ;
+  }
+
+//   fSDigitsFileName = fManager->GetInputFileName(0, 0) ;
+//   AliPHOSGetter * gime = AliPHOSGetter::GetInstance(fSDigitsFileName, GetName()) ; 
+//   gime->Event(0,"S") ; 
+//  fHitsFileName = gime->SDigitizer()->GetTitle() ; 
   
 }
 
@@ -131,8 +143,26 @@ AliPHOSDigitizer::AliPHOSDigitizer(AliRunDigitizer * ard)
   AliPHOSDigitizer::~AliPHOSDigitizer()
 {
   // dtor
-
-
+  // fDefaultInit = kTRUE if Digitizer created by default ctor (to get just the parameters)
+  
+//   if (!fDefaultInit) {
+//     AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ; 
+//    // remove the task from the folder list
+//    gime->RemoveTask("S",GetName()) ;
+//    gime->RemoveTask("D",GetName()) ;
+   
+//    // remove the Digits from the folder list
+//    gime->RemoveObjects("D", GetName()) ;
+   
+//    // remove the SDigits from the folder list
+//    gime->RemoveSDigits() ;
+   
+//    // Delete gAlice
+//    gime->CloseFile() ; 
+   
+   fSplitFile = 0 ; 
+   // }
 }
 
 //____________________________________________________________________________
@@ -146,17 +176,12 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
   // This design avoids scanning over the list of digits to add 
   // contribution to new SDigits only.
 
-  if( strcmp(GetName(), "") == 0 )
-    Init() ;
-
   AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ; 
   TClonesArray * digits = gime->Digits(GetName()) ; 
-  AliPHOSSDigitizer * sdiz = gime->SDigitizer(GetName()) ; 
 
   digits->Clear() ;
 
   const AliPHOSGeometry *geom = gime->PHOSGeometry() ; 
-
   //Making digits with noise, first EMC
   Int_t nEMC = geom->GetNModules()*geom->GetNPhi()*geom->GetNZ();
   
@@ -169,8 +194,6 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
 
   digits->Expand(nCPV) ;
 
-
-  // sdigitize random gaussian noise and add it to all cells (EMCA+CPV+PPSD) 
   // get first the sdigitizer from the tasks list (must have same name as the digitizer)
   const AliPHOSSDigitizer * sDigitizer = gime->SDigitizer(GetName()); 
   if ( !sDigitizer) {
@@ -185,20 +208,23 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
   TClonesArray * sdigits = 0 ;
   Int_t input = 0 ;
   TObjArray * sdigArray = new TObjArray(2) ;
-  while ( (folder = (TFolder*)next()) ) 
+  while ( (folder = (TFolder*)next()) ) 
     if ( (sdigits = (TClonesArray*)folder->FindObject(GetName()) ) ) {
-      cout << "INFO: AliPHOSDigitizer::Digitize -> Adding SDigits " 
-          << GetName() << " from " << folder->GetName() << endl ; 
+      TString fileName(folder->GetName()) ;
+      fileName.ReplaceAll("_","/") ;
+//       cout << "INFO: AliPHOSDigitizer::Digitize -> Adding SDigits " 
+//        << GetName() << " from " << fileName << endl ; 
       sdigArray->AddAt(sdigits, input) ;
       input++ ;
     }
+  }
 
   //Find the first crystall with signal
   Int_t nextSig = 200000 ; 
   Int_t i;
   for(i=0; i<input; i++){
     sdigits = (TClonesArray *)sdigArray->At(i) ;
-    if ( !sdigits->GetEntries() )
+    if ( !sdigits->GetEntriesFast() )
       continue ; 
     Int_t curNext = ((AliPHOSDigit *)sdigits->At(0))->GetId() ;
      if(curNext < nextSig) 
@@ -218,10 +244,10 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
     Float_t noise = gRandom->Gaus(0., fPinNoise) ; 
     new((*digits)[absID-1]) AliPHOSDigit( -1,absID,sDigitizer->Digitize(noise), TimeOfNoise() ) ;
     //look if we have to add signal?
+    digit = (AliPHOSDigit *) digits->At(absID-1) ;
     if(absID==nextSig){
       //Add SDigits from all inputs 
-      digit = (AliPHOSDigit *) digits->At(absID-1) ;
-
       ticks->Clear() ;
       Int_t contrib = 0 ;
       Float_t a = digit->GetAmp() ;
@@ -241,8 +267,8 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
        while(curSDigit && curSDigit->GetId() == absID){           
          //Shift primary to separate primaries belonging different inputs
          Int_t primaryoffset ;
-         if(fARD)
-           primaryoffset = fARD->GetMask(i) ; 
+         if(fManager)
+           primaryoffset = fManager->GetMask(i) ; 
          else
            primaryoffset = 10000000*i ;
          curSDigit->ShiftPrimary(primaryoffset) ;
@@ -297,12 +323,13 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
          curSDigit = (AliPHOSDigit*)((TClonesArray *)sdigArray->At(i))->At(index[i]) ;         
        else
          curSDigit = 0 ;
+
        //May be several digits will contribute from the same input
        while(curSDigit && curSDigit->GetId() == absID){           
          //Shift primary to separate primaries belonging different inputs
          Int_t primaryoffset ;
-         if(fARD)
-           primaryoffset = fARD->GetMask(i) ; 
+         if(fManager)
+           primaryoffset = fManager->GetMask(i) ; 
          else
            primaryoffset = 10000000*i ;
          curSDigit->ShiftPrimary(primaryoffset) ;
@@ -316,8 +343,9 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
            curSDigit = 0 ;
        }
       }
-      
+
       //Find next signal module
+      nextSig = 200000 ;
       for(i=0; i<input; i++){
        sdigits = (TClonesArray *)sdigArray->At(i) ;
        Int_t curNext = nextSig ;
@@ -333,17 +361,18 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
   
   
   //remove digits below thresholds
-  for(absID = 0; absID < nEMC ; absID++){
-    digit = (AliPHOSDigit*) digits->At(absID) ;
+  for(i = 0; i < nEMC ; i++){
+    digit = (AliPHOSDigit*) digits->At(i) ;
     if(sDigitizer->Calibrate( digit->GetAmp() ) < fEMCDigitThreshold)
-      digits->RemoveAt(absID) ;
+      digits->RemoveAt(i) ;
     else
       digit->SetTime(gRandom->Gaus(digit->GetTime(),fTimeResolution) ) ;
   }
 
-  for(absID = nEMC; absID < nCPV ; absID++)
-    if(sDigitizer->Calibrate(((AliPHOSDigit*)digits->At(absID))->GetAmp()) < fCPVDigitThreshold)
-      digits->RemoveAt(absID) ;
+
+  for(i = nEMC; i < nCPV ; i++)
+    if(sDigitizer->Calibrate(((AliPHOSDigit*)digits->At(i))->GetAmp()) < fCPVDigitThreshold)
+      digits->RemoveAt(i) ;
     
   digits->Compress() ;  
   
@@ -354,7 +383,7 @@ void AliPHOSDigitizer::Digitize(const Int_t event)
   for (i = 0 ; i < ndigits ; i++) { 
     AliPHOSDigit * digit = (AliPHOSDigit *) digits->At(i) ; 
     digit->SetIndexInList(i) ;     
-    Float_t energy = sdiz->Calibrate(digit->GetAmp()) ;
+    Float_t energy = sDigitizer->Calibrate(digit->GetAmp()) ;
     digit->SetAmp(DigitizeEnergy(energy,digit->GetId()) ) ;
   }
 
@@ -378,9 +407,8 @@ void AliPHOSDigitizer::Exec(Option_t *option)
 { 
   // Managing method
 
-  if( strcmp(GetName(), "") == 0 )    
+  if(strcmp(GetName(), "") == 0 )   
     Init() ;
-  
   if (strstr(option,"print")) {
     Print("");
     return ; 
@@ -395,61 +423,61 @@ void AliPHOSDigitizer::Exec(Option_t *option)
   
   TTree * treeD ;
   
-  if(fARD){
-    treeD = fARD->GetTreeD() ;
+  if(fManager){
+    treeD = fManager->GetTreeD() ;
     nevents = 1 ;    // Will process only one event
+    
+    //Check, if this branch already exits
+    if (treeD) { 
+      TObjArray * lob = (TObjArray*)treeD->GetListOfBranches() ;
+      TIter next(lob) ; 
+      TBranch * branch = 0 ;  
+      Bool_t phosfound = kFALSE, digitizerfound = kFALSE ; 
+      
+      while ( (branch = (TBranch*)next()) && (!phosfound || !digitizerfound) ) {
+       if ( (strcmp(branch->GetName(), "PHOS")==0) && 
+            (strcmp(branch->GetTitle(), GetName())==0) ) 
+         phosfound = kTRUE ;
+       
+       else if ( (strcmp(branch->GetName(), "AliPHOSDigitizer")==0) && 
+                 (strcmp(branch->GetTitle(), GetName())==0) ) 
+         digitizerfound = kTRUE ; 
+      }
+      
+      if ( phosfound ) {
+       cerr << "WARNING: AliPHOSDigitizer -> Digits branch with name " << GetName() 
+            << " already exits" << endl ;
+       return ; 
+      }   
+      if ( digitizerfound ) {
+       cerr << "WARNING: AliPHOSDigitizer -> Digitizer branch with name " << GetName() 
+            << " already exits" << endl ;
+       return ; 
+      }
+    }   
   }
-  else {
-    gAlice->GetEvent(0) ;
-    nevents = (Int_t) gAlice->TreeE()->GetEntries() ;
-    treeD=gAlice->TreeD() ;
-  }
-  if(treeD == 0 ){
-    cerr << " AliPHOSDigitizer :: Can not find TreeD " << endl ;
-    return ;
+  else { //PHOS standalone
+    if(gime->BranchExists("Digits") ) 
+      return ;
+    nevents=gime->MaxEvent() ;
   }
-
-  //Check, if this branch already exits
-  TObjArray * lob = (TObjArray*)treeD->GetListOfBranches() ;
-  TIter next(lob) ; 
-  TBranch * branch = 0 ;  
-  Bool_t phosfound = kFALSE, digitizerfound = kFALSE ; 
   
-  while ( (branch = (TBranch*)next()) && (!phosfound || !digitizerfound) ) {
-    if ( (strcmp(branch->GetName(), "PHOS")==0) && 
-        (strcmp(branch->GetTitle(), GetName())==0) ) 
-      phosfound = kTRUE ;
-    
-    else if ( (strcmp(branch->GetName(), "AliPHOSDigitizer")==0) && 
-             (strcmp(branch->GetTitle(), GetName())==0) ) 
-      digitizerfound = kTRUE ; 
-  }
-
-  if ( phosfound ) {
-    cerr << "WARNING: AliPHOSDigitizer -> Digits branch with name " << GetName() 
-        << " already exits" << endl ;
-    return ; 
-  }   
-  if ( digitizerfound ) {
-    cerr << "WARNING: AliPHOSDigitizer -> Digitizer branch with name " << GetName() 
-        << " already exits" << endl ;
-    return ; 
-  }   
-
   Int_t ievent ;
-
+  
   for(ievent = 0; ievent < nevents; ievent++){
-    
-    if(fARD){
+  
+    if(fManager){
+
       Int_t input ;
-      for(input = 0 ; input < fARD->GetNinputs(); input ++){
-       TTree * treeS = fARD->GetInputTreeS(input) ;
+      for(input = 0 ; input < fManager->GetNinputs(); input ++){
+       TTree * treeS = fManager->GetInputTreeS(input) ;
        if(!treeS){
-         cerr << "AliPHOSDigitizer -> No Input " << endl ;
+         cerr << "AliPHOSDigitizer::Exec -> No Input " << endl ;
          return ;
        }
        gime->ReadTreeS(treeS,input) ;
       }
+
     }
     else
       gime->Event(ievent,"S") ;
@@ -464,7 +492,7 @@ void AliPHOSDigitizer::Exec(Option_t *option)
     //increment the total number of Digits per run 
     fDigitsInRun += gime->Digits()->GetEntriesFast() ;  
   }
-  
+   
   if(strstr(option,"tim")){
     gBenchmark->Stop("PHOSDigitizer");
     cout << "AliPHOSDigitizer:" << endl ;
@@ -494,61 +522,84 @@ Float_t AliPHOSDigitizer::FrontEdgeTime(TClonesArray * ticks)
   }
   return time ;
 }
+
 //____________________________________________________________________________ 
 Bool_t AliPHOSDigitizer::Init()
 {
-  fPinNoise           = 0.01 ;
-  fEMCDigitThreshold  = 0.01 ;
-  fCPVNoise           = 0.01;
-  fCPVDigitThreshold  = 0.09 ;
-  fTimeResolution     = 0.5e-9 ;
-  fTimeSignalLength   = 1.0e-9 ;
-  fDigitsInRun  = 0 ; 
-  fADCchanelEmc = 0.0015;        // width of one ADC channel in GeV
-  fADCpedestalEmc = 0.005 ;      //
-  fNADCemc = (Int_t) TMath::Power(2,16) ;  // number of channels in EMC ADC
-
-  fADCchanelCpv = 0.0012 ;          // width of one ADC channel in CPV 'popugais'
-  fADCpedestalCpv = 0.012 ;         // 
-  fNADCcpv = (Int_t) TMath::Power(2,12);      // number of channels in CPV ADC
-
-  fTimeThreshold = 0.001*10000000 ; //Means 1 MeV in terms of SDigits amplitude
-
   // Makes all memory allocations
-  // Adds Digitizer task to the folder of PHOS tasks
 
-   //============================================================= YS
-  //  The initialisation is now done by AliPHOSGetter
-    
   if( strcmp(GetTitle(), "") == 0 )
     SetTitle("galice.root") ;
-  
-  // the SDigits name is stored by AliPHOSGetter as the name of the TClones Array 
-  // //YSAlice/WhiteBoard/SDigits/PHOS/headerFile/branchname and has branchTitle as title.    
-    
-  AliPHOSGetter * gime = AliPHOSGetter::GetInstance(GetTitle(), GetName()) ; 
+
+  AliPHOSGetter * gime = AliPHOSGetter::GetInstance(GetTitle(), GetName(), fToSplit) ; 
   if ( gime == 0 ) {
     cerr << "ERROR: AliPHOSDigitizer::Init -> Could not obtain the Getter object !" << endl ; 
     return kFALSE;
   } 
   
   const AliPHOSGeometry * geom = gime->PHOSGeometry() ;
+
   fEmcCrystals = geom->GetNModules() *  geom->GetNCristalsInModule() ;
-     
-  // create a folder on the white board //YSAlice/WhiteBoard/Digits/PHOS/headerFile/digitsTitle
+  
+  // Post Digits to the white board
   gime->PostDigits(GetName() ) ;   
   
-  //add Task to //YSAlice/tasks/Digitizer/PHOS
-    gime->PostDigitizer(this) ;
+  // Post Digitizer to the white board
+  gime->PostDigitizer(this) ;
+
+  fSplitFile = 0 ;
+  if(fToSplit){
+    // construct the name of the file as /path/PHOS.SDigits.root
+    //First - extract full path if necessary
+    TString digitsFileName(GetTitle()) ;
+    Ssiz_t islash = digitsFileName.Last('/') ;
+    if(islash<digitsFileName.Length())
+      digitsFileName.Remove(islash+1,digitsFileName.Length()) ;
+    else
+      digitsFileName="" ;
+    // Next - append the file name 
+    digitsFileName+="PHOS.Digits." ;
+    if((strcmp(GetName(),"Default")!=0)&&(strcmp(GetName(),"")!=0)){
+      digitsFileName+=GetName() ;
+      digitsFileName+="." ;
+    }
+    digitsFileName+="root" ;
+    // Finally - check if the file already opened or open the file
+    fSplitFile = static_cast<TFile*>(gROOT->GetFile(digitsFileName.Data()));   
+    if(!fSplitFile)
+      fSplitFile =  TFile::Open(digitsFileName.Data(),"update") ;
+  }
   
   //Mark that we will use current header file
-  if(!fARD){
+  if(!fManager){
     gime->PostSDigits(GetName(),GetTitle()) ;
     gime->PostSDigitizer(GetName(),GetTitle()) ;
   }
   return kTRUE ;
 }
 
+//____________________________________________________________________________ 
+void AliPHOSDigitizer::InitParameters()
+{
+  fPinNoise           = 0.004 ;
+  fEMCDigitThreshold  = 0.012 ;
+  fCPVNoise           = 0.01;
+  fCPVDigitThreshold  = 0.09 ;
+  fTimeResolution     = 0.5e-9 ;
+  fTimeSignalLength   = 1.0e-9 ;
+  fDigitsInRun  = 0 ; 
+  fADCchanelEmc = 0.0015;        // width of one ADC channel in GeV
+  fADCpedestalEmc = 0.005 ;      //
+  fNADCemc = (Int_t) TMath::Power(2,16) ;  // number of channels in EMC ADC
+
+  fADCchanelCpv = 0.0012 ;          // width of one ADC channel in CPV 'popugais'
+  fADCpedestalCpv = 0.012 ;         // 
+  fNADCcpv = (Int_t) TMath::Power(2,12);      // number of channels in CPV ADC
+
+  fTimeThreshold = 0.001*10000000 ; //Means 1 MeV in terms of SDigits amplitude
+    
+}
+
 //__________________________________________________________________
 void AliPHOSDigitizer::MixWith(const char* headerFile)
 {
@@ -567,15 +618,15 @@ void AliPHOSDigitizer::MixWith(const char* headerFile)
   if( strcmp(GetName(), "") == 0 )
     Init() ;
 
-  if(fARD){
+  if(fManager){
     cout << "Can not use this method under AliRunDigitizer " << endl ;
     return ;
   }
   
   // check if the specified SDigits do not already exist on the White Board:
-  // //YSAlice/WhiteBoard/SDigits/PHOS/headerFile/sDigitsTitle
+  // //Folders/RunMC/Event/Data/PHOS/SDigits/headerFile/sdigitsname
 
-  TString path = "YSAlice/WhiteBoard/SDigits/PHOS/" ; 
+  TString path = "Folders/RunMC/Event/Data/PHOS/SDigits" ; 
   path += headerFile ; 
   path += "/" ; 
   path += GetName() ;
@@ -599,25 +650,90 @@ void AliPHOSDigitizer::MixWith(const char* headerFile)
   
 }
 
+// //__________________________________________________________________
+// void AliPHOSDigitizer::SetSplitFile(const TString splitFileName)
+// {
+//   // Diverts the Digits in a file separate from the hits file
+  
+//   // I guess it is not going to work if we do merging
+// //   if (fManager) {
+// //     cerr << "ERROR: AliPHOSDigitizer::SetSplitFile -> Not yet available in case of merging activated " << endl ;  
+// //     return ; 
+// //   }
+
+//   cout << "AliPHOSDigitizer::SetSplitFile " << gDirectory->GetName() << endl ;  
+//   cout << "AliPHOSDigitizer::SetSplitFile " << gAlice->GetTreeDFileName() << endl ;  
+//   cout << "AliPHOSDigitizer::SetSplitFile " <<  splitFileName.Data() << endl ;
+  
+//   SetTitle(splitFileName) ; 
+
+//   TDirectory * cwd = gDirectory ;
+//   if ( !(gAlice->GetTreeDFileName() == splitFileName) ) {
+//     if (gAlice->GetTreeDFile() )  
+//       gAlice->GetTreeDFile()->Close() ; 
+//   }
+
+//   fSplitFile = gAlice->InitTreeFile("D",splitFileName.Data());
+//   fSplitFile->cd() ; 
+//   gAlice->Write(0, TObject::kOverwrite);
+
+//   TTree *treeE  = gAlice->TreeE();
+//   if (!treeE) {
+//     cerr << "ERROR: AliPHOSDigitizer::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: AliPHOSDigitizer::SetSplitFile -> AliceGeom was not found in the input file "<<endl;
+//     abort() ;
+//     }
+//   AliceGeom->Write(0, TObject::kOverwrite);
+  
+//   gAlice->MakeTree("D",fSplitFile);
+//   cwd->cd() ; 
+//   cout << "INFO: AliPHOSDigitizer::SetSPlitMode -> Digits will be stored in " << splitFileName.Data() << endl ; 
+// }
+
 //__________________________________________________________________
 void AliPHOSDigitizer::Print(Option_t* option)const {
   // Print Digitizer's parameters
   if( strcmp(GetName(), "") != 0 ){
-    
+
+
     cout << "------------------- "<< GetName() << " -------------" << endl ;
-    cout << "Digitizing sDigits from file(s): " <<endl ;
-    
-     TCollection * folderslist = ((TFolder*)gROOT->FindObjectAny("YSAlice/WhiteBoard/SDigits/PHOS"))->GetListOfFolders() ; 
-    TIter next(folderslist) ; 
-    TFolder * folder = 0 ; 
-    
-    while ( (folder = (TFolder*)next()) ) {
-      if ( folder->FindObject(GetName())  ) 
-       cout << "Adding SDigits " << GetName() << " from " << folder->GetName() << endl ; 
-    }
-    cout << endl ;
-    cout << "Writing digits to " << GetTitle() << endl ;
-    
+
+    const Int_t nStreams = GetNInputStreams() ; 
+    if (nStreams) {
+      Int_t index = 0 ;  
+      for (index = 0 ; index < nStreams ; index++)  
+       cout << "Adding SDigits " << GetName() << " from " <<  fManager->GetInputFileName(index, 0) << endl ; 
+      
+      cout << endl ;
+      cout << "Writing digits to " <<   fManager->GetInputFileName(0, 0) << endl ;   
+    } else { 
+//       AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ;  
+//       gime->Folder("sdigits")  ;
+//       cout << "Digitizing sDigits from file(s): " <<endl ;
+//       TCollection * folderslist = gime->Folder("sdigits")->GetListOfFolders() ; 
+//       TIter next(folderslist) ; 
+//       TFolder * folder = 0 ; 
+      
+//       while ( (folder = (TFolder*)next()) ) {
+//     if ( folder->FindObject(GetName())  ) 
+      //    cout << "Adding SDigits " << GetName() << " from " << GetSDigitsFileName() << endl ; 
+//      }
+      cout << endl ;
+      cout << "Writing digits to " << GetTitle() << endl ;
+    }    
     cout << endl ;
     cout << "With following parameters: " << endl ;
     cout << "     Electronics noise in EMC (fPinNoise) = " << fPinNoise << endl ;
@@ -645,10 +761,11 @@ void AliPHOSDigitizer::PrintDigits(Option_t * option){
     
     //loop over digits
     AliPHOSDigit * digit;
-    cout << "Digit Id    Amplitude     Index "  <<  " Nprim " << " Primaries list " <<  endl;      
+    cout << "EMC digits (with primaries): " << 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 < digits->GetEntries()) && 
+    for (index = 0 ; (index < digits->GetEntriesFast()) && 
         (((AliPHOSDigit * )  digits->At(index))->GetId() <= maxEmc) ; index++) {
       digit = (AliPHOSDigit * )  digits->At(index) ;
       if(digit->GetNprimary() == 0) continue;
@@ -668,10 +785,11 @@ void AliPHOSDigitizer::PrintDigits(Option_t * option){
     
     //loop over CPV digits
     AliPHOSDigit * digit;
-    cout << "Digit Id " << " Amplitude " <<  " Index "  <<  " Nprim " << " Primaries list " <<  endl;      
+    cout << "CPV digits: " << 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 < digits->GetEntries(); index++) {
+    for (index = 0 ; index < digits->GetEntriesFast(); index++) {
       digit = (AliPHOSDigit * )  digits->At(index) ;
       if(digit->GetId() > maxEmc){
        cout << setw(6)  <<  digit->GetId() << "   "  <<        setw(10)  <<  digit->GetAmp() <<   "    "  
@@ -688,16 +806,16 @@ void AliPHOSDigitizer::PrintDigits(Option_t * option){
 
 }
 
-//__________________________________________________________________
-void AliPHOSDigitizer::SetSDigitsBranch(const char* title)
-{
-  // we set title (comment) of the SDigits branch in the first! header file
-  if( strcmp(GetName(), "") == 0 )
-    Init() ;
+// //__________________________________________________________________
+// void AliPHOSDigitizer::SetSDigitsBranch(const char* title)
+// {
+//   // we set title (comment) of the SDigits branch in the first! header file
+//   if( strcmp(GetName(), "") == 0 )
+//     Init() ;
 
-  AliPHOSGetter::GetInstance()->SDigits()->SetName(title) ; 
+//   AliPHOSGetter::GetInstance()->SDigits()->SetName(title) ; 
  
-}
+// }
 //__________________________________________________________________
 Float_t AliPHOSDigitizer::TimeOfNoise(void)
 {  // Calculates the time signal generated by noise
@@ -705,19 +823,19 @@ Float_t AliPHOSDigitizer::TimeOfNoise(void)
   return 1. ;
 
 }
-//____________________________________________________________________________
-void AliPHOSDigitizer::Reset() 
-{ 
-  // sets current event number to the first simulated event
+// //____________________________________________________________________________
+// void AliPHOSDigitizer::Reset() 
+// 
+//   // sets current event number to the first simulated event
 
-  if( strcmp(GetName(), "") == 0 )
-    Init() ;
+//   if( strcmp(GetName(), "") == 0 )
+//     Init() ;
 
- //  Int_t inputs ;
-//   for(inputs = 0; inputs < fNinputs ;inputs++)
-//       fIevent->AddAt(-1, inputs ) ;
+//  //  Int_t inputs ;
+// //   for(inputs = 0; inputs < fNinputs ;inputs++)
+// //       fIevent->AddAt(-1, inputs ) ;
   
-}
+// }
 
 //____________________________________________________________________________
 void AliPHOSDigitizer::WriteDigits(Int_t event)
@@ -732,56 +850,31 @@ void AliPHOSDigitizer::WriteDigits(Int_t event)
   //      and names of files, from which digits are made.
 
   AliPHOSGetter * gime = AliPHOSGetter::GetInstance() ; 
-  TClonesArray * digits = gime->Digits(GetName()) ; 
-
+  const TClonesArray * digits = gime->Digits(GetName()) ; 
   TTree * treeD ;
-
-  if(fARD)
-    treeD = fARD->GetTreeD() ;
- else
-    treeD = gAlice->TreeD();
   
-  // create new branches
-  // -- generate file name if necessary
-  char * file =0;
-  if(gSystem->Getenv("CONFIG_SPLIT_FILE")){ //generating file name
-    file = new char[strlen(gAlice->GetBaseFile())+20] ;
-    sprintf(file,"%s/PHOS.Digits.root",gAlice->GetBaseFile()) ;
+  if(fManager) 
+    treeD = fManager->GetTreeD() ;
+  else {
+    if((gAlice->TreeD() == 0) || (fSplitFile))  // we should not create TreeD if it is already here
+      gAlice->MakeTree("D", fSplitFile);       // We overwrite TreeD in split file in the case of second reconstruction
+    if(fSplitFile)
+      fSplitFile->cd() ;
+    treeD = gAlice->TreeD();
   }
-
-  TDirectory *cwd = gDirectory;
+  
   // -- create Digits branch
   Int_t bufferSize = 32000 ;    
   TBranch * digitsBranch = treeD->Branch("PHOS",&digits,bufferSize);
   digitsBranch->SetTitle(GetName());
-  if (file) {
-    digitsBranch->SetFile(file);
-    TIter next( digitsBranch->GetListOfBranches());
-    TBranch * sbr ;
-    while ((sbr=(TBranch*)next())) {
-      sbr->SetFile(file);
-    }   
-    cwd->cd();
-  } 
-    
+  
   // -- Create Digitizer branch
   Int_t splitlevel = 0 ;
-  AliPHOSDigitizer * d = gime->Digitizer(GetName()) ;
+  const AliPHOSDigitizer * d = gime->Digitizer(GetName()) ;
   TBranch * digitizerBranch = treeD->Branch("AliPHOSDigitizer", "AliPHOSDigitizer", &d,bufferSize,splitlevel); 
   digitizerBranch->SetTitle(GetName());
-  if (file) {
-    digitizerBranch->SetFile(file);
-    TIter next( digitizerBranch->GetListOfBranches());
-    TBranch * sbr;
-    while ((sbr=(TBranch*)next())) {
-      sbr->SetFile(file);
-    }   
-    cwd->cd();
-  }
-  
-  digitsBranch->Fill() ;      
-  digitizerBranch->Fill() ;
 
-  treeD->Write(0,kOverwrite) ;  
+  digitsBranch->Fill() ;
+  digitizerBranch->Fill() ; 
+  treeD->AutoSave() ; 
 }