]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - STEER/AliQADataMakerSteer.cxx
Adding the missing GRP entries to the esd event tag (Panos)
[u/mrichter/AliRoot.git] / STEER / AliQADataMakerSteer.cxx
index 9c6f2490350b096e8a1372cbbd46545374524729..2b78a24cf07053c0851e0a1db5a0ebb8986f2797 100644 (file)
@@ -40,6 +40,9 @@
 #include "AliCDBEntry.h"
 #include "AliCDBId.h"
 #include "AliCDBMetaData.h"
+#include "AliCodeTimer.h"
+#include "AliCorrQADataMakerRec.h"
+#include "AliDetectorRecoParam.h"
 #include "AliESDEvent.h"
 #include "AliGeomManager.h"
 #include "AliGlobalQADataMaker.h"
@@ -72,10 +75,12 @@ AliQADataMakerSteer::AliQADataMakerSteer(char * mode, const char* gAliceFilename
        fMaxEvents(0),   
   fMode(mode), 
        fNumberOfEvents(999999), 
+  fRecoParam(),
        fRunNumber(0), 
        fRawReader(NULL), 
        fRawReaderDelete(kTRUE), 
-       fRunLoader(NULL)
+       fRunLoader(NULL), 
+  fTasks("")
 {
        // default ctor
        fMaxEvents = fNumberOfEvents ; 
@@ -84,6 +89,7 @@ AliQADataMakerSteer::AliQADataMakerSteer(char * mode, const char* gAliceFilename
                        fLoader[iDet]      = NULL ;
                        fQADataMaker[iDet] = NULL ;
                        fQACycles[iDet]    = 999999 ;
+      fQAWriteExpert[iDet] = kFALSE ;
                }
        }       
 }
@@ -102,16 +108,19 @@ AliQADataMakerSteer::AliQADataMakerSteer(const AliQADataMakerSteer & qas) :
        fMaxEvents(qas.fMaxEvents),    
        fMode(qas.fMode), 
        fNumberOfEvents(qas.fNumberOfEvents), 
-    fRunNumber(qas.fRunNumber), 
+       fRecoParam(),           
+       fRunNumber(qas.fRunNumber), 
        fRawReader(NULL), 
        fRawReaderDelete(kTRUE), 
-       fRunLoader(NULL)
+       fRunLoader(NULL), 
+  fTasks(qas.fTasks)
 {
        // cpy ctor
        for (UInt_t iDet = 0; iDet < fgkNDetectors; iDet++) {
-               fLoader[iDet]      = qas.fLoader[iDet] ;
-               fQADataMaker[iDet] = qas.fQADataMaker[iDet] ;
-               fQACycles[iDet]    = qas.fQACycles[iDet] ;      
+               fLoader[iDet]         = qas.fLoader[iDet] ;
+               fQADataMaker[iDet]    = qas.fQADataMaker[iDet] ;
+               fQACycles[iDet]       = qas.fQACycles[iDet] ;   
+    fQAWriteExpert[iDet] = qas.fQAWriteExpert[iDet] ;
        }
 }
 
@@ -133,10 +142,9 @@ AliQADataMakerSteer::~AliQADataMakerSteer()
                  fLoader[iDet] = NULL;
                  if (fQADataMaker[iDet]) {
                          (fQADataMaker[iDet])->Finish() ; 
+                               delete fQADataMaker[iDet] ;
                  }
                }
