]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - STEER/AliReconstruction.cxx
Monitoring of process information: updated version (Marian)
[u/mrichter/AliRoot.git] / STEER / AliReconstruction.cxx
index 6e89804827ac0bb2689c6f23d58cfa634dcb0d8c..b91e0e1c494a7d5f29e4285d21c46d497eb7315b 100644 (file)
 #include "AliAODVertex.h"
 #include "AliAODCluster.h"
 
-#include "AliQualAssDataMaker.h" 
+#include "AliQADataMaker.h" 
+
+#include "AliSysInfo.h" // memory snapshots
+
 
 ClassImp(AliReconstruction)
 
@@ -191,14 +194,18 @@ AliReconstruction::AliReconstruction(const char* gAliceFilename, const char* cdb
   fRunCascadeFinder(kTRUE),
   fStopOnError(kFALSE),
   fWriteAlignmentData(kFALSE),
-  fCleanESD(kTRUE),
   fWriteESDfriend(kFALSE),
   fWriteAOD(kFALSE),
   fFillTriggerESD(kTRUE),
 
+  fCleanESD(kTRUE),
+  fDmax(50.),
+  fZmax(50.),
+
   fRunLocalReconstruction("ALL"),
   fRunTracking("ALL"),
   fFillESD("ALL"),
+  fUseTrackingErrorsForAlignment(""),
   fGAliceFileName(gAliceFilename),
   fInput(""),
   fEquipIdMap(""),
@@ -228,7 +235,8 @@ AliReconstruction::AliReconstruction(const char* gAliceFilename, const char* cdb
     fReconstructor[iDet] = NULL;
     fLoader[iDet] = NULL;
     fTracker[iDet] = NULL;
-    fQualAssDataMaker[iDet] = NULL;
+    fQADataMaker[iDet] = NULL;
+       fQACycles[iDet] = 999999;       
   }
   AliPID pid;
 }
@@ -245,14 +253,18 @@ AliReconstruction::AliReconstruction(const AliReconstruction& rec) :
   fRunCascadeFinder(rec.fRunCascadeFinder),
   fStopOnError(rec.fStopOnError),
   fWriteAlignmentData(rec.fWriteAlignmentData),
-  fCleanESD(rec.fCleanESD),
   fWriteESDfriend(rec.fWriteESDfriend),
   fWriteAOD(rec.fWriteAOD),
   fFillTriggerESD(rec.fFillTriggerESD),
 
+  fCleanESD(rec.fCleanESD),
+  fDmax(rec.fDmax),
+  fZmax(rec.fZmax),
+
   fRunLocalReconstruction(rec.fRunLocalReconstruction),
   fRunTracking(rec.fRunTracking),
   fFillESD(rec.fFillESD),
+  fUseTrackingErrorsForAlignment(rec.fUseTrackingErrorsForAlignment),
   fGAliceFileName(rec.fGAliceFileName),
   fInput(rec.fInput),
   fEquipIdMap(rec.fEquipIdMap),
@@ -285,7 +297,8 @@ AliReconstruction::AliReconstruction(const AliReconstruction& rec) :
     fReconstructor[iDet] = NULL;
     fLoader[iDet] = NULL;
     fTracker[iDet] = NULL;
