merger methods for QA files
authorschutz <schutz@f7af4fe6-9843-0410-8265-dc069ae4e863>
Fri, 6 Mar 2009 14:59:55 +0000 (14:59 +0000)
committerschutz <schutz@f7af4fe6-9843-0410-8265-dc069ae4e863>
Fri, 6 Mar 2009 14:59:55 +0000 (14:59 +0000)
STEER/AliQAManager.cxx
STEER/AliReconstruction.cxx
STEER/AliReconstruction.h
test/PbPbbench/rec.C
test/PbPbbench/recraw/rec.C
test/QA/rawqa.C
test/ppbench/rec.C
test/ppbench/recraw/rec.C

index 0f738b6..673205e 100644 (file)
@@ -720,7 +720,7 @@ Bool_t AliQAManager::MergeData(const Int_t runNumber) const
 {
        // Merge all the cycles from all detectors in one single file per run
        TString cmd ;
-       if (runNumber == -1) 
+       if (runNumber != -1) 
                cmd = Form(".! ls *%s*.%d.root > tempo.txt", AliQA::GetQADataFileName(), runNumber) ; 
        else 
                cmd = Form(".! ls *%s*.*.root > tempo.txt", AliQA::GetQADataFileName()) ; 
@@ -744,7 +744,11 @@ Bool_t AliQAManager::MergeData(const Int_t runNumber) const
        }
 
   TFileMerger merger ; 
-  TString outFileName(Form("Merged.%s.Data.%d.root",AliQA::GetQADataFileName(),runNumber)); 
+  TString outFileName ;
+  if (runNumber != -1) 
+    outFileName = Form("Merged.%s.Data.%d.root",AliQA::GetQADataFileName(),runNumber); 
+  else 
+    outFileName = Form("Merged.%s.Data.root",AliQA::GetQADataFileName()); 
   merger.OutputFile(outFileName.Data()) ; 
   for (Int_t ifile = 0 ; ifile < index-1 ; ifile++) {
     TString pattern(Form("%s.%d.", AliQA::GetQADataFileName(), runNumber)); 
@@ -784,7 +788,11 @@ Bool_t AliQAManager::MergeResults(const Int_t runNumber) const
        }
        
        TFileMerger merger ; 