-               if (fQADataMaker[iDet])
-                       delete fQADataMaker[iDet] ;
        }
        if (fRawReaderDelete) { 
                fRunLoader = NULL ;
@@ -171,52 +179,62 @@ Bool_t AliQADataMakerSteer::DoIt(const AliQA::TASKINDEX_t taskIndex)
                for (UInt_t iDet = 0; iDet < fgkNDetectors ; iDet++) {
                        if (IsSelected(AliQA::GetDetName(iDet))) {
                                AliQADataMaker * qadm = GetQADataMaker(iDet) ;
+                               if (!qadm) continue; // This detector doesn't have any QA (for example, HLT)
                                if ( qadm->IsCycleDone() ) {
-                                       qadm->EndOfCycle(AliQA::kRAWS) ;
-                                       qadm->StartOfCycle(AliQA::kRAWS) ;
+                                       qadm->EndOfCycle(taskIndex) ;
                                }
-                               TTree * data ; 
+                               TTree * data = NULL 
                                AliLoader* loader = GetLoader(qadm->GetUniqueID());
                                switch (taskIndex) {
+                                       case AliQA::kNULLTASKINDEX : 
+                                               break ; 
                                        case AliQA::kRAWS :
                                                qadm->Exec(taskIndex, fRawReader) ; 
                                                break ; 
                                        case AliQA::kHITS :
-                                               loader->LoadHits() ; 
-                                               data = loader->TreeH() ; 
-                                               if ( ! data ) {
-                                                       AliWarning(Form(" Hit Tree not found for  %s", AliQA::GetDetName(iDet))) ; 
-                                               } else {
-                                                       qadm->Exec(taskIndex, data) ;
-                                               } 
+            if( loader ) {
+              loader->LoadHits() ; 
+              data = loader->TreeH() ; 
+              if ( ! data ) {
+                AliWarning(Form(" Hit Tree not found for  %s", AliQA::GetDetName(iDet))) ; 
+                break ; 
+              } 
+            } 
+            qadm->Exec(taskIndex, data) ;
                                                break ;
                                                case AliQA::kSDIGITS :
-                                               loader->LoadSDigits() ; 
-                                               data = loader->TreeS() ; 
-                                               if ( ! data ) {
-                                                       AliWarning(Form(" SDigit Tree not found for  %s", AliQA::GetDetName(iDet))) ; 
-                                               } else {
-                                                       qadm->Exec(taskIndex, data) ; 
-                                       }
+            if( loader ) {      
+              loader->LoadSDigits() ; 
+              data = loader->TreeS() ; 
+              if ( ! data ) {
+                AliWarning(Form(" SDigit Tree not found for  %s", AliQA::GetDetName(iDet))) ; 
+                break ; 
+              } 
+            }
+            qadm->Exec(taskIndex, data) ; 
                                                break; 
                                                case AliQA::kDIGITS :
-                                               loader->LoadDigits() ; 
-                                               data = loader->TreeD() ; 
-                                               if ( ! data ) {
-                                                       AliWarning(Form(" Digit Tree not found for  %s", AliQA::GetDetName(iDet))) ; 
-                                               } else {
-                                                       qadm->Exec(taskIndex, data) ;
-                                               }
+            if( loader ) {      
+              loader->LoadDigits() ; 
+              data = loader->TreeD() ; 
+              if ( ! data ) {
+                AliWarning(Form(" Digit Tree not found for  %s", AliQA::GetDetName(iDet))) ; 
+                break ; 
+              } 
+            }
+            qadm->Exec(taskIndex, data) ;
                                                break; 
                                                case AliQA::kRECPOINTS :
-                                               loader->LoadRecPoints() ; 
-                                               data = loader->TreeR() ; 
-                                               if (!data) {
-                                                       AliWarning(Form("RecPoints not found for %s", AliQA::GetDetName(iDet))) ; 
-                                               } else {
-                                                       qadm->Exec(taskIndex, data) ; 
-                                               }
-                                               break; 
+            if( loader ) {      
+              loader->LoadRecPoints() ; 
+              data = loader->TreeR() ; 
+              if (!data) {
+                AliWarning(Form("RecPoints not found for %s", AliQA::GetDetName(iDet))) ; 
+                break ; 
+              } 
+            }
+            qadm->Exec(taskIndex, data) ; 
+            break; 
                                                case AliQA::kTRACKSEGMENTS :
                                                break; 
                                                case AliQA::kRECPARTICLES :
@@ -229,6 +247,7 @@ Bool_t AliQADataMakerSteer::DoIt(const AliQA::TASKINDEX_t taskIndex)
                                } //task switch
                        }
                } // detector loop
+    Increment() ; 
        } // event loop 
        // Save QA data for all detectors
        rv = Finish(taskIndex) ;