-    fQualAssDataMaker[iDet] = NULL;
+    fQADataMaker[iDet] = NULL;
+       fQACycles[iDet] = rec.fQACycles[iDet];  
   }
   for (Int_t i = 0; i < rec.fSpecCDBUri.GetEntriesFast(); i++) {
     if (rec.fSpecCDBUri[i]) fSpecCDBUri.Add(rec.fSpecCDBUri[i]->Clone());
@@ -339,20 +352,21 @@ void AliReconstruction::InitCDBStorage()
 
   // Remote storage (the Grid storage) is used if it is activated
   // and if the object is not found in the default storage
-  if (man->IsRemoteStorageSet())
-  {
-    AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-    AliWarning("Remote CDB storage has been already set !");
-    AliWarning(Form("Ignoring the remote storage declared in AliReconstruction: %s",fRemoteCDBUri.Data()));
-    AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-    fRemoteCDBUri = "";
-  }
-  else {
-    AliDebug(2,"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-    AliDebug(2, Form("Remote CDB storage is set to: %s",fRemoteCDBUri.Data()));
-    AliDebug(2, "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
-    man->SetRemoteStorage(fRemoteCDBUri);
-  }
+  // OBSOLETE: Removed
+  //  if (man->IsRemoteStorageSet())
+  //  {
+  //   AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+  //   AliWarning("Remote CDB storage has been already set !");
+  //   AliWarning(Form("Ignoring the remote storage declared in AliReconstruction: %s",fRemoteCDBUri.Data()));
+  //   AliWarning("!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+  //   fRemoteCDBUri = "";
+  //  }
+  //  else {
+  //   AliDebug(2,"!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+  //   AliDebug(2, Form("Remote CDB storage is set to: %s",fRemoteCDBUri.Data()));
+  //   AliDebug(2, "!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+  //   man->SetRemoteStorage(fRemoteCDBUri);
+  //  }
 
   // Now activate the detector specific CDB storage locations
   for (Int_t i = 0; i < fSpecCDBUri.GetEntriesFast(); i++) {
@@ -556,12 +570,14 @@ Bool_t AliReconstruction::Run(const char* input)
   if (!fEquipIdMap.IsNull() && fRawReader)
     fRawReader->LoadEquipmentIdsMap(fEquipIdMap);
 
-
+   AliSysInfo::AddStamp("Start");
   // get the run loader
   if (!InitRunLoader()) return kFALSE;
+   AliSysInfo::AddStamp("LoadLoader");
 
   // Initialize the CDB storage
   InitCDBStorage();
+   AliSysInfo::AddStamp("LoadCDB");
 
   // Set run number in CDBManager (if it is not already set by the user)
   if (!SetRunNumber()) if (fStopOnError) return kFALSE;
@@ -575,6 +591,7 @@ Bool_t AliReconstruction::Run(const char* input)
   }
 
   if (!MisalignGeometry(fLoadAlignData)) if (fStopOnError) return kFALSE;
+   AliSysInfo::AddStamp("LoadGeom");
 
   // local reconstruction
   if (!fRunLocalReconstruction.IsNull()) {
@@ -592,6 +609,7 @@ Bool_t AliReconstruction::Run(const char* input)
       return kFALSE;
     }
   }
+   AliSysInfo::AddStamp("Vertexer");
 
   // get trackers
   if (!fRunTracking.IsNull() && !CreateTrackers(fRunTracking)) {
@@ -600,6 +618,7 @@ Bool_t AliReconstruction::Run(const char* input)
       return kFALSE;
     }      
   }
+   AliSysInfo::AddStamp("LoadTrackers");
 
   // get the possibly already existing ESD file and tree
   AliESDEvent* esd = new AliESDEvent(); AliESDEvent* hltesd = new AliESDEvent();
@@ -672,6 +691,10 @@ Bool_t AliReconstruction::Run(const char* input)
   ProcInfo_t ProcInfo;
   gSystem->GetProcInfo(&ProcInfo);
   AliInfo(Form("Current memory usage %d %d", ProcInfo.fMemResident, ProcInfo.fMemVirtual));
+  
+  // checking the QA of previous steps
+  CheckQA() ; 
+  
   for (Int_t iEvent = 0; iEvent < fRunLoader->GetNumberOfEvents(); iEvent++) {
     if (fRawReader) fRawReader->NextEvent();
     if ((iEvent < fFirstEvent) || ((fLastEvent >= 0) && (iEvent > fLastEvent))) {
@@ -767,7 +790,7 @@ Bool_t AliReconstruction::Run(const char* input)
     }
   
     if (!fFillESD.IsNull()) 
-    RunQualAss(fFillESD.Data(), esd);
+    RunQA(fFillESD.Data(), esd);
 
     // fill Event header information from the RawEventHeader
     if (fRawReader){FillRawEventHeaderESD(esd);}
@@ -785,6 +808,8 @@ Bool_t AliReconstruction::Run(const char* input)
       }
     }
 
+    file->cd();
+
     //Try to improve the reconstructed primary vertex position using the tracks
     AliESDVertex *pvtx=0;
     Bool_t dovertex=kTRUE;
@@ -855,10 +880,12 @@ Bool_t AliReconstruction::Run(const char* input)
   for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
        if (!IsSelected(fgkDetectorName[iDet], detStr)) 
                continue;