-       TString outFileName(Form("Merged.%s.Result.%d.root", AliQA::GetQADataFileName(), runNumber));           
+  TString outFileName ;
+  if (runNumber != -1) 
+    outFileName = Form("Merged.%s.Result.%d.root",AliQA::GetQADataFileName(),runNumber); 
+  else 
+    outFileName = Form("Merged.%s.Result.root",AliQA::GetQADataFileName()); 
        merger.OutputFile(outFileName.Data()) ; 
        for (Int_t ifile = 0 ; ifile < index ; ifile++) {
                TString file = fileList[ifile] ; 
index cb0132d..ffd9cac 100644 (file)
@@ -1,6 +1,6 @@
 /**************************************************************************
  * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
- *                                                                        *QARef
+ *                                                                        *
  * Author: The ALICE Off-line Project.                                    *
  * Contributors are mentioned in the code where appropriate.              *
  *                                                                        *
@@ -569,11 +569,24 @@ void AliReconstruction::InitQA()
       qadm->StartOfCycle(AliQA::kESDS, AliCDBManager::Instance()->GetRun(), sameCycle) ; 
       qadm->Init(AliQA::kESDS);
     }
-    AliSysInfo::AddStamp("InitQA");
   }
+    AliSysInfo::AddStamp("InitQA") ; 
 }
 
 //_____________________________________________________________________________
+void AliReconstruction::MergeQA()
+{
+  //Initialize the QA and start of cycle 
+  AliCodeTimerAuto("") ;
+  if ( ! fQAManager ) {
+    AliFatal("Hum... this should not happen") ; 
+  } else { 
+   fQAManager->Merge(AliCDBManager::Instance()->GetRun()) ; 
+  }
+  AliSysInfo::AddStamp("MergeQA") ; 
+}
+  
+//_____________________________________________________________________________
 void AliReconstruction::InitCDB()
 {
 // activate a default CDB storage
index 0b16b4a..c24404b 100644 (file)
@@ -144,7 +144,7 @@ public:
   void    SetRunGlobalQA(Bool_t flag=kTRUE){fRunGlobalQA = flag;}
   void    SetQARefDefaultStorage(const char* uri);
   void    InitQA();
-
+  void    MergeQA(); 
 
   // Plane Efficiency Evaluation
   void    SetRunPlaneEff(Bool_t flag=kFALSE)  {fRunPlaneEff = flag;}
@@ -274,6 +274,7 @@ private:
   Bool_t                fRunGlobalQA;   // Run global QA flag
   Bool_t                fSameQACycle;   //! open a new QA data file or not
   Bool_t                fInitQACalled;  //! control of QA intialisation
+  
   // Plane Efficiency Evaluation
   Bool_t         fRunPlaneEff ;      // Evaluate Plane Efficiency
 
index e8fa902..e24673c 100644 (file)
@@ -19,6 +19,7 @@ void rec() {
   TStopwatch timer;
   timer.Start();
   reco.Run();
+  reco.MergeQA() ; 
   timer.Stop();
   timer.Print();
 }
index 2793548..461335a 100644 (file)
@@ -26,6 +26,7 @@ void rec() {
   TStopwatch timer;
   timer.Start();
   reco.Run();
+  reco.MergeQA() ; 
   timer.Stop();
   timer.Print();
 }
index 240d25f..ae13e97 100644 (file)
@@ -25,10 +25,10 @@ TString ClassName() { return "rawqa" ; }
 //________________________________qa______________________________________
 void rawqa(const Int_t runNumber, Int_t maxFiles = 10, const char* year = "08") 
 {      
-       char * kDefaultOCDBStorage = Form("alien://folder=/alice/data/20%s/LHC%sd/OCDB/", year, year) ; 
+//     char * kDefaultOCDBStorage = Form("alien://folder=/alice/data/20%s/LHC%sd/OCDB/", year, year) ; 
+       char * kDefaultOCDBStorage = Form("local://$ALICE_ROOT/OCDB") ; 
        //AliQA::SetQARefStorage(Form("%s%s/", AliQA::GetQARefDefaultStorage(), year)) ;  
-       AliQA::SetQARefStorage("local://$ALICE_ROOT/OCDB") ;
-       AliQA::SetQARefDataDirName(AliQA::kMONTECARLO) ; //RUN_TYPE
+       AliQA::SetQARefStorage("local://$ALICE_ROOT/QAref") ;
        
        UInt_t maxEvents = 99999 ;
        if ( maxFiles < 0 ) {
@@ -38,7 +38,7 @@ void rawqa(const Int_t runNumber, Int_t maxFiles = 10, const char* year = "08")
        AliLog::SetGlobalDebugLevel(0) ; 
        // connect to the grid 
        TGrid * grid = 0x0 ; 
-               grid = TGrid::Connect("alien://") ; 
+//             grid = TGrid::Connect("alien://") ; 
                
        Bool_t detIn[AliDAQ::kNDetectors] = {kFALSE} ;
        TString detNameOff[AliDAQ::kNDetectors] = {"ITS", "ITS", "ITS", "TPC", "TRD", "TOF", "HMPID", "PHOS", "PHOS", "PMD", "MUON", "MUON", "FMD", "T0", "VZERO", "ZDC", "ACORDE", "TRG", "EMCAL", "DAQ_TEST", "HLT"} ; 
@@ -75,7 +75,6 @@ void rawqa(const Int_t runNumber, Int_t maxFiles = 10, const char* year = "08")
        if (local) 
                in.open("tempo.txt", ifstream::in) ; 
 
-       AliQADataMakerSteer qas("rec") ; 
        TString detectors  = ""; 
        TString detectorsW = ""; 
        UShort_t file = 0 ; 
@@ -84,6 +83,10 @@ void rawqa(const Int_t runNumber, Int_t maxFiles = 10, const char* year = "08")
        AliCDBManager* man = AliCDBManager::Instance();
        man->SetDefaultStorage(kDefaultOCDBStorage) ;  
        man->SetRun(runNumber) ; 
+       AliQAManager qam("rec") ; 
+  qam->SetDefaultStorage(AliQA::GetQARefStorage()) ; 
+  qam->SetRun(runNumber) ; 
+    
        AliGeomManager::LoadGeometry();
        for ( file = 0 ; file < maxFiles ; file++) {
                if ( qas.GetCurrentEvent() >= maxEvents) 
@@ -112,6 +115,7 @@ void rawqa(const Int_t runNumber, Int_t maxFiles = 10, const char* year = "08")
                AliTRDrawStreamBase::SetRawStreamVersion("TB");
                while ( rawReader->NextEvent() ) {
                        man->SetRun(rawReader->GetRunNumber());
+                       qam->SetRun(rawReader->GetRunNumber());
                        AliLog::Flush();
                        UChar_t * data ; 
                        while (rawReader->ReadNextData(data)) {
@@ -134,9 +138,9 @@ void rawqa(const Int_t runNumber, Int_t maxFiles = 10, const char* year = "08")
                                break ; 
                }
                if ( !detectors.IsNull() ) {
-                       qas.SetMaxEvents(maxEvents) ;   
-                       detectorsW = qas.Run(detectors, rawReader) ;
-                       qas.Reset() ;
+                       qam.SetMaxEvents(maxEvents) ;   
+                       detectorsW = qam.Run(detectors, rawReader) ;
+                       qam.Reset() ;
                } else {
                        AliError("No valid detectors found") ; 
                } 
@@ -144,7 +148,7 @@ void rawqa(const Int_t runNumber, Int_t maxFiles = 10, const char* year = "08")
                eventsProcessed += qas.GetCurrentEvent() ; 
        }
        AliLog::Flush();
-       qas.Merge(runNumber) ; 
+       qam.Merge(runNumber) ; 
        
        AliLog::Flush();
        // The summary 
index 3c8735e..bb46eee 100644 (file)
@@ -20,6 +20,7 @@ void rec() {
   TStopwatch timer;
   timer.Start();
   reco.Run();
+  reco.MergeQA() ; 
   timer.Stop();
   timer.Print();
 }
index 9f373de..8436547 100644 (file)
@@ -26,6 +26,7 @@ void rec() {
   TStopwatch timer;
   timer.Start();
   reco.Run();
+  reco.MergeQA() ; 
   timer.Stop();
   timer.Print();
 }