@@ -246,7 +265,7 @@ Bool_t AliQADataMakerSteer::Finish(const AliQA::TASKINDEX_t taskIndex)
        for (UInt_t iDet = 0; iDet < fgkNDetectors ; iDet++) {
                if (IsSelected(AliQA::GetDetName(iDet))) {
                        AliQADataMaker * qadm = GetQADataMaker(iDet) ;
-                       qadm->EndOfCycle(taskIndex) ; 
+                       if (qadm) qadm->EndOfCycle(taskIndex) ; 
                }
        }
        return kTRUE ; 
@@ -283,7 +302,7 @@ AliLoader * AliQADataMakerSteer::GetLoader(Int_t iDet)
 {
        // get the loader for a detector
 
-       if ( !fRunLoader ) 
+       if ( !fRunLoader || iDet == AliQA::kCORR
                return NULL ; 
        
        TString detName = AliQA::GetDetName(iDet) ;
@@ -329,10 +348,20 @@ AliQADataMaker * AliQADataMakerSteer::GetQADataMaker(const Int_t iDet)
        
        if (iDet == AliQA::kGLOBAL) { //Global QA
                qadm = new AliGlobalQADataMaker();
+               qadm->SetName(AliQA::GetDetName(iDet));
+               qadm->SetUniqueID(iDet);
                fQADataMaker[iDet] = qadm;
                return qadm;
        }
 
+       if (iDet == AliQA::kCORR) { //the data maker for correlations among detectors
+    qadm = new AliCorrQADataMakerRec(fQADataMaker) ; 
+               qadm->SetName(AliQA::GetDetName(iDet));
+               qadm->SetUniqueID(iDet);
+               fQADataMaker[iDet] = qadm;
+               return qadm;
+  }
+
        // load the QA data maker object
        TPluginManager* pluginManager = gROOT->GetPluginManager() ;
        TString detName = AliQA::GetDetName(iDet) ;
@@ -360,21 +389,65 @@ AliQADataMaker * AliQADataMakerSteer::GetQADataMaker(const Int_t iDet)
        if (pluginHandler && (pluginHandler->LoadPlugin() == 0)) {
                qadm = (AliQADataMaker *) pluginHandler->ExecPlugin(0) ;
        }
-       if (qadm) 
+       if (qadm) {
+               qadm->SetName(AliQA::GetDetName(iDet));
+               qadm->SetUniqueID(iDet);
                fQADataMaker[iDet] = qadm ;
+       }
+       
                return qadm ;
 }
 
+//_____________________________________________________________________________
+void  AliQADataMakerSteer::EndOfCycle(TObjArray * detArray) 
+{
+       // End of cycle QADataMakers 
+       
+       for (UInt_t iDet = 0; iDet < fgkNDetectors ; iDet++) {
+               if (IsSelected(AliQA::GetDetName(iDet))) {
+                       AliQADataMaker * qadm = GetQADataMaker(iDet) ;
+                       if (!qadm) 
+                               continue ;      
+                       // skip non active detectors
+                       if (detArray) {
+                               AliModule* det = static_cast<AliModule*>(detArray->FindObject(AliQA::GetDetName(iDet))) ;
+                               if (!det || !det->IsActive())  
+                                       continue ;
+                       }
+                       for (UInt_t taskIndex = 0; taskIndex < AliQA::kNTASKINDEX; taskIndex++) {
+                               if ( fTasks.Contains(Form("%d", taskIndex)) ) 
+                                       qadm->EndOfCycle(AliQA::GetTaskIndex(AliQA::GetTaskName(taskIndex))) ;
+                       }
+                       qadm->Finish();
+               }
+       }
+}
+
+//_____________________________________________________________________________
+void AliQADataMakerSteer::Increment()
+{
+  // Increments the cycle counter for all QA Data Makers
+       for (UInt_t iDet = 0; iDet < fgkNDetectors ; iDet++) {
+               if (IsSelected(AliQA::GetDetName(iDet))) {
+                       AliQADataMaker * qadm = GetQADataMaker(iDet) ;
+                       if (qadm) 
+        qadm->Increment() ;
+    }
+  }
+}
+  
 //_____________________________________________________________________________
 Bool_t AliQADataMakerSteer::Init(const AliQA::TASKINDEX_t taskIndex, const  char * input )
 {
        // Initialize the event source and QA data makers
        
+       //fTasks = AliQA::GetTaskName(taskIndex) ; 
+
        if (taskIndex == AliQA::kRAWS) { 
                if (!fRawReader) {
                        fRawReader = AliRawReader::Create(input);
                }
-           if ( ! fRawReader ) 
+               if ( ! fRawReader ) 
                        return kFALSE ; 
                fRawReaderDelete = kTRUE ; 
                fRawReader->NextEvent() ; 
@@ -385,6 +458,7 @@ Bool_t AliQADataMakerSteer::Init(const AliQA::TASKINDEX_t taskIndex, const  char
                if ( fMaxEvents < 0 ) 
                        fMaxEvents = fNumberOfEvents ; 
                } else if (taskIndex == AliQA::kESDS) {
+                       fTasks = AliQA::GetTaskName(AliQA::kESDS) ; 
                if (!gSystem->AccessPathName("AliESDs.root")) { // AliESDs.root exists
                        TFile * esdFile = TFile::Open("AliESDs.root") ;
                        fESDTree = dynamic_cast<TTree *> (esdFile->Get("esdTree")) ; 
@@ -411,7 +485,6 @@ Bool_t AliQADataMakerSteer::Init(const AliQA::TASKINDEX_t taskIndex, const  char
                        fNumberOfEvents = fRunLoader->GetNumberOfEvents() ;
                        if ( fMaxEvents < 0 ) 
                                fMaxEvents = fNumberOfEvents ; 
-
                }
        }
 
@@ -428,10 +501,20 @@ Bool_t AliQADataMakerSteer::Init(const AliQA::TASKINDEX_t taskIndex, const  char
        if ( !  AliGeomManager::GetGeometry() ) 
                AliGeomManager::LoadGeometry() ; 
        
-       // Build array of QA data makers for all detectors
+       InitQADataMaker(fRunNumber, fRecoParam, detArray) ; //, fCycleSame, kTRUE, detArray) ; 
+       return kTRUE ; 
+}
+
+//_____________________________________________________________________________
+void  AliQADataMakerSteer::InitQADataMaker(UInt_t run, const AliRecoParam & par, TObjArray * detArray) 
+{
+       // Initializes The QADataMaker for all active detectors and for all active tasks 
+
        for (UInt_t iDet = 0; iDet < fgkNDetectors ; iDet++) {
                if (IsSelected(AliQA::GetDetName(iDet))) {
                        AliQADataMaker * qadm = GetQADataMaker(iDet) ;
+      if (fQAWriteExpert[iDet])
+        qadm->SetWriteExpert() ; 
                        if (!qadm) {
                                AliError(Form("AliQADataMaker not found for %s", AliQA::GetDetName(iDet))) ; 
                                fDetectorsW.ReplaceAll(AliQA::GetDetName(iDet), "") ; 
@@ -443,16 +526,22 @@ Bool_t AliQADataMakerSteer::Init(const AliQA::TASKINDEX_t taskIndex, const  char
                                        if (!det || !det->IsActive())  
                                                continue ;
                                }
-                               qadm->SetName(AliQA::GetDetName(iDet));
-                               qadm->SetUniqueID(iDet);
-                               qadm->Init(taskIndex, fRunNumber, GetQACycles(qadm->GetUniqueID())) ;
-                               qadm->StartOfCycle(taskIndex, fCycleSame) ;
+             // Set default reco params
+                               qadm->SetRecoParam(par.GetDetRecoParam(iDet));
+        Bool_t sameCycle = kFALSE ; 
+                               for (UInt_t taskIndex = 0; taskIndex < AliQA::kNTASKINDEX; taskIndex++) {
+                                       if ( fTasks.Contains(Form("%d", taskIndex)) ) {
+            qadm->StartOfCycle(AliQA::GetTaskIndex(AliQA::GetTaskName(taskIndex)), run,  sameCycle) ;
+                                               qadm->Init(AliQA::GetTaskIndex(AliQA::GetTaskName(taskIndex)), GetQACycles(qadm->GetUniqueID())) ;
+            sameCycle = kTRUE ;
+                                       }
+                               }
                        }
                }
-       } 
-       return kTRUE ; 
+       }
 }
 
+
 //_____________________________________________________________________________
 Bool_t AliQADataMakerSteer::InitRunLoader()
 {
@@ -509,34 +598,48 @@ Bool_t AliQADataMakerSteer::IsSelected(const char * det)
        
        Bool_t rv = kFALSE;
        const TString detName(det) ;
-       // check if all detectors are selected
-       if (fDetectors.Contains("ALL")) {
-               fDetectors = "ALL";
-               rv = kTRUE;
-       } else if ((fDetectors.CompareTo(detName) == 0) ||
-                          fDetectors.BeginsWith(detName+" ") ||
-                          fDetectors.EndsWith(" "+detName) ||
-                          fDetectors.Contains(" "+detName+" ")) {
-               rv = kTRUE;
-       }
-               
+  // always activates Correlation
+  if ( detName.Contains(AliQA::GetDetName(AliQA::kCORR))) {
+    rv = kTRUE ; 
+  } else {
+    // check if all detectors are selected
+    if (fDetectors.Contains("ALL")) {
+      fDetectors = "ALL";
+      rv = kTRUE;
+    } else if ((fDetectors.CompareTo(detName) == 0) ||
+               fDetectors.BeginsWith(detName+" ") ||
+               fDetectors.EndsWith(" "+detName) ||
+               fDetectors.Contains(" "+detName+" ")) {
+      rv = kTRUE;
+    }
+  }
        return rv ;
 }
 
 //_____________________________________________________________________________
 Bool_t AliQADataMakerSteer::Merge(const Int_t runNumber) const
+{
+       // Merge data from all the cycles from all detectors in one single file per run
+       // Merge the QA results from all the data chunks in one run 
+ Bool_t rv = MergeData(runNumber) ; 
+ rv *= MergeResults(runNumber) ;
+ return rv ; 
+}
+       
+       
+//_____________________________________________________________________________
+Bool_t AliQADataMakerSteer::MergeData(const Int_t runNumber) const
 {
        // Merge all the cycles from all detectors in one single file per run
        TString cmd ;
-       if ( runNumber == -1 )
-               cmd = Form(".! ls *%s*.*.*.root > tempo.txt", AliQA::GetQADataFileName()) ; 
+       if (runNumber == -1) 
+               cmd = Form(".! ls *%s*.%d.root > tempo.txt", AliQA::GetQADataFileName(), runNumber) ; 
        else 
-               cmd = Form(".! ls *%s*.%d.*.root > tempo.txt", AliQA::GetQADataFileName(), runNumber) ; 
+               cmd = Form(".! ls *%s*.*.root > tempo.txt", AliQA::GetQADataFileName()) ; 
        gROOT->ProcessLine(cmd.Data()) ;
        ifstream in("tempo.txt") ; 
        const Int_t runMax = 10 ;  
        TString file[AliQA::kNDET*runMax] ;
-       Int_t run[AliQA::kNDET*runMax] = {-1} ;
        
        Int_t index = 0 ; 
        while ( 1 ) {
@@ -551,41 +654,55 @@ Bool_t AliQADataMakerSteer::Merge(const Int_t runNumber) const
                AliError(Form("run number %d not found", runNumber)) ; 
                return kFALSE ; 
        }
+
+  TFileMerger merger ; 
+  TString outFileName(Form("Merged.%s.Data.%d.root",AliQA::GetQADataFileName(),runNumber)); 
+  merger.OutputFile(outFileName.Data()) ; 
+  for (Int_t ifile = 0 ; ifile < index-1 ; ifile++) {
+    TString pattern(Form("%s.%d.", AliQA::GetQADataFileName(), runNumber)); 
+    TString tmp(file[ifile]) ; 
+    if (tmp.Contains(pattern)) {
+      merger.AddFile(tmp) ; 
+    }
+       }
+  merger.Merge() ; 
+       return kTRUE ; 
+}
+
+//_____________________________________________________________________________
+Bool_t AliQADataMakerSteer::MergeResults(const Int_t runNumber) const
+{
+       // Merge the QA result from all the data chunks in a run 
+       TString cmd ;
+       cmd = Form(".! ls %s*.root > tempo.txt", AliQA::GetQADataFileName()) ; 
+       gROOT->ProcessLine(cmd.Data()) ;
+       ifstream in("tempo.txt") ; 
+       const Int_t chunkMax = 100 ;  
+       TString fileList[chunkMax] ;
        
-       Int_t runIndex    = 0 ;  
-       Int_t runIndexMax = 0 ; 
-       TString stmp(Form(".%s.", AliQA::GetQADataFileName())) ; 
-       for (Int_t ifile = 0 ; ifile < index ; ifile++) {
-               TString tmp(file[ifile]) ; 
-               tmp.ReplaceAll(".root", "") ; 
-               TString det = tmp(0, tmp.Index(".")) ; 
-               tmp.Remove(0, tmp.Index(stmp)+4) ; 
-               TString ttmp = tmp(0, tmp.Index(".")) ; 
-               Int_t newRun = ttmp.Atoi() ;
-               for (Int_t irun = 0; irun <= runIndexMax; irun++) {
-                       if (newRun == run[irun]) 
-                               break ; 
-                       run[runIndex] = newRun ; 
-                       runIndex++ ; 
-               }
-               runIndexMax = runIndex ; 
-               ttmp = tmp(tmp.Index(".")+1, tmp.Length()) ; 
-               Int_t cycle = ttmp.Atoi() ;  
-               AliDebug(1, Form("%s : det = %s run = %d cycle = %d \n", file[ifile].Data(), det.Data(), newRun, cycle)) ; 
+       Int_t index = 0 ; 
+       while ( 1 ) {
+               TString file ; 
+               in >> fileList[index] ; 
+               if ( !in.good() ) 
+                       break ; 
+               AliInfo(Form("index = %d file = %s", index, (fileList[index].Data()))) ; 
+               index++ ;
        }
-       for (Int_t irun = 0 ; irun < runIndexMax ; irun++) {
-               TFileMerger merger ; 
-               TString outFileName(Form("Merged.%s.%d.root",AliQA::GetQADataFileName(),run[irun]));            
-               merger.OutputFile(outFileName.Data()) ; 
-               for (Int_t ifile = 0 ; ifile < index-1 ; ifile++) {
-                       TString pattern(Form("%s.%d.", AliQA::GetQADataFileName(), run[irun])) ; 
-                       TString tmp(file[ifile]) ; 
-                       if (tmp.Contains(pattern)) {
-                               merger.AddFile(tmp) ; 
-                       }
-               }
-               merger.Merge() ; 
+       
+       if ( index == 0 ) { 
+               AliError("No QA Result File found") ; 
+               return kFALSE ; 
+       }
+       
+       TFileMerger merger ; 
+       TString outFileName(Form("Merged.%s.Result.%d.root", AliQA::GetQADataFileName(), runNumber));           
+       merger.OutputFile(outFileName.Data()) ; 
+       for (Int_t ifile = 0 ; ifile < index ; ifile++) {
+               TString file = fileList[ifile] ; 
+               merger.AddFile(file) ; 
        }
+       merger.Merge() ; 
        
        return kTRUE ; 
 }
@@ -598,7 +715,7 @@ void AliQADataMakerSteer::Reset(const Bool_t sameCycle)
        for (UInt_t iDet = 0; iDet < fgkNDetectors ; iDet++) {
                if (IsSelected(AliQA::GetDetName(iDet))) {
                        AliQADataMaker * qadm = GetQADataMaker(iDet);
-                       qadm->Reset(sameCycle);
+                       qadm->Reset();
                }
        } 
        if (fRawReaderDelete) { 
@@ -698,17 +815,94 @@ TString AliQADataMakerSteer::Run(const char * detectors, const AliQA::TASKINDEX_
                }
        }
        
-       if ( !Init(taskIndex, fileName) ) 
-               return kFALSE ; 
 
-       DoIt(taskIndex) ;
+       if ( taskIndex == AliQA::kNULLTASKINDEX) { 
+               for (UInt_t task = 0; task < AliQA::kNTASKINDEX; task++) {
+                       if ( fTasks.Contains(Form("%d", task)) ) {
+                               if ( !Init(AliQA::GetTaskIndex(AliQA::GetTaskName(task)), fileName) ) 
+                                       return kFALSE ; 
+                               DoIt(AliQA::GetTaskIndex(AliQA::GetTaskName(task))) ;
+                       }
+               }
+       } else {
+               if ( !Init(taskIndex, fileName) ) 
+                       return kFALSE ; 
+               DoIt(taskIndex) ; 
+       }               
        
        return fDetectorsW ;
 
 }
 
 //_____________________________________________________________________________
-Bool_t AliQADataMakerSteer::Save2OCDB(const Int_t runNumber, const char * year, const Int_t cycleNumber, const char * detectors) const
+void AliQADataMakerSteer::RunOneEvent(AliRawReader * rawReader) 
+{
+       //Runs all the QA data Maker for Raws only and on one event only (event loop done by calling method)
+  if ( ! rawReader ) 
+    return ; 
+       AliCodeTimerAuto("") ;
+  if (fTasks.Contains(Form("%d", AliQA::kRAWS))){
+    for (UInt_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+      if (!IsSelected(AliQA::GetDetName(iDet))) 
+        continue;
+      AliQADataMaker *qadm = GetQADataMaker(iDet);  
+      if (!qadm) 
+        continue;
+      if ( qadm->IsCycleDone() ) {
+        qadm->EndOfCycle() ;
+      }
+      AliCodeTimerStart(Form("running RAW quality assurance data maker for %s", AliQA::GetDetName(iDet))); 
+                       qadm->Exec(AliQA::kRAWS, rawReader) ;
+      AliCodeTimerStop(Form("running RAW quality assurance data maker for %s", AliQA::GetDetName(iDet)));
+               }
+  }
+}
+
+//_____________________________________________________________________________
+void AliQADataMakerSteer::RunOneEvent(AliESDEvent *& esd) 
+{
+       //Runs all the QA data Maker for ESDs only and on one event only (event loop done by calling method)
+       
+  AliCodeTimerAuto("") ;
+  if (fTasks.Contains(Form("%d", AliQA::kESDS))) {
+    for (UInt_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+      if (!IsSelected(AliQA::GetDetName(iDet))) 
+        continue;
+      AliQADataMaker *qadm = GetQADataMaker(iDet);  
+      if (!qadm) 
+        continue;
+      if ( qadm->IsCycleDone() ) {
+        qadm->EndOfCycle() ;
+      }
+      AliCodeTimerStart(Form("running ESD quality assurance data maker for %s", AliQA::GetDetName(iDet)));
+                       qadm->Exec(AliQA::kESDS, esd) ;
+      AliCodeTimerStop(Form("running ESD quality assurance data maker for %s", AliQA::GetDetName(iDet)));
+               }
+       }
+}
+
+//_____________________________________________________________________________
+void AliQADataMakerSteer::RunOneEventInOneDetector(Int_t det, TTree * tree) 
+{
+       // Runs all the QA data Maker for ESDs only and on one event only (event loop done by calling method)
+       AliCodeTimerAuto("") ;
+  if (fTasks.Contains(Form("%d", AliQA::kRECPOINTS))) {
+    if (IsSelected(AliQA::GetDetName(det))) {
+      AliQADataMaker *qadm = GetQADataMaker(det);  
+      if (qadm) { 
+        if ( qadm->IsCycleDone() ) {
+          qadm->EndOfCycle() ;
+        }
+        AliCodeTimerStart(Form("running RecPoints quality assurance data maker for %s", AliQA::GetDetName(det)));
+        qadm->Exec(AliQA::kRECPOINTS, tree) ;
+        AliCodeTimerStop(Form("running RecPoints quality assurance data maker for %s", AliQA::GetDetName(det)));
+      }
+    }
+  }
+}
+
+//_____________________________________________________________________________
+Bool_t AliQADataMakerSteer::Save2OCDB(const Int_t runNumber, const char * year, const char * detectors) const
 {
        // take the locasl QA data merge into a single file and save in OCDB 
        Bool_t rv = kTRUE ; 
@@ -728,13 +922,13 @@ Bool_t AliQADataMakerSteer::Save2OCDB(const Int_t runNumber, const char * year,
                rv = Merge(runNumber) ; 
                if ( ! rv )
                        return kFALSE ; 
-               TString inputFileName(Form("Merged.%s.%d.root", AliQA::GetQADataFileName(), runNumber)) ; 
+               TString inputFileName(Form("Merged.%s.Data.%d.root", AliQA::GetQADataFileName(), runNumber)) ; 
                inputFile = TFile::Open(inputFileName.Data()) ; 
                rv = SaveIt2OCDB(runNumber, inputFile, year) ; 
        } else {
                for (Int_t index = 0; index < AliQA::kNDET; index++) {
                        if (sdet.Contains(AliQA::GetDetName(index))) {
-                               TString inputFileName(Form("%s.%s.%d.%d.root", AliQA::GetDetName(index), AliQA::GetQADataFileName(), runNumber, cycleNumber)) ; 
+                               TString inputFileName(Form("%s.%s.%d.root", AliQA::GetDetName(index), AliQA::GetQADataFileName(), runNumber)) ; 
                                inputFile = TFile::Open(inputFileName.Data()) ;                         
                                rv *= SaveIt2OCDB(runNumber, inputFile, year) ; 
                        }
@@ -773,6 +967,7 @@ Bool_t AliQADataMakerSteer::SaveIt2OCDB(const Int_t runNumber, TFile * inputFile
                if ( detDir ) {
                        AliInfo(Form("Entering %s", detDir->GetName())) ;
                        TString detOCDBDir(Form("%s/%s/%s", AliQA::GetDetName(detIndex), AliQA::GetRefOCDBDirName(), AliQA::GetRefDataDirName())) ; 
+      printf("SSSSSSSSSSSSSSSSSSSSS %s\n", detOCDBDir.Data()) ; 
                        AliCDBId idr(detOCDBDir.Data(), runNumber, AliCDBRunRange::Infinity())  ;
                        TList * listDetQAD = new TList() ;
                        TString listName(Form("%s QA data Reference", AliQA::GetDetName(detIndex))) ; 
@@ -810,3 +1005,18 @@ Bool_t AliQADataMakerSteer::SaveIt2OCDB(const Int_t runNumber, TFile * inputFile
        return rv ; 
 }      
 
+//_____________________________________________________________________________
+void AliQADataMakerSteer::SetRecoParam(const char* detector, AliDetectorRecoParam *par)
+{
+  // Set custom reconstruction parameters for a given detector
+  // Single set of parameters for all the events
+  for (UInt_t iDet = 0; iDet < fgkNDetectors; iDet++) {
+    if(!strcmp(detector, AliQA::GetDetName(iDet))) {
+      par->SetAsDefault();
+      fRecoParam.AddDetRecoParam(iDet,par);
+      break;
+    }
+  }
+}
+
+