-    AliQualAssDataMaker * qadm = GetQualAssDataMaker(iDet);
+    AliQADataMaker * qadm = GetQADataMaker(iDet);
     if (!qadm) continue;
-    qadm->Finish(AliQualAss::kRECPOINTS);
-    qadm->Finish(AliQualAss::kESDS) ; 
+    qadm->EndOfCycle(AliQA::kRECPOINTS);
+    qadm->EndOfCycle(AliQA::kESDS);
+    qadm->Finish(AliQA::kRECPOINTS);
+    qadm->Finish(AliQA::kESDS) ; 
   }
 
   tree->GetUserInfo()->Add(esd);
@@ -876,7 +903,8 @@ Bool_t AliReconstruction::Run(const char* input)
   file->cd();
   if (fWriteESDfriend)
     tree->SetBranchStatus("ESDfriend*",0);
-  tree->Write();
+  // we want to have only one tree version number
+  tree->Write(tree->GetName(),TObject::kOverwrite);
   hlttree->Write();
 
   if (fWriteAOD) {
@@ -905,7 +933,7 @@ Bool_t AliReconstruction::Run(const char* input)
 Bool_t AliReconstruction::RunLocalReconstruction(const TString& detectors)
 {
 // run the local reconstruction
-
+  static Int_t eventNr=0;
   AliCodeTimerAuto("")
 
  //  AliCDBManager* man = AliCDBManager::Instance();
@@ -938,6 +966,7 @@ Bool_t AliReconstruction::RunLocalReconstruction(const TString& detectors)
 //     }
      
 //      AliCodeTimerStop(Form("running reconstruction for %s", fgkDetectorName[iDet]));
+    // AliSysInfo::AddStamp(Form("LRec%s_%d",fgkDetectorName[iDet],eventNr));
 
 //     // unload calibration data
 //     man->UnloadFromCache(calibPath);
@@ -952,6 +981,7 @@ Bool_t AliReconstruction::RunLocalReconstruction(const TString& detectors)
 //     if (fStopOnError) return kFALSE;
 //   }
 
+         eventNr++;
   return kTRUE;
 }
 
@@ -959,7 +989,7 @@ Bool_t AliReconstruction::RunLocalReconstruction(const TString& detectors)
 Bool_t AliReconstruction::RunLocalEventReconstruction(const TString& detectors)
 {
 // run the local reconstruction
-
+  static Int_t eventNr=0;
   AliCodeTimerAuto("")
 
   TString detStr = detectors;
@@ -1009,16 +1039,24 @@ Bool_t AliReconstruction::RunLocalEventReconstruction(const TString& detectors)
       loader->UnloadDigits();
     }
 
-    AliQualAssDataMaker * qadm = GetQualAssDataMaker(iDet);
+    AliQADataMaker * qadm = GetQADataMaker(iDet);
     if (qadm) {
       AliCodeTimerStart(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
       AliInfo(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
-      qadm->Exec(AliQualAss::kRECPOINTS, clustersTree) ; 
+         
+     if (qadm->IsCycleDone() ) {
+      qadm->EndOfCycle(AliQA::kRECPOINTS) ; 
+         qadm->EndOfCycle(AliQA::kESDS) ; 
+      qadm->StartOfCycle(AliQA::kRECPOINTS) ; 
+         qadm->StartOfCycle(AliQA::kESDS, "same") ; 
+     }
+      qadm->Exec(AliQA::kRECPOINTS, clustersTree) ; 
       AliCodeTimerStop(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
     }
 
     loader->WriteRecPoints("OVERWRITE");
     loader->UnloadRecPoints();
+    AliSysInfo::AddStamp(Form("LRec%s_%d",fgkDetectorName[iDet],eventNr), iDet,1,eventNr);
   }
 
   if ((detStr.CompareTo("ALL") != 0) && !detStr.IsNull()) {
@@ -1026,7 +1064,7 @@ Bool_t AliReconstruction::RunLocalEventReconstruction(const TString& detectors)
                   detStr.Data()));
     if (fStopOnError) return kFALSE;
   }
-  
+  eventNr++;
   return kTRUE;
 }
 
@@ -1206,7 +1244,7 @@ Bool_t AliReconstruction::RunMuonTracking(AliESDEvent*& esd)
 Bool_t AliReconstruction::RunTracking(AliESDEvent*& esd)
 {
 // run the barrel tracking
-
+  static Int_t eventNr=0;
   AliCodeTimerAuto("")
 
   AliInfo("running tracking");
@@ -1225,13 +1263,14 @@ Bool_t AliReconstruction::RunTracking(AliESDEvent*& esd)
 
     // load clusters
     fLoader[iDet]->LoadRecPoints("read");
+    AliSysInfo::AddStamp(Form("RLoadCluster%s_%d",fgkDetectorName[iDet],eventNr),iDet,1, eventNr);
     TTree* tree = fLoader[iDet]->TreeR();
     if (!tree) {
       AliError(Form("Can't get the %s cluster tree", fgkDetectorName[iDet]));
       return kFALSE;
     }
     fTracker[iDet]->LoadClusters(tree);
-
+    AliSysInfo::AddStamp(Form("TLoadCluster%s_%d",fgkDetectorName[iDet],eventNr), iDet,2, eventNr);
     // run tracking
     if (fTracker[iDet]->Clusters2Tracks(esd) != 0) {
       AliError(Form("%s Clusters2Tracks failed", fgkDetectorName[iDet]));
@@ -1244,7 +1283,8 @@ Bool_t AliReconstruction::RunTracking(AliESDEvent*& esd)
     if (iDet == 1) {
       GetReconstructor(1)->FillESD((TTree*)NULL, (TTree*)NULL, esd);
       AliESDpid::MakePID(esd);
-    }
+    } 
+    AliSysInfo::AddStamp(Form("Tracking0%s_%d",fgkDetectorName[iDet],eventNr), iDet,3,eventNr);
   }
 
   // pass 2: ALL backwards
@@ -1256,12 +1296,14 @@ Bool_t AliReconstruction::RunTracking(AliESDEvent*& esd)
     if (iDet > 1) {     // all except ITS, TPC
       TTree* tree = NULL;
       fLoader[iDet]->LoadRecPoints("read");
+      AliSysInfo::AddStamp(Form("RLoadCluster0%s_%d",fgkDetectorName[iDet],eventNr), iDet,1, eventNr);
       tree = fLoader[iDet]->TreeR();
       if (!tree) {
        AliError(Form("Can't get the %s cluster tree", fgkDetectorName[iDet]));
        return kFALSE;
       }
-      fTracker[iDet]->LoadClusters(tree);
+      fTracker[iDet]->LoadClusters(tree); 
+      AliSysInfo::AddStamp(Form("TLoadCluster0%s_%d",fgkDetectorName[iDet],eventNr), iDet,2, eventNr);
     }
 
     // run tracking
@@ -1283,6 +1325,7 @@ Bool_t AliReconstruction::RunTracking(AliESDEvent*& esd)
       GetReconstructor(1)->FillESD((TTree*)NULL, (TTree*)NULL, esd);
       AliESDpid::MakePID(esd);
     }
+    AliSysInfo::AddStamp(Form("Tracking1%s_%d",fgkDetectorName[iDet],eventNr), iDet,3, eventNr);
   }
 
   // write space-points to the ESD in case alignment data output
@@ -1303,10 +1346,12 @@ Bool_t AliReconstruction::RunTracking(AliESDEvent*& esd)
     if (fCheckPointLevel > 1) {
       WriteESD(esd, Form("%s.refit", fgkDetectorName[iDet]));
     }
-
+    AliSysInfo::AddStamp(Form("Tracking2%s_%d",fgkDetectorName[iDet],eventNr), iDet,3, eventNr);
     // unload clusters
     fTracker[iDet]->UnloadClusters();
+    AliSysInfo::AddStamp(Form("TUnloadCluster%s_%d",fgkDetectorName[iDet],eventNr), iDet,4, eventNr);
     fLoader[iDet]->UnloadRecPoints();
+    AliSysInfo::AddStamp(Form("RUnloadCluster%s_%d",fgkDetectorName[iDet],eventNr), iDet,5, eventNr);
   }
   //
   // Propagate track to the vertex - if not done by ITS
@@ -1323,7 +1368,7 @@ Bool_t AliReconstruction::RunTracking(AliESDEvent*& esd)
    AliTracker::PropagateTrackTo(track,kRadius,track->GetMass(),kMaxStep,kTRUE);
     track->RelateToVertex(esd->GetVertex(),fieldZ, kMaxD);
   }
-  
+  eventNr++;
   return kTRUE;
 }
 
@@ -1334,23 +1379,16 @@ Bool_t AliReconstruction::CleanESD(AliESDEvent *esd){
   //
 
   AliInfo("Cleaning the ESD...");
-
-  const AliESDVertex *vertex=esd->GetVertex();
-  Double_t vz=vertex->GetZv();
-  
   Int_t nTracks=esd->GetNumberOfTracks();
-  for (Int_t i=0; i<nTracks; i++) {
-    AliESDtrack *track=esd->GetTrack(i);
+  AliInfo(Form("Number of ESD tracks before cleaning %d",nTracks));
 
-    Float_t xy,z; track->GetImpactParameters(xy,z);
-    if (TMath::Abs(xy) < 50.)    continue;  
-    if (vertex->GetStatus())
-      if (TMath::Abs(vz-z) < 5.) continue;  
+  Float_t cleanPars[]={fDmax,fZmax};
+  Bool_t rc=esd->Clean(cleanPars);
 
-    esd->RemoveTrack(i);
-  }
+  nTracks=esd->GetNumberOfTracks();
+  AliInfo(Form("Number of ESD tracks after cleaning %d",nTracks));
 
-  return kTRUE;
+  return rc;
 }
 
 //_____________________________________________________________________________
@@ -1359,7 +1397,7 @@ Bool_t AliReconstruction::FillESD(AliESDEvent*& esd, const TString& detectors)
 // fill the event summary data
 
   AliCodeTimerAuto("")
-
+    static Int_t eventNr=0; 
   TString detStr = detectors;
   for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
     if (!IsSelected(fgkDetectorName[iDet], detStr)) continue;
@@ -1407,7 +1445,8 @@ Bool_t AliReconstruction::FillESD(AliESDEvent*& esd, const TString& detectors)
                   detStr.Data()));
     if (fStopOnError) return kFALSE;
   }
-
+  AliSysInfo::AddStamp(Form("FillESD%d",eventNr), 0,1, eventNr);
+  eventNr++;
   return kTRUE;
 }
 
@@ -1612,15 +1651,6 @@ AliReconstructor* AliReconstruction::GetReconstructor(Int_t iDet)
   TString recName = "Ali" + detName + "Reconstructor";
   if (gAlice && !gAlice->GetDetector(detName) && (detName != "HLT")) return NULL;
 
-  if (detName == "HLT") {
-    if (!gROOT->GetClass("AliLevel3")) {
-      gSystem->Load("libAliHLTSrc.so");
-      gSystem->Load("libAliHLTMisc.so");
-      gSystem->Load("libAliHLTHough.so");
-      gSystem->Load("libAliHLTComp.so");
-    }
-  }
-
   AliReconstructor* reconstructor = NULL;
   // first check if a plugin is defined for the reconstructor
   TPluginHandler* pluginHandler = 
@@ -1735,6 +1765,7 @@ Bool_t AliReconstruction::CreateTrackers(const TString& detectors)
       AliWarning(Form("couldn't create a tracker for %s", detName.Data()));
       if (fStopOnError) return kFALSE;
     }
+    AliSysInfo::AddStamp(Form("LTracker%s",fgkDetectorName[iDet]), iDet,0);
   }
 
   return kTRUE;
@@ -1751,8 +1782,8 @@ void AliReconstruction::CleanUp(TFile* file, TFile* fileOld)
     fLoader[iDet] = NULL;
     delete fTracker[iDet];
     fTracker[iDet] = NULL;
-    delete fQualAssDataMaker[iDet];
-    fQualAssDataMaker[iDet] = NULL;
+    delete fQADataMaker[iDet];
+    fQADataMaker[iDet] = NULL;
   }
   delete fVertexer;
   fVertexer = NULL;
@@ -2484,15 +2515,15 @@ void AliReconstruction::ESDFile2AODFile(TFile* esdFile, TFile* aodFile)
       AliAODTrack *primTrack = NULL;
       Char_t ttype=AliAODCluster::kUndef;
 
-      if (cluster->IsPHOS()) ttype=AliAODCluster::kPHOSNeutral;
-      else if (cluster->IsEMCAL()) {
-
-       if (cluster->GetClusterType() == AliESDCaloCluster::kPseudoCluster)
-         ttype = AliAODCluster::kEMCALPseudoCluster;
-       else
-         ttype = AliAODCluster::kEMCALClusterv1;
-
+      if (cluster->GetClusterType() == AliESDCaloCluster::kPHOSCluster){
+       ttype = AliAODCluster::kPHOSNeutral;
       }
+      else if (cluster->GetClusterType() == AliESDCaloCluster::kEMCALClusterv1){
+       ttype = AliAODCluster::kEMCALClusterv1;
+      }      
+      else if (cluster->GetClusterType() == AliESDCaloCluster::kEMCALPseudoCluster){
+       ttype = AliAODCluster::kEMCALPseudoCluster;
+      }    
 
       new(clusters[jClusters++]) AliAODCluster(id,
                                               label,
@@ -2578,7 +2609,13 @@ void AliReconstruction::WriteAlignmentData(AliESDEvent* esd)
          Int_t isp = 0;
          Int_t isp2 = 0;
          while (isp < nspdet) {
-           Bool_t isvalid = tracker->GetTrackPoint(idx[isp2],p); isp2++;
+           Bool_t isvalid;
+           if(IsSelected(fgkDetectorName[iDet],fUseTrackingErrorsForAlignment)) {
+             isvalid = tracker->GetTrackPointTrackingError(idx[isp2],p,track);
+           } else {
+             isvalid = tracker->GetTrackPoint(idx[isp2],p); 
+           } 
+           isp2++;
            const Int_t kNTPCmax = 159;
            if (iDet==1 && isp2>kNTPCmax) break;   // to be fixed
            if (!isvalid) continue;
@@ -2660,54 +2697,58 @@ void AliReconstruction::TNamedToFile(TTree* fTree, TString fName){
   out.close();
 
 }
+  
+
 
 //_____________________________________________________________________________
-AliQualAssDataMaker * AliReconstruction::GetQualAssDataMaker(Int_t iDet)
+AliQADataMaker * AliReconstruction::GetQADataMaker(Int_t iDet)
 {
 // get the quality assurance data maker object and the loader for a detector
 
-  if (fQualAssDataMaker[iDet]) 
-    return fQualAssDataMaker[iDet];
+  if (fQADataMaker[iDet]) 
+    return fQADataMaker[iDet];
 
   // load the QA data maker object
   TPluginManager* pluginManager = gROOT->GetPluginManager();
   TString detName = fgkDetectorName[iDet];
-  TString qadmName = "Ali" + detName + "QualAssDataMaker";
+  TString qadmName = "Ali" + detName + "QADataMaker";
   if (gAlice && !gAlice->GetDetector(detName) && (detName != "HLT")) 
     return NULL;
 
-  AliQualAssDataMaker * qadm = NULL;
+  AliQADataMaker * qadm = NULL;
   // first check if a plugin is defined for the quality assurance data maker
-  TPluginHandler* pluginHandler = pluginManager->FindHandler("AliQualAssDataMaker", detName);
+  TPluginHandler* pluginHandler = pluginManager->FindHandler("AliQADataMaker", detName);
   // if not, add a plugin for it
   if (!pluginHandler) {
     AliDebug(1, Form("defining plugin for %s", qadmName.Data()));
     TString libs = gSystem->GetLibraries();
     if (libs.Contains("lib" + detName + "base.so") ||
        (gSystem->Load("lib" + detName + "base.so") >= 0)) {
-      pluginManager->AddHandler("AliQualAssDataMaker", detName, 
+      pluginManager->AddHandler("AliQADataMaker", detName, 
                                qadmName, detName + "qadm", qadmName + "()");
     } else {
-      pluginManager->AddHandler("AliQualAssDataMaker", detName, 
+      pluginManager->AddHandler("AliQADataMaker", detName, 
                                qadmName, detName, qadmName + "()");
     }
-    pluginHandler = pluginManager->FindHandler("AliQualAssDataMaker", detName);
+    pluginHandler = pluginManager->FindHandler("AliQADataMaker", detName);
   }
   if (pluginHandler && (pluginHandler->LoadPlugin() == 0)) {
-    qadm = (AliQualAssDataMaker *) pluginHandler->ExecPlugin(0);
+    qadm = (AliQADataMaker *) pluginHandler->ExecPlugin(0);
   }
   if (qadm) {
     AliInfo(Form("Initializing quality assurance data maker for %s", fgkDetectorName[iDet]));
-    qadm->Init(AliQualAss::kRECPOINTS);
-    qadm->Init(AliQualAss::kESDS) ; 
-    fQualAssDataMaker[iDet] = qadm;
+    qadm->Init(AliQA::kRECPOINTS, AliCDBManager::Instance()->GetRun(), GetQACycles(fgkDetectorName[iDet]));
+    qadm->StartOfCycle(AliQA::kRECPOINTS);
+    qadm->Init(AliQA::kESDS, AliCDBManager::Instance()->GetRun());
+    qadm->StartOfCycle(AliQA::kESDS, "same") ;         
+    fQADataMaker[iDet] = qadm;
   }
 
   return qadm;
 }
 
 //_____________________________________________________________________________
-Bool_t AliReconstruction::RunQualAss(const char* detectors, AliESDEvent *& esd)
+Bool_t AliReconstruction::RunQA(const char* detectors, AliESDEvent *& esd)
 {
   // run the Quality Assurance data producer
 
@@ -2716,13 +2757,14 @@ Bool_t AliReconstruction::RunQualAss(const char* detectors, AliESDEvent *& esd)
   for (Int_t iDet = 0; iDet < fgkNDetectors; iDet++) {
    if (!IsSelected(fgkDetectorName[iDet], detStr)) 
      continue;
-   AliQualAssDataMaker * qadm = GetQualAssDataMaker(iDet);
+   AliQADataMaker * qadm = GetQADataMaker(iDet);
    if (!qadm) 
      continue;
    AliCodeTimerStart(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
    AliInfo(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
     
-   qadm->Exec(AliQualAss::kESDS, esd) ; 
+   qadm->Exec(AliQA::kESDS, esd) ; 
+   qadm->Increment() ; 
 
    AliCodeTimerStop(Form("running quality assurance data maker for %s", fgkDetectorName[iDet]));
  }
@@ -2734,4 +2776,50 @@ Bool_t AliReconstruction::RunQualAss(const char* detectors, AliESDEvent *& esd)
  }
  
  return kTRUE;
+  
+}
+
+
+//_____________________________________________________________________________
+void AliReconstruction::CheckQA()
+{
+// check the QA of SIM for this run and remove the detectors 
+// with status Fatal
+  
+       TString newDetList ; 
+       for (Int_t iDet = 0; iDet < AliQA::kNDET; iDet++) {
+               TString detName(AliQA::GetDetName(iDet)) ;
+               if ( fRunLocalReconstruction.Contains(AliQA::GetDetName(iDet)) || 
+                       fRunLocalReconstruction.Contains("ALL") )  {
+                       AliQA * qa = AliQA::Instance(AliQA::DETECTORINDEX(iDet)) ; 
+                       if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kFATAL)) {
+                               AliInfo(Form("QA status for %s in Hits and/or SDIGITS  and/or Digits was Fatal; No reconstruction performed", detName.Data())) ;
+                       } else if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kERROR)) {
+                               AliError(Form("QA status for %s in Hits and/or SDIGITS  and/or Digits was ERROR", detName.Data())) ;
+                               newDetList += detName ; 
+                               newDetList += " " ; 
+                       } else if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kWARNING) ) {
+                               AliWarning(Form("QA status for %s in Hits and/or SDIGITS  and/or Digits was WARNING", detName.Data())) ;
+                               newDetList += detName ; 
+                               newDetList += " " ; 
+                       } else if ( qa->IsSet(AliQA::DETECTORINDEX(iDet), AliQA::kSIM, AliQA::kINFO) ) {
+                               AliInfo(Form("QA status for %s in Hits and/or SDIGITS  and/or Digits was INFO", detName.Data())) ;
+                               newDetList += detName ; 
+                               newDetList += " " ; 
+                       }
+               }
+       }
+       fRunLocalReconstruction = newDetList ; 
+}
+
+//_____________________________________________________________________________
+Int_t AliReconstruction::GetDetIndex(const char* detector)
+{
+  // return the detector index corresponding to detector
+  Int_t index = -1 ; 
+  for (index = 0; index < fgkNDetectors ; index++) {
+    if ( strcmp(detector, fgkDetectorName[index]) == 0 )
+       break ; 
+  }    
+  return index ; 
 }