]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - ANALYSIS/AliPhysicsSelection.cxx
Compatibility with ROOT trunk
[u/mrichter/AliRoot.git] / ANALYSIS / AliPhysicsSelection.cxx
index cd88fc35d507aa67b2473513a1cb72660389240b..2f8da1d126915b2f5bc0a4612615f8cd18c25c2b 100644 (file)
@@ -92,6 +92,8 @@
 // to be present:
 //   AddBGTriggerClass("+CSMBA-ABCE-NOPF-ALL -CSMBB-ABCE-NOPF-ALL");
 //
+// The class also supports the triggers used in heavy ion runs
+//
 //   Origin: Jan Fiete Grosse-Oetringhaus, CERN 
 //           Michele Floris, CERN
 //-------------------------------------------------------------------------
 #include <TIterator.h>
 #include <TDirectory.h>
 #include <TObjArray.h>
+#include <TPRegexp.h>
+#include <TFormula.h>
+#include <TParameter.h>
+#include <TInterpreter.h>
 
 #include <AliPhysicsSelection.h>
 
 #include <AliESDEvent.h>
 #include <AliAnalysisTaskSE.h>
 #include "AliAnalysisManager.h"
-
+#include "TPRegexp.h"
+#include "TFile.h"
+#include <AliOADBContainer.h>
+#include "AliOADBPhysicsSelection.h"
+#include "AliOADBFillingScheme.h"
+#include "AliOADBTriggerAnalysis.h"
+
+using std::cout;
+using std::endl;
 ClassImp(AliPhysicsSelection)
 
 AliPhysicsSelection::AliPhysicsSelection() :
@@ -122,20 +136,29 @@ AliPhysicsSelection::AliPhysicsSelection() :
   fCollTrigClasses(),
   fBGTrigClasses(),
   fTriggerAnalysis(),
-  fBackgroundIdentification(0),
+//  fHistStatisticsTokens(0),
   fHistBunchCrossing(0),
   fHistTriggerPattern(0),
   fSkipTriggerClassSelection(0),
   fUsingCustomClasses(0),
   fSkipV0(0),
-  fBIFactorA(1),
-  fBIFactorC(1),
+  fBIFactorA(-1),
+  fBIFactorC(-1),
+  fBIFactorAC(-1), 
   fComputeBG(0),
+  fBGStatOffset(-1),
   fUseBXNumbers(1),
   fUseMuonTriggers(0),
   fFillingScheme(""),
   fBin0CallBack(""),
-  fBin0CallBackPointer(0)
+  fBin0CallBackPointer(0),
+  fIsPP(kFALSE),
+  fPSOADB(0),
+  fFillOADB(0),
+  fTriggerOADB(0),
+  fRegexp(0),
+  fCashedTokens(0)
+  
 {
   // constructor
   
@@ -145,6 +168,10 @@ AliPhysicsSelection::AliPhysicsSelection() :
   fHistStatistics[0] = 0;
   fHistStatistics[1] = 0;
   
+  fRegexp = new TPRegexp("([[:alpha:]]\\w*)");
+  fCashedTokens = new TList;
+  fCashedTokens->SetOwner();
+  
   AliLog::SetClassDebugLevel("AliPhysicsSelection", AliLog::kWarning);
 }
     
@@ -166,7 +193,10 @@ AliPhysicsSelection::~AliPhysicsSelection()
     delete fHistStatistics[1];
     fHistStatistics[1] = 0;
   }
-  
+  // if (fHistStatisticsTokens) {
+  //   delete fHistStatisticsTokens;
+  //   fHistStatisticsTokens = 0;
+  // }
   if (fHistBunchCrossing)
   {
     delete fHistBunchCrossing;
@@ -178,17 +208,54 @@ AliPhysicsSelection::~AliPhysicsSelection()
     fHistTriggerPattern = 0;
   }
 
+  if (fPSOADB)
+  { 
+    delete fPSOADB;
+    fPSOADB = 0;    
+  }  
+  if (fFillOADB)
+  { 
+    delete fFillOADB;
+    fFillOADB = 0;
+  }  
+  if (fTriggerOADB)
+  { 
+    delete fTriggerOADB;
+    fTriggerOADB = 0;
+  }  
+  
+  if (fRegexp)
+  {
+    delete fRegexp;
+    fRegexp = 0;
+  }
+    
+  if (fCashedTokens)
+  {
+    delete fCashedTokens;
+    fCashedTokens = 0;
+  }
+
+
 }
 
-Bool_t AliPhysicsSelection::CheckTriggerClass(const AliESDEvent* aEsd, const char* trigger) const
+UInt_t AliPhysicsSelection::CheckTriggerClass(const AliESDEvent* aEsd, const char* trigger, Int_t& triggerLogic) const
 {
   // checks if the given trigger class(es) are found for the current event
-  // format of trigger: +TRIGGER1 -TRIGGER2
-  //   requires TRIGGER1 and rejects TRIGGER2
+  // format of trigger: +TRIGGER1,TRIGGER1b,TRIGGER1c -TRIGGER2 [#XXX] [&YY] [*ZZ]
+  //   requires one out of TRIGGER1,TRIGGER1b,TRIGGER1c and rejects TRIGGER2
+  //   in bunch crossing XXX
+  //   if successful, YY is returned (for association between entry in fCollTrigClasses and AliVEvent::EOfflineTriggerTypes)
+  //   triggerLogic is filled with ZZ, defaults to kCINT1
   
   Bool_t foundBCRequirement = kFALSE;
   Bool_t foundCorrectBC = kFALSE;
   
+  UInt_t returnCode = AliVEvent::kUserDefined;
+  triggerLogic = kCINT1;
+  
+  AliDebug(AliLog::kDebug+1, Form("Processing event with triggers %s", aEsd->GetFiredTriggerClasses().Data()));
+  
   TString str(trigger);
   TObjArray* tokens = str.Tokenize(" ");
   
@@ -202,15 +269,29 @@ Bool_t AliPhysicsSelection::CheckTriggerClass(const AliESDEvent* aEsd, const cha
       
       str2.Remove(0, 1);
       
-      if (flag && !aEsd->IsTriggerClassFired(str2))
+      TObjArray* tokens2 = str2.Tokenize(",");
+      
+      Bool_t foundTriggerClass = kFALSE;
+      for (Int_t j=0; j < tokens2->GetEntries(); j++)
       {
-        AliDebug(AliLog::kDebug, Form("Rejecting event because trigger class %s is not present", str2.Data()));
-        delete tokens;
-        return kFALSE;
+        TString str3(((TObjString*) tokens2->At(j))->String());
+        
+        if (flag && aEsd->IsTriggerClassFired(str3))
+          foundTriggerClass = kTRUE;
+        if (!flag && aEsd->IsTriggerClassFired(str3))
+        {
+          AliDebug(AliLog::kDebug+1, Form("Rejecting event because trigger class %s is present", str3.Data()));
+          delete tokens2;
+          delete tokens;
+          return kFALSE;
+        }
       }
-      if (!flag && aEsd->IsTriggerClassFired(str2))
+      
+      delete tokens2;
+      
+      if (flag && !foundTriggerClass)
       {
-        AliDebug(AliLog::kDebug, Form("Rejecting event because trigger class %s is present", str2.Data()));
+        AliDebug(AliLog::kDebug+1, Form("Rejecting event because (none of the) trigger class(es) %s is present", str2.Data()));
         delete tokens;
         return kFALSE;
       }
@@ -222,14 +303,26 @@ Bool_t AliPhysicsSelection::CheckTriggerClass(const AliESDEvent* aEsd, const cha
       str2.Remove(0, 1);
       
       Int_t bcNumber = str2.Atoi();
-      AliDebug(AliLog::kDebug, Form("Checking for bunch crossing number %d", bcNumber));
+      AliDebug(AliLog::kDebug+1, Form("Checking for bunch crossing number %d", bcNumber));
       
       if (aEsd->GetBunchCrossNumber() == bcNumber)
       {
         foundCorrectBC = kTRUE;
-        AliDebug(AliLog::kDebug, Form("Found correct bunch crossing %d", bcNumber));
+        AliDebug(AliLog::kDebug+1, Form("Found correct bunch crossing %d", bcNumber));
       }
     }
+    else if (str2[0] == '&')
+    {
+      str2.Remove(0, 1);
+      
+      returnCode = str2.Atoll();
+    }
+    else if (str2[0] == '*')
+    {
+      str2.Remove(0, 1);
+      
+      triggerLogic = str2.Atoi();
+    }
     else
       AliFatal(Form("Invalid trigger syntax: %s", trigger));
   }
@@ -239,17 +332,100 @@ Bool_t AliPhysicsSelection::CheckTriggerClass(const AliESDEvent* aEsd, const cha
   if (foundBCRequirement && !foundCorrectBC)
     return kFALSE;
   
-  return kTRUE;
+  return returnCode;
 }
+
+//______________________________________________________________________________
+TObject *AliPhysicsSelection::GetStatistics(const Option_t *option) const
+{
+// Get the statistics histograms ("ALL" and "BIN0" and "TOK")
+   TString opt(option);
+   opt.ToUpper();
+   Int_t ihist = 0;
+   if (opt == "ALL") ihist = kStatIdxAll;
+   if (opt == "BIN0") ihist = kStatIdxBin0;
+   //   if (opt == "TOK") return fHistStatisticsTokens;
+   return fHistStatistics[ihist];
+}   
+
+//______________________________________________________________________________
+Bool_t AliPhysicsSelection::EvaluateTriggerLogic(const AliESDEvent* aEsd, AliTriggerAnalysis* triggerAnalysis, const char* triggerLogic, Bool_t offline)
+{
+  // evaluates trigger logic. If called with no ESD pointer/triggerAnalysis pointer, it just caches the tokens
+  // Fills the statistics histogram, if booked at row i
+  TString trigger(triggerLogic);
+  
+  // add space after each token (to use ReplaceAll later)
+  fRegexp->Substitute(trigger, "$1 ", "g");
+  
+  while (1)
+  {
+    AliDebug(AliLog::kDebug, trigger.Data());
     
-Bool_t AliPhysicsSelection::IsCollisionCandidate(const AliESDEvent* aEsd)
+    TArrayI pos;
+    Int_t nMatches = fRegexp->Match(trigger, "", 0, 2, &pos);
+
+    if (nMatches <= 0)
+      break;
+      
+    TString token(trigger(pos[0], pos[1]-pos[0]+1));
+    
+    TParameter<Int_t>* param = (TParameter<Int_t>*) fCashedTokens->FindObject(token);
+    if (!param)
+    {
+      TInterpreter::EErrorCode error;
+      Int_t bit = gInterpreter->ProcessLine(Form("AliTriggerAnalysis::k%s;", token.Data()), &error);
+      
+      if (error > 0)
+        AliFatal(Form("Trigger token %s unknown", token.Data()));
+      
+      param = new TParameter<Int_t>(token, bit);
+      fCashedTokens->Add(param);
+      AliDebug(AliLog::kDebug, "Added token");
+    }
+    
+    Long64_t bit = param->GetVal();
+    
+    AliDebug(AliLog::kDebug, Form("Tok %d %d %s %lld", pos[0], pos[1], token.Data(), bit));
+    
+    if (offline) 
+      bit |= AliTriggerAnalysis::kOfflineFlag;
+    
+    if(aEsd && triggerAnalysis) {
+      trigger.ReplaceAll(token, Form("%d", triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) bit)));
+      //      if(fHistStatisticsTokens)              
+    }
+  }
+
+  TFormula formula("formula", trigger);
+  if (formula.Compile() > 0)
+    AliFatal(Form("Could not evaluate trigger logic %s (evaluated to %s)", triggerLogic, trigger.Data()));
+  Bool_t result = formula.Eval(0);
+  
+  AliDebug(AliLog::kDebug, Form("%s --> %d", trigger.Data(), result));
+  
+  return result;
+}
+
+//______________________________________________________________________________
+UInt_t AliPhysicsSelection::IsCollisionCandidate(const AliESDEvent* aEsd)
 {
   // checks if the given event is a collision candidate
-  
-  if (fCurrentRun != aEsd->GetRunNumber())
-    if (!Initialize(aEsd->GetRunNumber()))
+  //
+  // returns a bit word describing the fired offline triggers (see AliVEvent::EOfflineTriggerTypes)
+  AliAnalysisManager *mgr = AliAnalysisManager::GetAnalysisManager();
+  if (!mgr) {
+    AliError("Cannot get the analysis manager");
+    return 0;
+  } 
+  mgr->LoadBranch("AliESDHeader.");
+  mgr->LoadBranch("AliESDRun.");
+
+  if (fCurrentRun != aEsd->GetRunNumber()) {
+    if (!Initialize(aEsd))
       AliFatal(Form("Could not initialize for run %d", aEsd->GetRunNumber()));
-    
+    if(fComputeBG) SetBIFactors(aEsd); // is this safe here?
+  }
   const AliESDHeader* esdHeader = aEsd->GetHeader();
   if (!esdHeader)
   {
@@ -269,7 +445,17 @@ Bool_t AliPhysicsSelection::IsCollisionCandidate(const AliESDEvent* aEsd)
       AliFatal(Form("Invalid event type for MC: %d", esdHeader->GetEventType()));
   }
   
-  Bool_t accept = kFALSE;
+  mgr->LoadBranch("AliMultiplicity.");
+//mgr->LoadBranch("AliESDFMD.");
+  mgr->LoadBranch("AliESDVZERO.");
+  mgr->LoadBranch("AliESDZDC.");
+  mgr->LoadBranch("SPDVertex.");
+  mgr->LoadBranch("PrimaryVertex.");
+  mgr->LoadBranch("TPCVertex.");
+  mgr->LoadBranch("Tracks");
+  mgr->LoadBranch("SPDPileupVertices");
+
+  UInt_t accept = 0;
     
   Int_t count = fCollTrigClasses.GetEntries() + fBGTrigClasses.GetEntries();
   for (Int_t i=0; i < count; i++)
@@ -280,69 +466,99 @@ Bool_t AliPhysicsSelection::IsCollisionCandidate(const AliESDEvent* aEsd)
     else
       triggerClass = ((TObjString*) fBGTrigClasses.At(i - fCollTrigClasses.GetEntries()))->String();
   
-    AliDebug(AliLog::kDebug, Form("Processing trigger class %s", triggerClass));
+    AliDebug(AliLog::kDebug+1, Form("Processing trigger class %s", triggerClass));
   
     AliTriggerAnalysis* triggerAnalysis = static_cast<AliTriggerAnalysis*> (fTriggerAnalysis.At(i));
   
     triggerAnalysis->FillTriggerClasses(aEsd);
     
-    if (CheckTriggerClass(aEsd, triggerClass))
+    Int_t triggerLogic = 0; 
+    UInt_t singleTriggerResult = CheckTriggerClass(aEsd, triggerClass, triggerLogic);
+    
+    if (singleTriggerResult)
     {
       triggerAnalysis->FillHistograms(aEsd);
   
       Bool_t isBin0 = kFALSE;
       if (fBin0CallBack != "") {
-       AliAnalysisManager *mgr = AliAnalysisManager::GetAnalysisManager();
-       if (!mgr) {
-         AliError("Cannot get the analysis manager");
-       }  
-       else {
          isBin0 = ((AliAnalysisTaskSE*)mgr->GetTask(fBin0CallBack.Data()))->IsEventInBinZero();
-       }
       } else if (fBin0CallBackPointer) {
          isBin0 = (*fBin0CallBackPointer)(aEsd);
-       
       }
       
-
+      // ---->
+      // FIXME: this stuff is still used to fill the stat
+      // tables. Decide wethere we are switching to a new stat table
+      // (with all AliTriggerAnalysis tokens? Only we the tokens
+      // actually used in the selection?) and clean up
+
+      // hardware trigger
+      Int_t fastORHW   = triggerAnalysis->EvaluateTrigger(aEsd, AliTriggerAnalysis::kSPDGFO); // SPD number of chips from trigger bits (!)
+      //      Int_t fastORHWL1 = triggerAnalysis->EvaluateTrigger(aEsd, AliTriggerAnalysis::kSPDGFOL1); // SPD number of chips from trigger bits in second layer (!)
+      Bool_t v0AHW     = fSkipV0 ? 0 : triggerAnalysis->EvaluateTrigger(aEsd, AliTriggerAnalysis::kV0A);// should replay hw trigger
+      Bool_t v0CHW     = fSkipV0 ? 0 : triggerAnalysis->EvaluateTrigger(aEsd, AliTriggerAnalysis::kV0C);// should replay hw trigger
       
-      // hardware trigger (should only remove events for MC)
-      // replay CINT1B hardware trigger
-      // TODO this has to depend on the actual hardware trigger (and that depends on the run...)
-      Int_t fastORHW = triggerAnalysis->SPDFiredChips(aEsd, 1); // SPD number of chips from trigger bits (!)
-      Bool_t v0A       = fSkipV0 ? 0 :triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kV0A);
-      Bool_t v0C       = fSkipV0 ? 0 :triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kV0C);
-      Bool_t v0AHW     = fSkipV0 ? 0 :(triggerAnalysis->V0Trigger(aEsd, AliTriggerAnalysis::kASide, kTRUE) == AliTriggerAnalysis::kV0BB);// should replay hw trigger
-      Bool_t v0CHW     = fSkipV0 ? 0 :(triggerAnalysis->V0Trigger(aEsd, AliTriggerAnalysis::kCSide, kTRUE) == AliTriggerAnalysis::kV0BB);// should replay hw trigger
       // offline trigger
-      Int_t fastOROffline = triggerAnalysis->SPDFiredChips(aEsd, 0); // SPD number of chips from clusters (!)
-      Bool_t v0ABG = fSkipV0 ? 0 :triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kV0ABG);
-      Bool_t v0CBG = fSkipV0 ? 0 :triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kV0CBG);
+      Int_t fastOROffline   = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kSPDGFO)); // SPD number of chips from clusters (!)
+      Int_t fastOROfflineL1 = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kSPDGFOL1)); // SPD number of chips from clusters in second layer (!)
+      Bool_t v0A       = fSkipV0 ? 0 : triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kV0A));
+      Bool_t v0C       = fSkipV0 ? 0 : triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kV0C));
+      Bool_t v0ABG = fSkipV0 ? 0 : triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kV0ABG));
+      Bool_t v0CBG = fSkipV0 ? 0 : triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kV0CBG));
       Bool_t v0BG = v0ABG || v0CBG;
+      Bool_t t0       = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kT0    ));
+      Bool_t t0BG     = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kT0BG    ));
+      Bool_t t0PileUp = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kT0Pileup));
 
       // fmd
-      Bool_t fmdA =  triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kFMDA);
-      Bool_t fmdC =  triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kFMDC);
-      Bool_t fmd  = fmdA || fmdC;
+      // Bool_t fmdA = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kFMDA));
+      // Bool_t fmdC = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kFMDC));
+      // Bool_t fmd  = fmdA || fmdC;
     
       // SSD
-      Int_t ssdClusters = triggerAnalysis->SSDClusters(aEsd);
+      //Int_t ssdClusters = triggerAnalysis->SSDClusters(aEsd);
+      
+      // ZDC
+      // Bool_t zdcA = triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kZDCA);
+      // Bool_t zdcC = triggerAnalysis->IsOfflineTriggerFired(aEsd, AliTriggerAnalysis::kZDCC);
+      Bool_t zdcA    = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kZDCTDCA));
+      Bool_t zdcC    = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kZDCTDCC));
+      Bool_t zdcTime = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kZDCTime));
+
+      Bool_t laserCut = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kTPCLaserWarmUp));
 
       // Some "macros"
       Bool_t mb1 = (fastOROffline > 0 || v0A || v0C) && (!v0BG);
       Bool_t mb1prime = (fastOROffline > 1 || (fastOROffline > 0 && (v0A || v0C)) || (v0A && v0C) ) && (!v0BG);
 
       // Background rejection
-      Bool_t bgID = ! fBackgroundIdentification->IsSelected(const_cast<AliESDEvent*> (aEsd));
-
-      Int_t ntrig = fastOROffline; // any 2 hits
+      Bool_t bgID = kFALSE;
+      bgID = triggerAnalysis->EvaluateTrigger(aEsd,  (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kSPDClsVsTrkBG | AliTriggerAnalysis::kOfflineFlag)); // FIXME: temporarily, we keep both ways to validate the new one. if the external BG id is not set, it will use the new one
+      
+      /*Int_t ntrig = fastOROffline; // any 2 hits
       if(v0A)              ntrig += 1;
       if(v0C)              ntrig += 1; //v0C alone is enough
       if(fmd)              ntrig += 1;
-      if(ssdClusters>1)    ntrig += 1;
+      if(ssdClusters>1)    ntrig += 1;*/
 
+      // // EMCAL offline trigger validation
+      // Bool_t emcCut = triggerAnalysis->EvaluateTrigger(aEsd, (AliTriggerAnalysis::Trigger) (AliTriggerAnalysis::kOfflineFlag | AliTriggerAnalysis::kEMCAL));
+      
+      // <---
+
+      TString triggerLogicOnline  = fPSOADB->GetHardwareTrigger(triggerLogic);
+      TString triggerLogicOffline = fPSOADB->GetOfflineTrigger(triggerLogic);
 
-      Bool_t hwTrig = fastORHW > 0 || v0AHW || v0CHW;
+      AliDebug(AliLog::kDebug, Form("Triggers from OADB [0x%x][%d][%s][%s]",singleTriggerResult,AliOADBPhysicsSelection::GetActiveBit(singleTriggerResult),triggerLogicOffline.Data(),triggerLogicOnline.Data()));
+
+      // replay hardware trigger (should only remove events for MC)
+      Bool_t onlineTrigger  = EvaluateTriggerLogic(aEsd, triggerAnalysis, triggerLogicOnline, kFALSE);
+      // offline selection
+      Bool_t offlineTrigger = EvaluateTriggerLogic(aEsd, triggerAnalysis, triggerLogicOffline, kTRUE);
+      
+      // Printf("%s %s", triggerLogicOnline.Data(), triggerLogicOffline.Data());
+      // Printf("%d %d", onlineTrigger, offlineTrigger);
+          
 
       // Fill trigger pattern histo
       Int_t tpatt = 0;
@@ -357,11 +573,10 @@ Bool_t AliPhysicsSelection::IsCollisionCandidate(const AliESDEvent* aEsd)
        if (iHistStat == kStatIdxBin0 && !isBin0) continue; // skip the filling of bin0 stats if the event is not in the bin0
       
        fHistStatistics[iHistStat]->Fill(kStatTriggerClass, i);
-
-
+       if(iHistStat == kStatIdxAll) fHistBunchCrossing->Fill(aEsd->GetBunchCrossNumber(), i); // Fill only for all (avoid double counting)
 
        // We fill the rest only if hw trigger is ok
-       if (!hwTrig)
+       if (!onlineTrigger)
          {
            AliDebug(AliLog::kDebug, "Rejecting event because hardware trigger is not fired");
            continue;
@@ -376,345 +591,424 @@ Bool_t AliPhysicsSelection::IsCollisionCandidate(const AliESDEvent* aEsd)
        if (v0CBG)
          fHistStatistics[iHistStat]->Fill(kStatV0CBG, i);
 
-       // We fill the rest only if mb1 && ! v0BG
+       // T0 stats
+       if(t0)
+         fHistStatistics[iHistStat]->Fill(kStatT0BB,     i);
+       if(t0BG)
+         fHistStatistics[iHistStat]->Fill(kStatT0BG,     i);
+       if(t0PileUp)
+         fHistStatistics[iHistStat]->Fill(kStatT0PileUp, i);
+
+       // mb 1
        if (mb1)
          fHistStatistics[iHistStat]->Fill(kStatMB1, i);
-       else continue;
 
        if (mb1prime)
          fHistStatistics[iHistStat]->Fill(kStatMB1Prime, i);
 
-       if (fmd)
-         fHistStatistics[iHistStat]->Fill(kStatFMD, i);
+       if (laserCut)
+         fHistStatistics[iHistStat]->Fill(kStatLaserCut, i);
 
-       if(ssdClusters>1)
-         fHistStatistics[iHistStat]->Fill(kStatSSD1, i);
-
-       if(ntrig >= 2 && !v0BG) 
-         fHistStatistics[iHistStat]->Fill(kStatAny2Hits, i);
+       //if(ntrig >= 2 && !v0BG) 
+       //  fHistStatistics[iHistStat]->Fill(kStatAny2Hits, i);
 
        if (fastOROffline > 0)
          fHistStatistics[iHistStat]->Fill(kStatFO1, i);
        if (fastOROffline > 1)
          fHistStatistics[iHistStat]->Fill(kStatFO2, i);
+       if (fastOROfflineL1 > 1)
+         fHistStatistics[iHistStat]->Fill(kStatFO2L1, i);
         
        if (v0A)
          fHistStatistics[iHistStat]->Fill(kStatV0A, i);
        if (v0C)
          fHistStatistics[iHistStat]->Fill(kStatV0C, i);
-        
-       //       if (fastOROffline > 1 && !v0BG)
-       //         fHistStatistics[iHistStat]->Fill(kStatFO2NoBG, i);
-            
-       if (fastOROffline > 0 && (v0A || v0C) && !v0BG)
-         fHistStatistics[iHistStat]->Fill(kStatFO1AndV0, i);
+         
+       if (zdcA)
+         fHistStatistics[iHistStat]->Fill(kStatZDCA, i);
+       if (zdcC)
+         fHistStatistics[iHistStat]->Fill(kStatZDCC, i);
+       if (zdcA && zdcC)
+         fHistStatistics[iHistStat]->Fill(kStatZDCAC, i);
+
+       if (zdcTime)
+         fHistStatistics[iHistStat]->Fill(kStatZDCTime, i);
   
-       if (v0A && v0C && !v0BG && !bgID)
+       if (v0A && v0C && !v0BG && (!bgID && fIsPP))
          fHistStatistics[iHistStat]->Fill(kStatV0, i);
 
+       if (bgID && !v0BG) 
+         fHistStatistics[iHistStat]->Fill(kStatBG, i);
 
-       if ( mb1 )
-       
+       // FIXME: check lines below
+       if ( offlineTrigger )
          {
            if (!v0BG || fSkipV0)
              {
                if (!v0BG) fHistStatistics[iHistStat]->Fill(kStatOffline, i);
-      
-               if (fBackgroundIdentification && bgID)
-                 {
-                   AliDebug(AliLog::kDebug, "Rejecting event because of background identification");
-                   fHistStatistics[iHistStat]->Fill(kStatBG, i);
-                 }
-               else
-                 {
-                   AliDebug(AliLog::kDebug, "Accepted event for histograms");
+               AliDebug(AliLog::kDebug, Form("Accepted event for histograms with trigger logic %d", triggerLogic));
             
-                   fHistStatistics[iHistStat]->Fill(kStatAccepted, i);
-                   if(iHistStat == kStatIdxAll) fHistBunchCrossing->Fill(aEsd->GetBunchCrossNumber(), i); // Fill only for all (avoid double counting)
-                   if((i < fCollTrigClasses.GetEntries() || fSkipTriggerClassSelection) && (iHistStat==kStatIdxAll))
-                     accept = kTRUE; // only set for "all" (should not really matter)
-                 }
+               fHistStatistics[iHistStat]->Fill(kStatAccepted, i);
+               
+               if (aEsd->IsPileupFromSPD())
+                 fHistStatistics[iHistStat]->Fill(kStatAcceptedPileUp, i);
+               
+                   // if(iHistStat == kStatIdxAll) fHistBunchCrossing->Fill(aEsd->GetBunchCrossNumber(), i); // Fill only for all (avoid double counting)
+               if((i < fCollTrigClasses.GetEntries() || fSkipTriggerClassSelection) && (iHistStat==kStatIdxAll))
+                 accept |= singleTriggerResult; // only set for "all" (should not really matter)
              }
            else
              AliDebug(AliLog::kDebug, "Rejecting event because of V0 BG flag");
          }
        else
-         AliDebug(AliLog::kDebug, "Rejecting event because trigger condition is not fulfilled");
+         AliDebug(AliLog::kDebug, Form("Rejecting event because trigger logic %d is not fulfilled", triggerLogic));
       }
     }
   }
  
   if (accept)
-    AliDebug(AliLog::kDebug, "Accepted event as collision candidate");
+    AliDebug(AliLog::kDebug, Form("Accepted event as collision candidate with bit mask %d", accept));
   
   return accept;
 }
 
-Int_t AliPhysicsSelection::GetTriggerScheme(UInt_t runNumber) const
-{
-  // returns the current trigger scheme (classes that are accepted/rejected)
-  
-  if (fMC)
-    return 0;
+
+// const char * AliPhysicsSelection::GetFillingScheme(UInt_t runNumber)  {
+
+//   if(fMC) return "MC";
+
+//   if      (runNumber >= 104065 && runNumber <= 104160) {
+//     return "4x4a";
+//   } 
+//   else if (runNumber >= 104315 && runNumber <= 104321) {
+//     return "4x4a*";
+//   }
+//   else if (runNumber >= 104792 && runNumber <= 104803) {
+//     return "4x4b";
+//   }
+//   else if (runNumber >= 104824 && runNumber <= 104892) {
+//     return "4x4c";
+//   }
+//   else if (runNumber == 105143 || runNumber == 105160) {
+//     return "16x16a";
+//   }
+//   else if (runNumber >= 105256 && runNumber <= 105268) {
+//     return "4x4c";
+//   } 
+//   else if (runNumber >= 114786 && runNumber <= 116684) {
+//     return "Single_2b_1_1_1";
+//   }
+//   else if (runNumber >= 117048 && runNumber <= 117120) {
+//     return "Single_3b_2_2_2";
+//   }
+//   else if (runNumber >= 117220 && runNumber <= 119163) {
+//     return "Single_2b_1_1_1";
+//   }
+//   else if (runNumber >= 119837 && runNumber <= 119862) {
+//     return "Single_4b_2_2_2";
+//   }
+//   else if (runNumber >= 119902 && runNumber <= 120691) {
+//     return "Single_6b_3_3_3";
+//   }
+//   else if (runNumber >= 120741 && runNumber <= 122375) {
+//     return "Single_13b_8_8_8";
+//   }
+//   else if (runNumber >= 130148 && runNumber <= 130375) {
+//     return "125n_48b_36_16_36";
+//   } 
+//   else if (runNumber >= 130601 && runNumber <= 130640) {
+//     return "1000ns_50b_35_14_35";
+//   }
+//   else {
+//     AliError(Form("Unknown filling scheme (run %d)", runNumber));
+//   }
+
+//   return "Unknown";
+// }
+
+// const char * AliPhysicsSelection::GetBXIDs(UInt_t runNumber, const char * trigger)  {
+
+//   if (!fUseBXNumbers || fMC) return "";
+
+//   if      (runNumber >= 104065 && runNumber <= 104160) {
+//     if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #2128 #3019";
+//     else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #346 #3465";
+//     else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1234 #1680";
+//     else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   } 
+//   else if (runNumber >= 104315 && runNumber <= 104321) {
+//     if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #2000 #2891";
+//     else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #218 #3337";
+//     else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1106 #1552";
+//     else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   }
+//   else if (runNumber >= 104792 && runNumber <= 104803) {
+//     if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #2228 #3119";
+//     else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2554 #446";
+//     else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1334 #769";
+//     else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   }
+//   else if (runNumber >= 104824 && runNumber <= 104892) {
+//     if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #3119 #769";
+//     else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2554 #446";
+//     else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1334 #2228";
+//     else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   }
+//   else if (runNumber == 105143 || runNumber == 105160) {
+//     if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #1337 #1418 #2228 #2309 #3119 #3200 #446 #527";
+//     else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #1580  #1742  #1904  #2066  #2630  #2792  #2954  #3362";
+//     else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "  #845  #1007  #1169   #1577 #3359 #3521 #119  #281 ";
+//     else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   }
+//   else if (runNumber >= 105256 && runNumber <= 105268) {
+//     if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #3019 #669";
+//     else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2454 #346";
+//     else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1234 #2128";
+//     else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   } else if (runNumber >= 114786 && runNumber <= 116684) { // 7 TeV 2010, assume always the same filling scheme
+//     if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #346";
+//     else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2131";
+//     else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #3019";
+//     else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #1238";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   }
+//   else if (runNumber >= 117048 && runNumber <= 117120) {
+//     //    return "Single_3b_2_2_2";
+//    if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346  #1240 ";
+//    else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #2131 ";
+//    else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019 ";
+//    else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1238";
+//    //   else AliError(Form("Unknown trigger: %s", trigger));
+
+//   }
+//   else if ((runNumber >= 117220 && runNumber <= 118555) || (runNumber >= 118784 && runNumber <= 119163)) 
+//   {
+//     //    return "Single_2b_1_1_1";
+//     if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346 ";
+//     else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #2131 ";
+//     else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019 ";
+//     else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1238 ";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));                                                  
+//   }
+//   else if (runNumber >= 118556 && runNumber <= 118783) {
+//     //    return "Single_2b_1_1_1"; 
+//     // same as previous but was misaligned by 1 BX in fill 1069
+//     if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #345 ";
+//     else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #2130 ";
+//     else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3018 ";
+//     else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1238 ";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));                                                  
+//   }
+//   else if (runNumber >= 119837 && runNumber <= 119862) {
+//     //    return "Single_4b_2_2_2";
+//     if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #669  #3019 ";
+//     else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #346  #2454 ";
+//     else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #1234  #2128 ";
+//     else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1681 #3463";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+
+//   }
+//   else if (runNumber >= 119902 && runNumber <= 120691) {
+//     //    return "Single_6b_3_3_3";
+//     if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346  #546  #746 ";
+//     else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #2131  #2331  #2531 ";
+//     else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019  #3219  #3419 ";
+//     else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1296 #1670";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
+//   }
+//   else if (runNumber >= 120741 && runNumber <= 122375) {
+//     //    return "Single_13b_8_8_8";
+//     if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346  #446  #546  #646  #1240  #1340  #1440  #1540 ";
+//     else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #946  #2131  #2231  #2331  #2431 ";
+//     else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019  #3119  #3219  #3319  #3519 ";
+//     else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1835 #2726";
+//     //    else AliError(Form("Unknown trigger: %s", trigger));
     
-  // TODO dependent on run number
-  
-  switch (runNumber)
-  {
-    // CSMBB triggers
-    case 104044:
-    case 105054:
-    case 105057:
-      return 2;
-  }
+//   } 
+//   else if (runNumber >= 130148 && runNumber <= 130375) {
+//     TString triggerString = trigger;
+//     static TString returnString = " ";
+//     returnString = "";
+//     if (triggerString.Contains("B")) returnString += "   #346  #396  #446  #496  #546  #596  #646  #696  #1240  #1290  #1340  #1390  #1440  #1490  #1540  #1590 ";
+//     if (triggerString.Contains("A")) returnString += "   #755  #805  #855  #905  #955  #1005  #1799  #1849  #1899  #2131  #2181  #2231  #2281  #2331  #2381  #2431  #2481  #2531  #2581  #2631  #2846  #3016  #3066  #3116  #3166  #3216  #3266  #3316  #3366  #3425  #3475  #3525 ";
+//     if (triggerString.Contains("C")) returnString += "   #3019  #3069  #3119  #3169  #3219  #3269  #3319  #3369  #14  #64  #114  #746  #796  #846  #908  #958  #1008  #1640  #1690  #1740  #2055  #2125  #2175  #2225  #2275  #2325  #2375  #2425  #2475  #2534  #2584  #2634 ";
+//     // Printf("0x%x",returnString.Data());
+//     // Printf("%s",returnString.Data());
+//     return returnString.Data();
+//   } 
+//   else if (runNumber >= 130601 && runNumber <= 130640) {
+//     TString triggerString = trigger;
+//     static TString returnString = " ";
+//     returnString = "";
+//     if (triggerString.Contains("B")) returnString += "  #346  #386  #426  #466  #506  #546  #586  #1240  #1280  #1320  #1360  #1400  #1440  #1480 ";
+//     if (triggerString.Contains("A")) returnString += "  #626  #666  #706  #746  #786  #826  #866  #1520  #1560  #1600  #1640  #1680  #1720  #1760  #2076  #2131  #2171  #2211  #2251  #2291  #2331  #2371  #2414  #2454  #2494  #2534  #2574  #2614  #2654  #2694  #2734  #2774  #2814 "; //#2854  #2894  #2934 not present in this run
+//     if (triggerString.Contains("C")) returnString += "  #3019  #3059  #3099  #3139  #3179  #3219  #3259  #3299  #3339  #3379  #3419  #3459  #3499  #3539  #115  #629  #669  #709  #749  #789  #829  #869  #909  #949  #989  #1029  #1069  #1109  #1149  #1523  #1563  #1603  #1643 "; //#1683  #1723  #1763 not present in this run
+//     return returnString.Data();
+//   }
+
+//   else {
+//     AliWarning(Form("Unknown run %d, using all BXs!",runNumber));
+//   }
+
+//   return "";
+// }
+
+Bool_t AliPhysicsSelection::Initialize(const AliESDEvent* aEsd)
+{
+  // initializes the object for the given ESD
   
-  // default: CINT1 suite
-  return 1;
-}  
+  AliInfo(Form("Initializing for beam type: %s", aEsd->GetESDRun()->GetBeamType()));
+  fIsPP = kTRUE;
+  if (strcmp(aEsd->GetESDRun()->GetBeamType(), "A-A") == 0)
+    fIsPP = kFALSE;
 
-const char * AliPhysicsSelection::GetFillingScheme(UInt_t runNumber)  {
-
-  if(fMC) return "MC";
+  return Initialize(aEsd->GetRunNumber());
+}
 
-  if      (runNumber >= 104065 && runNumber <= 104160) {
-    return "4x4a";
-  } 
-  else if (runNumber >= 104315 && runNumber <= 104321) {
-    return "4x4a*";
-  }
-  else if (runNumber >= 104792 && runNumber <= 104803) {
-    return "4x4b";
-  }
-  else if (runNumber >= 104824 && runNumber <= 104892) {
-    return "4x4c";
-  }
-  else if (runNumber == 105143 || runNumber == 105160) {
-    return "16x16a";
-  }
-  else if (runNumber >= 105256 && runNumber <= 105268) {
-    return "4x4c";
-  } 
-  else if (runNumber >= 114786 && runNumber <= 116684) {
-    return "Single_2b_1_1_1";
-  }
-  else if (runNumber >= 117048 && runNumber <= 117120) {
-    return "Single_3b_2_2_2";
-  }
-  else if (runNumber >= 117220 && runNumber <= 119163) {
-    return "Single_2b_1_1_1";
-  }
-  else if (runNumber >= 119837 && runNumber <= 119862) {
-    return "Single_4b_2_2_2";
-  }
-  else if (runNumber >= 119902 && runNumber <= 120691) {
-    return "Single_6b_3_3_3";
-  }
-  else if (runNumber >= 120741 && runNumber <= 122375) {
-    return "Single_13b_8_8_8";
-  }
-  else {
-    AliError(Form("Unknown filling scheme (run %d)", runNumber));
-  }
+Bool_t AliPhysicsSelection::Initialize(Int_t runNumber)
+{
+  // initializes the object for the given run  
 
-  return "Unknown";
-}
 
-const char * AliPhysicsSelection::GetBXIDs(UInt_t runNumber, const char * trigger)  {
+  Bool_t oldStatus = TH1::AddDirectoryStatus();
+  TH1::AddDirectory(kFALSE);
 
-  if (!fUseBXNumbers || fMC) return "";
+  /// Open OADB file and fetch OADB objects
+  TString oadbfilename = AliPhysicsSelection::GetOADBFileName();
 
-  if      (runNumber >= 104065 && runNumber <= 104160) {
-    if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #2128 #3019";
-    else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #346 #3465";
-    else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1234 #1680";
-    else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
-    else AliError(Form("Unknown trigger: %s", trigger));
-  } 
-  else if (runNumber >= 104315 && runNumber <= 104321) {
-    if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #2000 #2891";
-    else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #218 #3337";
-    else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1106 #1552";
-    else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
-    else AliError(Form("Unknown trigger: %s", trigger));
-  }
-  else if (runNumber >= 104792 && runNumber <= 104803) {
-    if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #2228 #3119";
-    else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2554 #446";
-    else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1334 #769";
-    else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
-    else AliError(Form("Unknown trigger: %s", trigger));
-  }
-  else if (runNumber >= 104824 && runNumber <= 104892) {
-    if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #3119 #769";
-    else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2554 #446";
-    else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1334 #2228";
-    else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
-    else AliError(Form("Unknown trigger: %s", trigger));
-  }
-  else if (runNumber == 105143 || runNumber == 105160) {
-    if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #1337 #1418 #2228 #2309 #3119 #3200 #446 #527";
-    else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #1580  #1742  #1904  #2066  #2630  #2792  #2954  #3362";
-    else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "  #845  #1007  #1169   #1577 #3359 #3521 #119  #281 ";
-    else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
-    else AliError(Form("Unknown trigger: %s", trigger));
-  }
-  else if (runNumber >= 105256 && runNumber <= 105268) {
-    if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #3019 #669";
-    else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2454 #346";
-    else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #1234 #2128";
-    else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #790";
-    else AliError(Form("Unknown trigger: %s", trigger));
-  } else if (runNumber >= 114786 && runNumber <= 116684) { // 7 TeV 2010, assume always the same filling scheme
-    if     (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return " #346";
-    else if(!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return " #2131";
-    else if(!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return " #3019";
-    else if(!strcmp("CINT1-E-NOPF-ALL",trigger))     return " #1238";
-    else AliError(Form("Unknown trigger: %s", trigger));
-  }
-  else if (runNumber >= 117048 && runNumber <= 117120) {
-    //    return "Single_3b_2_2_2";
-   if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346  #1240 ";
-   else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #2131 ";
-   else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019 ";
-   else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1238";
-   else AliError(Form("Unknown trigger: %s", trigger));
+  TFile * foadb = TFile::Open(oadbfilename);
+  if(!foadb->IsOpen()) AliFatal(Form("Cannot open OADB file %s", oadbfilename.Data()));
 
-  }
-  else if (runNumber >= 117220 && runNumber <= 119163) {
-    //    return "Single_2b_1_1_1";
-    if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346 ";
-    else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #2131 ";
-    else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019 ";
-    else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1238 ";
-    else AliError(Form("Unknown trigger: %s", trigger));                                                   
-  }
-  else if (runNumber >= 119837 && runNumber <= 119862) {
-    //    return "Single_4b_2_2_2";
-    if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #669  #3019 ";
-    else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #346  #2454 ";
-    else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #1234  #2128 ";
-    else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1681 #3463";
-    else AliError(Form("Unknown trigger: %s", trigger));
 
+  if(!fPSOADB || !fUsingCustomClasses) { // if it's already set and custom class is required, we use the one provided by the user
+    AliInfo("Using Standard OADB");
+    AliOADBContainer * psContainer = (AliOADBContainer*) foadb->Get("physSel");
+    if (!psContainer) AliFatal("Cannot fetch OADB container for Physics selection");
+    fPSOADB = (AliOADBPhysicsSelection*) psContainer->GetObject(runNumber, fIsPP ? "oadbDefaultPP" : "oadbDefaultPbPb");
+    if (!fPSOADB) AliFatal(Form("Cannot find physics selection object for run %d", runNumber));
+  } else {
+    AliInfo("Using Custom OADB");
   }
-  else if (runNumber >= 119902 && runNumber <= 120691) {
-    //    return "Single_6b_3_3_3";
-    if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346  #546  #746 ";
-    else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #2131  #2331  #2531 ";
-    else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019  #3219  #3419 ";
-    else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1296 #1670";
-    else AliError(Form("Unknown trigger: %s", trigger));
+  if(!fFillOADB || !fUsingCustomClasses) { // if it's already set and custom class is required, we use the one provided by the user
+    AliOADBContainer * fillContainer = (AliOADBContainer*) foadb->Get("fillScheme");
+    if (!fillContainer) AliFatal("Cannot fetch OADB container for filling scheme");
+    fFillOADB = (AliOADBFillingScheme*) fillContainer->GetObject(runNumber, "Default");
+    if (!fFillOADB) AliFatal(Form("Cannot find  filling scheme object for run %d", runNumber));
   }
-  else if (runNumber >= 120741 && runNumber <= 122375) {
-    //    return "Single_13b_8_8_8";
-    if      (!strcmp("CINT1B-ABCE-NOPF-ALL",trigger)) return "   #346  #446  #546  #646  #1240  #1340  #1440  #1540 ";
-    else if (!strcmp("CINT1A-ABCE-NOPF-ALL",trigger)) return "   #946  #2131  #2231  #2331  #2431 ";
-    else if (!strcmp("CINT1C-ABCE-NOPF-ALL",trigger)) return "   #3019  #3119  #3219  #3319  #3519 ";
-    else if (!strcmp("CINT1-E-NOPF-ALL",trigger)) return " #1835 #2726";
-    else AliError(Form("Unknown trigger: %s", trigger));
-    
+  if(!fTriggerOADB || !fUsingCustomClasses) { // if it's already set and custom class is required, we use the one provided by the user
+    AliOADBContainer * triggerContainer = (AliOADBContainer*) foadb->Get("trigAnalysis");
+    if (!triggerContainer) AliFatal("Cannot fetch OADB container for trigger analysis");
+    fTriggerOADB = (AliOADBTriggerAnalysis*) triggerContainer->GetObject(runNumber, "Default");
+    fTriggerOADB->Print();
+    if (!fTriggerOADB) AliFatal(Form("Cannot find  trigger analysis object for run %d", runNumber));
   }
 
-  else {
-    AliError(Form("Unknown run %d, using all BXs!",runNumber));
-  }
-
-  return "";
-}
-    
-Bool_t AliPhysicsSelection::Initialize(Int_t runNumber)
-{
-  // initializes the object for the given run
-  // TODO having the run number here and parameters hardcoded is clearly temporary, a way needs to be found to have a CDB-like configuration also for analysis
-  
-  Bool_t oldStatus = TH1::AddDirectoryStatus();
-  TH1::AddDirectory(kFALSE);
   
   if(!fBin0CallBack) 
     AliError("Bin0 Callback not set: will not fill the statistics for the bin 0");
 
   if (fMC) {
-    // ovverride BX and bg options in case of MC
+    // override BX and bg options in case of MC
     fComputeBG    = kFALSE;
     fUseBXNumbers = kFALSE;
   }
 
-  Int_t triggerScheme = GetTriggerScheme(runNumber);
-  if (!fUsingCustomClasses && fCurrentRun != -1 && triggerScheme != GetTriggerScheme(fCurrentRun))
-    AliFatal("Processing several runs with different trigger schemes is not supported");
+  // FIXME: think how to implement this check with the OADB, trigger scheme is not a int number here 
+  // Int_t triggerScheme = GetTriggerScheme(runNumber);
+  // if (!fUsingCustomClasses && fCurrentRun != -1 && triggerScheme != GetTriggerScheme(fCurrentRun))
+  //   AliFatal("Processing several runs with different trigger schemes is not supported");
   
   if(fComputeBG && fCurrentRun != -1 && fCurrentRun != runNumber) 
     AliFatal("Cannot process several runs because BG computation is requested");
 
   if(fComputeBG && !fUseBXNumbers) 
-    AliFatal("Cannot compute BG id BX numbers are not used");
+    AliFatal("Cannot compute BG if BX numbers are not used");
   
-  if(fUseBXNumbers && fFillingScheme != "" && fFillingScheme != GetFillingScheme(runNumber))
+  if(fUseBXNumbers && fFillingScheme != "" && fFillingScheme != fFillOADB->GetFillingSchemeName())
     AliFatal("Cannot process runs with different filling scheme if usage of BX numbers is requested");
 
-  fFillingScheme      = GetFillingScheme(runNumber);
-
-  if(fComputeBG) SetBIFactors(runNumber);
+  fFillingScheme      = fFillOADB->GetFillingSchemeName();
 
   AliInfo(Form("Initializing for run %d", runNumber));
   
   // initialize first time?
   if (fCurrentRun == -1)
   {
-    if (fUsingCustomClasses) {
-      AliInfo("Using user-provided trigger classes");
-    } else {
-      switch (triggerScheme)
-      {
-      case 0:
-        fCollTrigClasses.Add(new TObjString(""));
-        break;
-        
-      case 1:
-       { // need a new scope to avoid cross-initialization errors
-
-         if (fUseMuonTriggers) {
-           // Muon trigger have the same BXIDs of the corresponding CINT triggers
-           fCollTrigClasses.Add(new TObjString(Form("%s%s ","+CMUS1B-ABCE-NOPF-MUON",  GetBXIDs(runNumber,"CINT1B-ABCE-NOPF-ALL"))));
-           fBGTrigClasses.Add  (new TObjString(Form("%s%s ","+CMUS1A-ABCE-NOPF-MUON",  GetBXIDs(runNumber,"CINT1A-ABCE-NOPF-ALL"))));
-           fBGTrigClasses.Add  (new TObjString(Form("%s%s ","+CMUS1C-ABCE-NOPF-MUON",  GetBXIDs(runNumber,"CINT1C-ABCE-NOPF-ALL"))));      
-           fBGTrigClasses.Add  (new TObjString(Form("%s%s ","+CMUS1-E-NOPF-MUON"    ,  GetBXIDs(runNumber,"CINT1-E-NOPF-ALL"))));
+    const UInt_t ntriggerBits = fPSOADB->GetNTriggerBits(); // FIXME!
+    for(UInt_t ibit = 0; ibit < ntriggerBits; ibit++){
+      
+      TIterator * collIter = fPSOADB->GetCollTrigClass(ibit)->MakeIterator();
+      TIterator * bgIter   = fPSOADB->GetBGTrigClass(ibit)->MakeIterator();
+      TObjString * obj = 0;
+      while((obj = (TObjString*) collIter->Next())){
+       if (obj->String() != "") {
+         fCollTrigClasses.Add(new TObjString(GetTriggerString(obj)));
+       }
+      }
+      // BG classes only make sense for real data
+      if(!fMC) {
+       obj = 0 ;
+       while((obj = (TObjString*) bgIter->Next())){
+         if (obj->String() != "") {
+           fBGTrigClasses.Add(new TObjString(GetTriggerString(obj)));
          }
-         TObjString * cint1b = new TObjString(Form("%s%s","+CINT1B-ABCE-NOPF-ALL",  GetBXIDs(runNumber,"CINT1B-ABCE-NOPF-ALL")));
-         TObjString * cint1a = new TObjString(Form("%s%s","+CINT1A-ABCE-NOPF-ALL",  GetBXIDs(runNumber,"CINT1A-ABCE-NOPF-ALL")));
-         TObjString * cint1c = new TObjString(Form("%s%s","+CINT1C-ABCE-NOPF-ALL",  GetBXIDs(runNumber,"CINT1C-ABCE-NOPF-ALL")));
-         TObjString * cint1e = new TObjString(Form("%s%s","+CINT1-E-NOPF-ALL",      GetBXIDs(runNumber,"CINT1-E-NOPF-ALL"))    );
-         //
-         fCollTrigClasses.Add(cint1b);
-         fBGTrigClasses.Add(cint1a);
-         fBGTrigClasses.Add(cint1c);
-         fBGTrigClasses.Add(cint1e);
-
        }
-        break;
-        
-      case 2:
-        fCollTrigClasses.Add(new TObjString("+CSMBB-ABCE-NOPF-ALL"));
-        fBGTrigClasses.Add(new TObjString("+CSMBA-ABCE-NOPF-ALL -CSMBB-ABCE-NOPF-ALL"));
-        fBGTrigClasses.Add(new TObjString("+CSMBC-ABCE-NOPF-ALL -CSMBB-ABCE-NOPF-ALL"));
-        break;
-        
-      default:
-        AliFatal(Form("Unsupported trigger scheme %d", triggerScheme));
       }
+
     }
+    // not sure how to handle this in the case of > x cuts
+    // // Book the token histo with the tokens actually used here!
+    // // 1. Cache the tokens
+    // for(UInt_t ibit = 0; ibit < ntriggerBits; ibit++){
+    //         EvaluateTriggerLogic(0,0, fPSOADB->GetHardwareTrigger(ibit), 0);
+    //         EvaluateTriggerLogic(0,0, fPSOADB->GetOfflineTrigger(ibit),  1);
+    // }
+    // // 2. Book the histogram
+    // if (!fHistStatisticsTokens) {
+    //         Int_t ntokens = fCashedTokens->GetEntries();
+    //         Int_t count = fCollTrigClasses->GetEntries() + fBGTrigClasses->GetEntries();
+    //         fHistStatisticsTokens = new TH2F("fHistStatisticsTokens", "fHistStatisticsTokens", ntokens + 2, 0.5, ntokens+2+0.5, count, -0.5, -0.5 + count);
+       
+    //         Int_t nrow = 0;
+    //         fHistStatisticsTokens->GetXaxis()->SetBinLabel(nrow++,  "Trigger class");
+    //         for(Int_t itoken = 0; itoken < ntoken; itoken++){
+    //           TParameter<Int_t> * param = fCashedTokens->At(itoken);
+    //           fHistStatisticsTokens->GetXaxis()->SetBinLabel(nrow++,  param->GetName());      
+    //         }
+       
+    //         fHistStatisticsTokens->GetXaxis()->SetBinLabel(nrow++,      "Accepted");
+
+    // }
+
     
+    
+    // TODO: 
+    // Add a new statistics histo containing only the tokens actually used in the selection
+
     Int_t count = fCollTrigClasses.GetEntries() + fBGTrigClasses.GetEntries();
     
     for (Int_t i=0; i<count; i++)
     {
+      
       AliTriggerAnalysis* triggerAnalysis = new AliTriggerAnalysis;
       triggerAnalysis->SetAnalyzeMC(fMC);
       triggerAnalysis->EnableHistograms();
       triggerAnalysis->SetSPDGFOThreshhold(1);
+      triggerAnalysis->SetDoFMD(kFALSE);
+      triggerAnalysis->SetCorrZDCCutParams(fTriggerOADB->GetZDCCutRefSumCorr(),
+                                          fTriggerOADB->GetZDCCutRefDeltaCorr(), 
+                                          fTriggerOADB->GetZDCCutSigmaSumCorr(),
+                                          fTriggerOADB->GetZDCCutSigmaDeltaCorr());
       fTriggerAnalysis.Add(triggerAnalysis);
     }
-      
+
+    
     // TODO: shall I really delete this?
     if (fHistStatistics[0])
       delete fHistStatistics[0];
@@ -724,11 +1018,13 @@ Bool_t AliPhysicsSelection::Initialize(Int_t runNumber)
     fHistStatistics[kStatIdxBin0] = BookHistStatistics("_Bin0");
     fHistStatistics[kStatIdxAll]  = BookHistStatistics("");
     
+
     if (fHistBunchCrossing)
       delete fHistBunchCrossing;
   
     fHistBunchCrossing = new TH2F("fHistBunchCrossing", "fHistBunchCrossing;bunch crossing number;", 4000, -0.5, 3999.5,  count, -0.5, -0.5 + count);
 
+    // TODO: remove fHistTriggerPattern
     if (fHistTriggerPattern)
       delete fHistTriggerPattern;
     
@@ -751,11 +1047,13 @@ Bool_t AliPhysicsSelection::Initialize(Int_t runNumber)
     n = 1;
     for (Int_t i=0; i < fCollTrigClasses.GetEntries(); i++)
     {
+      
       fHistBunchCrossing->GetYaxis()->SetBinLabel(n, ((TObjString*) fCollTrigClasses.At(i))->String());
       n++;
     }
     for (Int_t i=0; i < fBGTrigClasses.GetEntries(); i++)
     {
+      
       fHistBunchCrossing->GetYaxis()->SetBinLabel(n, ((TObjString*) fBGTrigClasses.At(i))->String());
       n++;
     }
@@ -767,6 +1065,7 @@ Bool_t AliPhysicsSelection::Initialize(Int_t runNumber)
   Int_t count = fCollTrigClasses.GetEntries() + fBGTrigClasses.GetEntries();
   for (Int_t i=0; i<count; i++)
   {
+    
     AliTriggerAnalysis* triggerAnalysis = static_cast<AliTriggerAnalysis*> (fTriggerAnalysis.At(i));
   
     switch (runNumber)
@@ -787,20 +1086,21 @@ Bool_t AliPhysicsSelection::Initialize(Int_t runNumber)
   
   TH1::AddDirectory(oldStatus);
   
+  
   return kTRUE;
 }
 
 TH2F * AliPhysicsSelection::BookHistStatistics(const char * tag) {
-
-    // add 6 rows to count for the estimate of good, accidentals and
-    // BG and the ratio of BG and accidentals to total +ratio goot to
-    // first col + 2 for error on good.
+  // add 6 rows to count for the estimate of good, accidentals and
+  // BG and the ratio of BG and accidentals to total +ratio goot to
+  // first col + 2 for error on good.
+  // TODO: Remember the the indexes of rows for the BG selection. Add new member fBGRows[] and use kStat as indexes
 
   Int_t count = fCollTrigClasses.GetEntries() + fBGTrigClasses.GetEntries();
 #ifdef VERBOSE_STAT
-  Int_t extrarows = fComputeBG ? 8 : 0;
+  Int_t extrarows = fComputeBG != 0 ? 11 : 0;
 #else
-  Int_t extrarows = fComputeBG ? 3 : 0;
+  Int_t extrarows = fComputeBG != 0 ? 6 : 0;
 #endif
   TH2F * h = new TH2F(Form("fHistStatistics%s",tag), Form("fHistStatistics - %s ;;",tag), kStatAccepted, 0.5, kStatAccepted+0.5, count+extrarows, -0.5, -0.5 + count+extrarows);
 
@@ -808,21 +1108,30 @@ TH2F * AliPhysicsSelection::BookHistStatistics(const char * tag) {
   h->GetXaxis()->SetBinLabel(kStatHWTrig,       "Hardware trigger");
   h->GetXaxis()->SetBinLabel(kStatFO1,          "FO >= 1");
   h->GetXaxis()->SetBinLabel(kStatFO2,          "FO >= 2");
+  h->GetXaxis()->SetBinLabel(kStatFO2L1,         "FO (L1) >= 2");
   h->GetXaxis()->SetBinLabel(kStatV0A,          "V0A");
   h->GetXaxis()->SetBinLabel(kStatV0C,          "V0C");
-  h->GetXaxis()->SetBinLabel(kStatFMD,          "FMD");
-  h->GetXaxis()->SetBinLabel(kStatSSD1,                 "SSD >= 2");
+  h->GetXaxis()->SetBinLabel(kStatT0BB,                 "T0");
+  h->GetXaxis()->SetBinLabel(kStatT0BG,                 "T0BG");
+  h->GetXaxis()->SetBinLabel(kStatT0PileUp,      "T0 PileUp");
+  h->GetXaxis()->SetBinLabel(kStatLaserCut,      "TPC Laser Wup Cut");
   h->GetXaxis()->SetBinLabel(kStatV0ABG,        "V0A BG");
   h->GetXaxis()->SetBinLabel(kStatV0CBG,        "V0C BG");
+  h->GetXaxis()->SetBinLabel(kStatZDCA,          "ZDCA");
+  h->GetXaxis()->SetBinLabel(kStatZDCC,          "ZDCC");
+  h->GetXaxis()->SetBinLabel(kStatZDCAC,         "ZDCA & ZDCC");
+  h->GetXaxis()->SetBinLabel(kStatZDCTime,       "ZDC Time Cut");
   h->GetXaxis()->SetBinLabel(kStatMB1,          "(FO >= 1 | V0A | V0C) & !V0 BG");
   h->GetXaxis()->SetBinLabel(kStatMB1Prime,      "(FO >= 2 | (FO >= 1 & (V0A | V0C)) | (V0A &v0C) ) & !V0 BG");
-  h->GetXaxis()->SetBinLabel(kStatFO1AndV0,     "FO >= 1 & (V0A | V0C) & !V0 BG");
+  //h->GetXaxis()->SetBinLabel(kStatFO1AndV0,   "FO >= 1 & (V0A | V0C) & !V0 BG");
   h->GetXaxis()->SetBinLabel(kStatV0,           "V0A & V0C & !V0 BG & !BG ID");
   h->GetXaxis()->SetBinLabel(kStatOffline,      "Offline Trigger");
-  h->GetXaxis()->SetBinLabel(kStatAny2Hits,     "2 Hits & !V0 BG");
+  //h->GetXaxis()->SetBinLabel(kStatAny2Hits,   "2 Hits & !V0 BG");
   h->GetXaxis()->SetBinLabel(kStatBG,           "Background identification");
+  h->GetXaxis()->SetBinLabel(kStatAcceptedPileUp, "Pile up (in accepted)");
   h->GetXaxis()->SetBinLabel(kStatAccepted,      "Accepted");
 
+
   Int_t n = 1;
   for (Int_t i=0; i < fCollTrigClasses.GetEntries(); i++)
     {
@@ -836,7 +1145,11 @@ TH2F * AliPhysicsSelection::BookHistStatistics(const char * tag) {
     }
 
   if(fComputeBG) {
-    h->GetYaxis()->SetBinLabel(n++, "BG (A+C)");
+    fBGStatOffset = n;
+    h->GetYaxis()->SetBinLabel(n++, "All B");
+    h->GetYaxis()->SetBinLabel(n++, "All A+C");
+    h->GetYaxis()->SetBinLabel(n++, "All E");
+    h->GetYaxis()->SetBinLabel(n++, Form("BG (A+C) (Mask [0x%x])", fComputeBG));
     h->GetYaxis()->SetBinLabel(n++, "ACC");
 #ifdef VERBOSE_STAT
     h->GetYaxis()->SetBinLabel(n++, "BG (A+C) %  (rel. to CINT1B)");
@@ -851,11 +1164,12 @@ TH2F * AliPhysicsSelection::BookHistStatistics(const char * tag) {
   return h;
 }
 
-void AliPhysicsSelection::Print(Option_t* /* option */) const
+void AliPhysicsSelection::Print(const Option_t *option) const
 {
   // print the configuration
-  
+  TString msg;
   Printf("Configuration initialized for run %d (MC: %d):", fCurrentRun, fMC);
+  msg += Form("Configuration initialized for run %d (MC: %d):\n", fCurrentRun, fMC);
   
   Printf("Collision trigger classes:");
   for (Int_t i=0; i < fCollTrigClasses.GetEntries(); i++)
@@ -875,42 +1189,121 @@ void AliPhysicsSelection::Print(Option_t* /* option */) const
     Printf("\nTotal available events:");
     
     triggerAnalysis->PrintTriggerClasses();
+    // Check if all triggers with counts are known to the physics selection. If not, print a WARNING (only for MC) 
+    if(!fMC) {
+      TMap * triggers = triggerAnalysis->GetTriggerClasses();
+      TIterator* iter = triggers->MakeIterator();
+      TObjString* obj = 0;
+      static TString alreadyFoundTriggers;
+      while ((obj = dynamic_cast<TObjString*> (iter->Next())))
+       {
+         TString strTrigger = obj->GetString();    
+         TParameter<Long64_t>* param = static_cast<TParameter<Long64_t>*> (triggers->GetValue(obj));
+         Long_t counts =  (Long_t)param->GetVal();
+         TObjArray* tokens = obj->String().Tokenize(" ");
+         for (Int_t i=0; i<tokens->GetEntries(); i++)
+           {
+             TString singleTrigStr = ((TObjString*) tokens->At(i))->String();
+             singleTrigStr.Strip(TString::kBoth, ' ' );
+             const char * singleTrig = singleTrigStr.Data();
+             //            Printf("%s", singleTrig);
+             TString singleTrigStrFull;
+             Bool_t found = kFALSE;
+             Int_t nCollTriggers = fCollTrigClasses.GetEntries();
+             for(Int_t iCollTriggers = 0; iCollTriggers < nCollTriggers; iCollTriggers++){
+               singleTrigStrFull = ((TObjString*)fCollTrigClasses.At(iCollTriggers))->String();
+               if(singleTrigStrFull.Contains(singleTrigStr)) {
+                 found = kTRUE;
+                 break;
+               }
+               singleTrigStrFull = singleTrigStr;
+             }
+             Int_t nBGTriggers = fBGTrigClasses.GetEntries();
+             for(Int_t iBGTriggers = 0; iBGTriggers < nBGTriggers; iBGTriggers++){
+               singleTrigStrFull = ((TObjString*)fBGTrigClasses.At(iBGTriggers))->String();
+               if(singleTrigStrFull.Contains(singleTrigStr)) {
+                 found = kTRUE;
+                 break;
+               }
+               singleTrigStrFull = singleTrigStr;
+             }
+             
+             TString blacklist = "CEMC7WU-B-NOPF-ALL, CEMC7WU-AC-NOPF-ALL CEMC7WU-E-NOPF-ALL C0LSR-ABCE-NOPF-TPC CBEAMB-B-NOPF-ALLNOTRD"; // We know we dont support those, so we print no warning           
+             if(counts>0 && !found && !blacklist.Contains(singleTrig) && !singleTrigStr.Contains("WU") && !alreadyFoundTriggers.Contains(singleTrig)) {
+               Printf("WARNING: Found unknown trigger [%s] with %ld counts in the ESD!", singleTrig, counts);
+               alreadyFoundTriggers += singleTrig; // Avoid printing warning twice for the same trigger
+             }       
+           }    
+         delete tokens;        
+       }
+      delete iter;
+    }
   }
   
-  if (fHistStatistics[kStatIdxAll] && fCollTrigClasses.GetEntries() > 0)
+  if (fHistStatistics[kStatIdxAll])
   {
-    Printf("\nSelection statistics for first collision trigger (%s):", ((TObjString*) fCollTrigClasses.First())->String().Data());
-    
-    Printf("Total events with correct trigger class: %d", (Int_t) fHistStatistics[kStatIdxAll]->GetBinContent(1, 1));
-    Printf("Selected collision candidates: %d", (Int_t) fHistStatistics[kStatIdxAll]->GetBinContent(fHistStatistics[kStatIdxAll]->GetXaxis()->FindBin("Accepted"), 1));
+    static TString alreadyFoundTriggers; // avoids printing twice the same warning
+       
+    for (Int_t i=0; i<fCollTrigClasses.GetEntries(); i++)
+    {
+      Printf("\nSelection statistics for collision trigger %s:", ((TObjString*) fCollTrigClasses.At(i))->String().Data());
+      msg += Form("\nSelection statistics for collision trigger %s:\n", ((TObjString*) fCollTrigClasses.At(i))->String().Data());
+      
+      Float_t allEvents       = fHistStatistics[kStatIdxAll]->GetBinContent(1, i+1); 
+      Float_t triggeredEvents = fHistStatistics[kStatIdxAll]->GetBinContent(fHistStatistics[kStatIdxAll]->GetXaxis()->FindBin("Accepted"), i+1); 
+
+      Printf("Total events with correct trigger class: %d", (Int_t) fHistStatistics[kStatIdxAll]->GetBinContent(1, i+1));
+      msg += Form("Total events with correct trigger class: %d\n", (Int_t) fHistStatistics[kStatIdxAll]->GetBinContent(1, i+1));
+      Printf("Selected collision candidates: %d", (Int_t) fHistStatistics[kStatIdxAll]->GetBinContent(fHistStatistics[kStatIdxAll]->GetXaxis()->FindBin("Accepted"), i+1));
+      msg += Form("Selected collision candidates: %d\n", (Int_t) fHistStatistics[kStatIdxAll]->GetBinContent(fHistStatistics[kStatIdxAll]->GetXaxis()->FindBin("Accepted"), i+1));
+      
+      // If the fraction of accepted events is too low, print a warning.
+      Float_t eff = allEvents > 0 ? triggeredEvents/allEvents : 0;
+      if(allEvents > 0 && (eff < 0.5) &&  // FIXME: make threshold programmable in OADB
+        !alreadyFoundTriggers.Contains(((TObjString*) fCollTrigClasses.At(i))->String().Data())) {
+       Printf("WARNING: Trigger class %s has a very low efficiency (%d/%d=%.2f)",((TObjString*) fCollTrigClasses.At(i))->String().Data(), (Int_t) triggeredEvents, (Int_t) allEvents, eff);
+       alreadyFoundTriggers += ((TObjString*) fCollTrigClasses.At(i))->String().Data();
+       Printf("%s", alreadyFoundTriggers.Data());
+      }
+
+    }
   }
   
   if (fHistBunchCrossing)
   {
     Printf("\nBunch crossing statistics:");
+    msg += "\nBunch crossing statistics:\n";
     
     for (Int_t i=1; i<=fHistBunchCrossing->GetNbinsY(); i++)
     {
       TString str;
-      str.Form("Trigger %s has accepted events in the bunch crossings: ", fHistBunchCrossing->GetYaxis()->GetBinLabel(i));
+      str.Form("Trigger %s has events in the bunch crossings: ", fHistBunchCrossing->GetYaxis()->GetBinLabel(i));
       
       for (Int_t j=1; j<=fHistBunchCrossing->GetNbinsX(); j++)
         if (fHistBunchCrossing->GetBinContent(j, i) > 0)
           str += Form("%d, ", (Int_t) fHistBunchCrossing->GetXaxis()->GetBinCenter(j));
-       
+             
       Printf("%s", str.Data());
+      msg += str;
+      msg += "\n";
     }
     
     for (Int_t j=1; j<=fHistBunchCrossing->GetNbinsX(); j++)
     {
-      Int_t count = 0;
+      Int_t countColl = 0;
+      Int_t countBG = 0;
       for (Int_t i=1; i<=fHistBunchCrossing->GetNbinsY(); i++)
       {
         if (fHistBunchCrossing->GetBinContent(j, i) > 0)
-          count++;
+        {
+          if (fCollTrigClasses.FindObject(fHistBunchCrossing->GetYaxis()->GetBinLabel(i)))
+            countColl++;
+          if (fBGTrigClasses.FindObject(fHistBunchCrossing->GetYaxis()->GetBinLabel(i)))
+            countBG++;
+        }
       }
-      if (count > 1)
-        Printf("WARNING: Bunch crossing %d has more than one trigger class active. Check BPTX functioning for this run!", (Int_t) fHistBunchCrossing->GetXaxis()->GetBinCenter(j));
+      if (countColl > 0 && countBG > 0)
+        Printf("WARNING: Bunch crossing %d has collision and BG trigger classes active. Check BPTX functioning for this run!", (Int_t) fHistBunchCrossing->GetXaxis()->GetBinCenter(j));
     }
   }
 
@@ -922,7 +1315,12 @@ void AliPhysicsSelection::Print(Option_t* /* option */) const
     Printf("WARNING: Ignoring V0 information in selection");
   if(!fBin0CallBack) 
     Printf("WARNING: Callback not set: will not fill the statistics for the bin 0");
-
+  TString opt(option);
+  opt.ToUpper();
+  if (opt == "STAT") {
+     AliAnalysisManager *mgr = AliAnalysisManager::GetAnalysisManager();
+     if (mgr) mgr->AddStatisticsMsg(msg);
+  }
 }
 
 Long64_t AliPhysicsSelection::Merge(TCollection* list)
@@ -941,7 +1339,7 @@ Long64_t AliPhysicsSelection::Merge(TCollection* list)
   TObject* obj;
   
   // collections of all histograms
-  const Int_t nHists = 9;
+  const Int_t nHists = 8;
   TList collections[nHists];
 
   Int_t count = 0;
@@ -950,40 +1348,113 @@ Long64_t AliPhysicsSelection::Merge(TCollection* list)
     AliPhysicsSelection* entry = dynamic_cast<AliPhysicsSelection*> (obj);
     if (entry == 0) 
       continue;
-      
-    collections[0].Add(&(entry->fTriggerAnalysis));
+    // Update run number. If this one is not initialized (-1) take the one from 
+    // the next physics selection to be merged with. In case of 2 different run
+    // numbers issue a warning (should physics selections from different runs be 
+    // merged together) A.G.
+    Int_t currentRun = entry->GetCurrentRun();
+    // Nothing to merge with since run number was not initialized.
+    if (currentRun < 0) continue;
+    if (fCurrentRun < 0) 
+    {
+      fCurrentRun = currentRun;
+      fMC = entry->fMC;
+      for (Int_t i=0; i<entry->fCollTrigClasses.GetEntries(); i++)
+        fCollTrigClasses.Add(entry->fCollTrigClasses.At(i)->Clone());
+      for (Int_t i=0; i<entry->fBGTrigClasses.GetEntries(); i++)
+        fBGTrigClasses.Add(entry->fBGTrigClasses.At(i)->Clone());
+    }
+    if (fCurrentRun != currentRun)
+       AliWarning(Form("Current run %d not matching the one to be merged with %d", fCurrentRun, currentRun));
+
+    // With the same strategy update fBGStatOffset
+    Int_t bgstatoffset = entry->GetBGStatOffset();
+    
+    // Nothing to merge with since BG was not initialized.
+    if (!(bgstatoffset < 0)){
+      if (fBGStatOffset < 0) 
+       {
+         fBGStatOffset = bgstatoffset;
+       }
+    }
+    if (fBGStatOffset != bgstatoffset)
+      AliWarning(Form("Current run %d not matching the one to be merged with %d", fBGStatOffset, bgstatoffset));
+    
+
+    
+    // Merge the OADBs (Take just the first instance you find
+    if (!fPSOADB && entry->GetOADBPhysicsSelection()) {
+      fPSOADB = (AliOADBPhysicsSelection*) entry->GetOADBPhysicsSelection()->Clone();
+    }
+    if (!fFillOADB && entry->GetOADBFillingScheme()){
+      fFillOADB = (AliOADBFillingScheme*) entry->GetOADBFillingScheme()->Clone();
+    }
+
+    if (entry->fTriggerAnalysis.GetEntries() > 0)
+      collections[0].Add(&(entry->fTriggerAnalysis));
     if (entry->fHistStatistics[0])
       collections[1].Add(entry->fHistStatistics[0]);
     if (entry->fHistStatistics[1])
       collections[2].Add(entry->fHistStatistics[1]);
+    // if (entry->fHistStatisticsTokens)
+    //   collections[3].Add(entry->fHistStatisticsTokens);
     if (entry->fHistBunchCrossing)
       collections[3].Add(entry->fHistBunchCrossing);
     if (entry->fHistTriggerPattern)
       collections[4].Add(entry->fHistTriggerPattern);
-    if (entry->fBackgroundIdentification)
-      collections[5].Add(entry->fBackgroundIdentification);
 
     count++;
   }
 
+  if (fTriggerAnalysis.GetEntries() == 0 && collections[0].GetEntries() > 0)
+  {
+    TList* firstList = (TList*) collections[0].First();
+    for (Int_t i=0; i<firstList->GetEntries(); i++)
+      fTriggerAnalysis.Add(firstList->At(i)->Clone());
+    
+    collections[0].RemoveAt(0);
+  }
   fTriggerAnalysis.Merge(&collections[0]);
+  
+  // if this instance is empty (not initialized) nothing would be merged here --> copy first entry
+  if (!fHistStatistics[0] && collections[1].GetEntries() > 0)
+  {
+    fHistStatistics[0] = (TH2F*) collections[1].First()->Clone();
+    collections[1].RemoveAt(0);
+  }
   if (fHistStatistics[0])
     fHistStatistics[0]->Merge(&collections[1]);
+    
+  if (!fHistStatistics[1] && collections[2].GetEntries() > 0)
+  {
+    fHistStatistics[1] = (TH2F*) collections[2].First()->Clone();
+    collections[2].RemoveAt(0);
+  }
   if (fHistStatistics[1])
     fHistStatistics[1]->Merge(&collections[2]);
+    
+  if (!fHistBunchCrossing && collections[3].GetEntries() > 0)
+  {
+    fHistBunchCrossing = (TH2F*) collections[3].First()->Clone();
+    collections[3].RemoveAt(0);
+  }
   if (fHistBunchCrossing)
     fHistBunchCrossing->Merge(&collections[3]);
+  
+  if (!fHistTriggerPattern && collections[4].GetEntries() > 0)
+  {
+    fHistTriggerPattern = (TH1F*) collections[4].First()->Clone();
+    collections[4].RemoveAt(0);
+  }
   if (fHistTriggerPattern)
     fHistTriggerPattern->Merge(&collections[4]);
-  if (fBackgroundIdentification)
-    fBackgroundIdentification->Merge(&collections[5]);
-  
+    
   delete iter;
 
   return count+1;
 }
 
-void AliPhysicsSelection::SaveHistograms(const char* folder) const
+void AliPhysicsSelection::SaveHistograms(const char* folder) 
 {
   // write histograms to current directory
   
@@ -998,93 +1469,174 @@ void AliPhysicsSelection::SaveHistograms(const char* folder) const
   
 
   // Fill the last rows of fHistStatistics before saving
-  if (fComputeBG) {
-    Int_t triggerScheme = GetTriggerScheme(UInt_t(fCurrentRun));
-    if(triggerScheme != 1){
-      AliWarning("BG estimate only supported for trigger scheme \"1\" (CINT1 suite)");
-    } else if (fUseMuonTriggers) {
-      AliWarning("BG estimate with muon triggers to be implemented");
-    } else {
-      // 0. Determine the ratios of triggers E/B, A/B, C/B from the stat histogram
-      // Those are used to rescale the different classes to the same number of bx ids
-      Float_t nB = 0;
-      Float_t nC = 0;
-      Float_t nA = 0;
-      Float_t nE = 0;
-      for (Int_t j=1; j<=fHistBunchCrossing->GetNbinsX(); j++) {
-       if (fHistBunchCrossing->GetBinContent(j, 1) > 0) nB++;
-       if (fHistBunchCrossing->GetBinContent(j, 2) > 0) nA++;
-       if (fHistBunchCrossing->GetBinContent(j, 3) > 0) nC++;
-       if (fHistBunchCrossing->GetBinContent(j, 4) > 0) nE++;
+  if (fComputeBG) {      
+    AliInfo("BG estimate assumes that for a given run you only have A and C triggers separately or"
+           " toghether as a AC class! Make sure this assumption holds in your case"); 
+    
+    // use an anum for the different trigger classes, to make loops easier to read
+    enum {kClassB =0 , kClassA, kClassC, kClassAC, kClassE, kNClasses};
+    const char * classFlags[] = {"B", "A", "C", "AC", "E"}; // labels
+    
+    UInt_t * rows[kNClasses] = {0}; // Array of matching rows
+    Int_t nrows[kNClasses] = {0};
+    // Get rows matching the requested trigger bits for all trigger classes
+    for(Int_t iTrigClass = 0; iTrigClass < kNClasses; iTrigClass++){
+      nrows[iTrigClass] = GetStatRow(classFlags[iTrigClass],fComputeBG,&rows[iTrigClass]);     
+    }
+    
+    // 0. Determine the ratios of triggers E/B, A/B, C/B from the stat histogram
+    // Those are used to rescale the different classes to the same number of bx ids
+    // TODO: pass names of the rows for B, CA and E and look names of the rows. How do I handle the case in which both AC are in the same row?         
+    Int_t nBXIds[kNClasses] = {0};
+      //      cout <<"Computing BG:" << endl;
+    
+    for(Int_t iTrigClass = 0; iTrigClass < kNClasses; iTrigClass++){
+      for(Int_t irow = 0; irow < nrows[iTrigClass]; irow++) {
+       if(irow==0) cout << "- Class " << classFlags[iTrigClass] << endl;   
+       for (Int_t j=1; j<=fHistBunchCrossing->GetNbinsX(); j++) {
+         if (fHistBunchCrossing->GetBinContent(j, rows[iTrigClass][irow]) > 0) {
+           nBXIds[iTrigClass]++;        
+         }
+       }
+       if(nBXIds[iTrigClass]>0) cout << "   Using row " << rows[iTrigClass][irow] <<  ": " 
+                                     << fHistBunchCrossing->GetYaxis()->GetBinLabel(rows[iTrigClass][irow]) 
+                                     << " (nBXID "<< nBXIds[iTrigClass] << ")"<< endl;
+
       }
-      Float_t ratioBE = nB/nE;
-      Float_t ratioBA = nB/nA;
-      Float_t ratioBC = nB/nC;
-      Printf("Ratio between the BX ids in the different trigger classes:");
-      Printf("  B/E = %f",ratioBE);
-      Printf("  B/A = %f",ratioBA);
-      Printf("  B/C = %f",ratioBC);
-      Int_t nHistStat = 2;
-      // TODO: get number of rows in a more flexible way
-      // 1. loop over all cols
 
-      for(Int_t iHistStat = 0; iHistStat < nHistStat; iHistStat++){
-    
-       Int_t ncol = fHistStatistics[iHistStat]->GetNbinsX();
-       Float_t good1 = 0;
-       for(Int_t icol = 1; icol <= ncol; icol++) {
-         Int_t cint1B = (Int_t) fHistStatistics[iHistStat]->GetBinContent(icol,1);     
-         Int_t cint1A = (Int_t) fHistStatistics[iHistStat]->GetBinContent(icol,2);     
-         Int_t cint1C = (Int_t) fHistStatistics[iHistStat]->GetBinContent(icol,3);     
-         Int_t cint1E = (Int_t) fHistStatistics[iHistStat]->GetBinContent(icol,4);      
-      
-         if (cint1B>0) {
-           Int_t acc  = ratioBE*cint1E; 
-           Double_t acc_err = TMath::Sqrt(ratioBE*ratioBE*cint1E);
-           //      Int_t bg   = cint1A + cint1C - 2*acc;
-           Float_t bg   = fBIFactorA*(ratioBA*cint1A-acc) + fBIFactorC*(ratioBC*cint1C-acc) ;
-           Float_t good = Float_t(cint1B) - bg - acc;
-           if (icol ==1) good1 = good;
-           //      Float_t errGood     = TMath::Sqrt(2*(cint1A+cint1C+cint1E));// Error on the number of goods assuming only bg fluctuates
-           //      DeltaG^2 = B + FA^2 A + FC^2 C + Ratio^2 (FA+FC-1)^2 E.
-           Float_t errGood     = TMath::Sqrt( cint1B + 
-                                              fBIFactorA*fBIFactorA*ratioBA*ratioBA*cint1A +
-                                              fBIFactorC*fBIFactorC*ratioBC*ratioBC*cint1C +
-                                              ratioBE * ratioBE * 
-                                              (fBIFactorA + fBIFactorC - 1)*(fBIFactorA + fBIFactorC - 1)*cint1E);
-           Float_t errBG = TMath::Sqrt(fBIFactorA*fBIFactorA*ratioBA*ratioBA*cint1A+
-                                       fBIFactorC*fBIFactorC*ratioBC*ratioBC*cint1C+
-                                       ratioBE*ratioBE*(fBIFactorA+fBIFactorC)*(fBIFactorA+fBIFactorC)*cint1E);
+    }
+
+    Float_t ratioToB[kNClasses];
+    ratioToB[kClassE]  = nBXIds[kClassE]  >0 ? Float_t(nBXIds[kClassB])/nBXIds[kClassE]   : 0;
+    ratioToB[kClassA]  = nBXIds[kClassA]  >0 ? Float_t(nBXIds[kClassB])/nBXIds[kClassA]   : 0;
+    ratioToB[kClassC]  = nBXIds[kClassC]  >0 ? Float_t(nBXIds[kClassB])/nBXIds[kClassC]   : 0;
+    ratioToB[kClassAC] = nBXIds[kClassAC] >0 ? Float_t(nBXIds[kClassB])/nBXIds[kClassAC]  : 0;
+    Printf("Ratio between the BX ids in the different trigger classes:");
+    Printf("  B/E  = %d/%d = %f", nBXIds[kClassB],nBXIds[kClassE], ratioToB[kClassE] );
+    Printf("  B/A  = %d/%d = %f", nBXIds[kClassB],nBXIds[kClassA], ratioToB[kClassA] );
+    Printf("  B/C  = %d/%d = %f", nBXIds[kClassB],nBXIds[kClassC], ratioToB[kClassC] );
+    Printf("  B/AC = %d/%d = %f", nBXIds[kClassB],nBXIds[kClassAC],ratioToB[kClassAC]);
+    Int_t nHistStat = 2;
+
+    // 1. loop over all cols
+    for(Int_t iHistStat = 0; iHistStat < nHistStat; iHistStat++){
+      Int_t ncol = fHistStatistics[iHistStat]->GetNbinsX();
+      Float_t good1 = 0;      
+      for(Int_t icol = 1; icol <= ncol; icol++) {
+       Int_t nEvents[kNClasses] = {0}; // number of events should be reset at every column
+       // For all trigger classes, add up over row matching trigger mask (as selected before)
+       for(Int_t iTrigClass = 0; iTrigClass < kNClasses; iTrigClass++){
+         for(Int_t irow = 0; irow < nrows[iTrigClass]; irow++) {         
+           nEvents[iTrigClass] += (Int_t) fHistStatistics[iHistStat]->GetBinContent(icol,rows[iTrigClass][irow]);      
+         }
+         //        cout << "Events " << classFlags[iTrigClass] << " ("<<icol<<") " << nEvents[iTrigClass] << endl;         
+       }
+       if (nEvents[kClassB]>0) {
+         Float_t acc  = ratioToB[kClassE]*nEvents[kClassE]; 
+         Double_t accErr = TMath::Sqrt(ratioToB[kClassE]*ratioToB[kClassE]*nEvents[kClassE]);
+         //      Int_t bg   = cint1A + cint1C - 2*acc;
+           
+         // If intensity measurements are available, they already
+         // contain the scaling for BX ratios, so we reset the
+         // ratioToB entries
+         if(icol == 1) {
+           if(fBIFactorAC > 0 || fBIFactorA > 0 || fBIFactorC > 0) {
+             if (fBIFactorAC <= 0 && (fBIFactorA <= 0 || fBIFactorC <= 0)) {
+               AliError("Not all intensities set!, assuming equal intensities");
+               fBIFactorA  = 1;
+               fBIFactorC  = 1;
+               fBIFactorAC = 1;
+             } else {
+               AliInfo("Using ratio of number of bunch crossing embedded in the intensity measurements");
+               ratioToB[kClassA]  = ratioToB[kClassA]  >0 ? 1  : 0;
+               ratioToB[kClassC]  = ratioToB[kClassC]  >0 ? 1  : 0;
+               ratioToB[kClassAC] = ratioToB[kClassAC] >0 ? 1  : 0;
+               AliInfo(Form(" - BI Factor A:  %f",  fBIFactorA ));
+               AliInfo(Form(" - BI Factor C:  %f",  fBIFactorC ));
+               AliInfo(Form(" - BI Factor AC: %f",  fBIFactorAC ));
+               
+             }
+           } else {
+             AliWarning("Intensities not set!, assuming equal intensities");
+             fBIFactorA  = 1;
+             fBIFactorC  = 1;
+             fBIFactorAC = 1;
+           }
+         }
+         // Assuming that for a given class the triggers are either recorded as A+C or AC
+         Float_t bg  = nEvents[kClassAC] > 0 ?
+           fBIFactorAC*(ratioToB[kClassAC]*nEvents[kClassAC] - 2*acc):
+           fBIFactorA* (ratioToB[kClassA]*nEvents[kClassA]-acc) + 
+           fBIFactorC* (ratioToB[kClassC]*nEvents[kClassC]-acc) ;
+
+         // cout << "-----------------------" << endl;
+         // cout << "Factors: " << fBIFactorA << " " << fBIFactorC << " " << fBIFactorAC << endl;
+         // cout << "Ratios: "  << ratioToB[kClassA] << " " << ratioToB[kClassC] << " " << ratioToB[kClassAC] << endl;
+         // cout << "Evts:   "  << nEvents[kClassA] << " " << nEvents[kClassC] << " " << nEvents[kClassAC] << " " <<  nEvents[kClassB] << endl;
+         // cout << "Acc: " << acc << endl;
+         // cout << "BG: " << bg << endl;
+         // cout  << "  " <<   fBIFactorA* (ratioToB[kClassA]*nEvents[kClassA]-acc) <<endl;
+         // cout  << "  " <<   fBIFactorC* (ratioToB[kClassC]*nEvents[kClassC]-acc) <<endl;
+         // cout  << "  " <<   fBIFactorAC*(ratioToB[kClassAC]*nEvents[kClassAC] - 2*acc) << endl;
+         // cout << "-----------------------" << endl;
+
+         Float_t good = Float_t(nEvents[kClassB]) - bg - acc;
+         if (icol ==1) good1 = good;
+         //      Float_t errGood     = TMath::Sqrt(2*(nEvents[kClassA]+nEvents[kClassC]+nEvents[kClassE]));// Error on the number of goods assuming only bg fluctuates
+         //      DeltaG^2 = B + FA^2 A + FC^2 C + Ratio^2 (FA+FC-1)^2 E.
+         Float_t errGood     = nEvents[kClassAC] > 0 ? 
+           TMath::Sqrt( nEvents[kClassB] +
+                        fBIFactorAC*fBIFactorAC*ratioToB[kClassAC]*ratioToB[kClassAC]*nEvents[kClassAC] +
+                        ratioToB[kClassE] * ratioToB[kClassE] * 
+                        (fBIFactorAC - 1)*(fBIFactorAC - 1)*nEvents[kClassE]) :  
+           TMath::Sqrt( nEvents[kClassB] + 
+                        fBIFactorA*fBIFactorA*ratioToB[kClassA]*ratioToB[kClassA]*nEvents[kClassA] +
+                        fBIFactorC*fBIFactorC*ratioToB[kClassC]*ratioToB[kClassC]*nEvents[kClassC] +
+                        ratioToB[kClassE] * ratioToB[kClassE] * 
+                        (fBIFactorA + fBIFactorC - 1)*(fBIFactorA + fBIFactorC - 1)*nEvents[kClassE]);
+
+         Float_t errBG = nEvents[kClassAC] > 0 ? 
+           TMath::Sqrt(fBIFactorAC*fBIFactorAC*ratioToB[kClassAC]*ratioToB[kClassAC]*nEvents[kClassAC]+
+                       4*ratioToB[kClassE]*ratioToB[kClassE]*(fBIFactorAC*fBIFactorAC)*nEvents[kClassE]) :
+           TMath::Sqrt(fBIFactorA*fBIFactorA*ratioToB[kClassA]*ratioToB[kClassA]*nEvents[kClassA]+
+                       fBIFactorC*fBIFactorC*ratioToB[kClassC]*ratioToB[kClassC]*nEvents[kClassC]+
+                       ratioToB[kClassE]*ratioToB[kClassE]*(fBIFactorA+fBIFactorC)*(fBIFactorA+fBIFactorC)*nEvents[kClassE]);
        
        
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowBG,bg);      
-           fHistStatistics[iHistStat]->SetBinError  (icol,kStatRowBG,errBG);   
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowAcc,acc);    
-           fHistStatistics[iHistStat]->SetBinError  (icol,kStatRowAcc,acc_err);        
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowGood,good);    
-           fHistStatistics[iHistStat]->SetBinError  (icol,kStatRowGood,errGood);    
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowAllB, nEvents[kClassB]); 
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowAllAC,nEvents[kClassA]+nEvents[kClassC]+nEvents[kClassAC]);      
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowAllE, nEvents[kClassE]); 
+
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowBG,bg);  
+         fHistStatistics[iHistStat]->SetBinError  (icol,fBGStatOffset+kStatRowBG,errBG);       
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowAcc,acc);        
+         fHistStatistics[iHistStat]->SetBinError  (icol,fBGStatOffset+kStatRowAcc,accErr);     
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowGood,good);    
+         fHistStatistics[iHistStat]->SetBinError  (icol,fBGStatOffset+kStatRowGood,errGood);    
 
 #ifdef VERBOSE_STAT
-           //kStatRowBG=5,kStatRowAcc,kStatRowBGFrac,kStatRowAccFrac,kStatRowErrGoodFrac,kStatRowGoodFrac,kStatRowGood,kStatRowErrGood
-           Float_t accFrac   = Float_t(acc) / cint1B  *100;
-           Float_t errAccFrac= Float_t(acc_err) / cint1B  *100;
-           Float_t bgFrac    = Float_t(bg)  / cint1B  *100;
-           Float_t goodFrac  = Float_t(good)  / good1 *100;
-           Float_t errGoodFrac = errGood/good1 * 100;
-           Float_t errFracBG = bg > 0 ? TMath::Sqrt((errBG/bg)*(errBG/bg) + 1/cint1B)*bgFrac : 0;
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowBGFrac,bgFrac);      
-           fHistStatistics[iHistStat]->SetBinError  (icol,kStatRowBGFrac,errFracBG);   
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowAccFrac,accFrac);    
-           fHistStatistics[iHistStat]->SetBinError  (icol,kStatRowAccFrac,errAccFrac);    
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowGoodFrac,goodFrac);    
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowErrGoodFrac,errGoodFrac);    
-           fHistStatistics[iHistStat]->SetBinContent(icol,kStatRowErrGood,errGood);    
+         //kStatRowBG=0,kStatRowAcc,kStatRowBGFrac,kStatRowAccFrac,kStatRowErrGoodFrac,kStatRowGoodFrac,kStatRowGood,kStatRowErrGood
+         Float_t accFrac   = Float_t(acc) / nEvents[kClassB]  *100;
+         Float_t errAccFrac= Float_t(accErr) / nEvents[kClassB]  *100;
+         Float_t bgFrac    = Float_t(bg)  / nEvents[kClassB]  *100;
+         Float_t goodFrac  = Float_t(good)  / good1 *100;
+         Float_t errGoodFrac = errGood/good1 * 100;
+         Float_t errFracBG = bg > 0 ? TMath::Sqrt((errBG/bg)*(errBG/bg) + 1/nEvents[kClassB])*bgFrac : 0;
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowBGFrac,bgFrac);  
+         fHistStatistics[iHistStat]->SetBinError  (icol,fBGStatOffset+kStatRowBGFrac,errFracBG);       
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowAccFrac,accFrac);    
+         fHistStatistics[iHistStat]->SetBinError  (icol,fBGStatOffset+kStatRowAccFrac,errAccFrac);    
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowGoodFrac,goodFrac);    
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowErrGoodFrac,errGoodFrac);    
+         fHistStatistics[iHistStat]->SetBinContent(icol,fBGStatOffset+kStatRowErrGood,errGood);    
 #endif
-         }
        }
       }
+    }
+    for (Int_t iTrigClass = 0; iTrigClass < kNClasses; iTrigClass++){
+      delete [] rows[iTrigClass];
     }  
-  }
+  }  
 
   fHistStatistics[0]->Write();
   fHistStatistics[1]->Write();
@@ -1093,154 +1645,291 @@ void AliPhysicsSelection::SaveHistograms(const char* folder) const
   
   Int_t count = fCollTrigClasses.GetEntries() + fBGTrigClasses.GetEntries();
   for (Int_t i=0; i < count; i++)
-  {
-    TString triggerClass = "trigger_histograms_";
-    if (i < fCollTrigClasses.GetEntries())
-      triggerClass += ((TObjString*) fCollTrigClasses.At(i))->String();
-    else
-      triggerClass += ((TObjString*) fBGTrigClasses.At(i - fCollTrigClasses.GetEntries()))->String();
-  
-    gDirectory->mkdir(triggerClass);
-    gDirectory->cd(triggerClass);
-  
-    static_cast<AliTriggerAnalysis*> (fTriggerAnalysis.At(i))->SaveHistograms();
+    {
+      TString triggerClass = "trigger_histograms_";
+      if (i < fCollTrigClasses.GetEntries())
+       triggerClass += ((TObjString*) fCollTrigClasses.At(i))->String();
+      else
+       triggerClass += ((TObjString*) fBGTrigClasses.At(i - fCollTrigClasses.GetEntries()))->String();
+      
+      gDirectory->mkdir(triggerClass);
+      gDirectory->cd(triggerClass);
+      
+      static_cast<AliTriggerAnalysis*> (fTriggerAnalysis.At(i))->SaveHistograms();
+      
+      gDirectory->cd("..");
+    }
     
+  if (folder)
     gDirectory->cd("..");
+  
+}
+
+Int_t AliPhysicsSelection::GetStatRow(const char * triggerBXClass, UInt_t offlineTriggerType, UInt_t ** rowIDs) const {
+  // Puts inside the array rowIDs the row number for a given offline
+  // trigger in a given bx class. Returns the total number of lines
+  // matching the selection
+  // triggerBXClass can be either "A", "AC", "B" or "E"
+  // offlineTriggerType is one of the types defined in AliVEvent
+  // User should delete rowIDs if no longer needed
+
+  if(!fHistStatistics[0]) {
+    AliWarning("Not initialized, returning 0");
+    return 0;
   }
-  if (fBackgroundIdentification)
-  {
-    gDirectory->mkdir("background_identification");
-    gDirectory->cd("background_identification");
+  const Int_t nrows = fHistStatistics[0]->GetNbinsY();
+
+  // allocate memory for at maximum nrows
+  Int_t nMatches = 0;
+  (*rowIDs) = new UInt_t[nrows];
+
+
+  // Loop over rows and find matching ones, using the PS OADB
+  // FIXME: check BG estimates
+  for(Int_t irow = 1; irow <= nrows; irow++){
+    TString triggerClassCurrent = fHistStatistics[0]->GetYaxis()->GetBinLabel(irow);
+    TPRegexp trigType (".*\\&(\\d+).*");
+    TObjArray * arr = trigType.MatchS(triggerClassCurrent.Data());
+    if(arr->GetEntries() > 1){
+      UInt_t tType = ((TObjString*)arr->At(1))->GetString().Atoi();
       
-    fBackgroundIdentification->GetOutput()->Write();
+      if (tType == offlineTriggerType && fPSOADB->GetBeamSide(triggerClassCurrent.Data()) == triggerBXClass) {
+       (*rowIDs)[nMatches] = irow;
+       nMatches++;
+      }
+
+    }
+    delete arr;
+
+  }
+  
+  return nMatches;
+}
+
+void AliPhysicsSelection::SetBIFactors(const AliESDEvent * aESD) {
+  // Set factors for realtive bunch intesities
+  if(!aESD) { 
+    AliFatal("ESD not given");
+  }
+  Int_t run = aESD->GetRunNumber();
+  if (run > 105268) {
+    // intensities stored in the ESDs
+    const AliESDRun* esdRun = aESD->GetESDRun();
+    Double_t intAB = esdRun->GetMeanIntensityIntecting(0);
+    Double_t intCB = esdRun->GetMeanIntensityIntecting(1);
+    Double_t intAA = esdRun->GetMeanIntensityNonIntecting(0);
+    Double_t intCC = esdRun->GetMeanIntensityNonIntecting(1);
+
+    // cout << "INT " <<intAB <<endl;
+    // cout << "INT " <<intCB <<endl;
+    // cout << "INT " <<intAA <<endl;
+    // cout << "INT " <<intCC <<endl;
+
+    if (intAB > 0 && intAA > 0) {
+      fBIFactorA = intAB/intAA;
+    } else {
+      AliWarning("Cannot set fBIFactorA");
+    }
+    
+    if (intCB > 0 && intCC > 0) {
+      fBIFactorC = intCB/intCC;
+    } else {
+      AliWarning("Cannot set fBIFactorC");
+    }
       
-    gDirectory->cd("..");
+    if (intAB > 0 && intAA > 0 &&
+       intCB > 0 && intCC > 0) {
+      fBIFactorAC = (intAB+intCB)/(intAA+intCC);
+    } else {
+      AliWarning("Cannot set fBIFactorAC");
+    }
+        
+  }  
+  else {
+    // First runs. Intensities hardcoded
+    switch(run) {
+    case 104155:
+      fBIFactorA = 0.961912722908;
+      fBIFactorC = 1.04992336081;
+      break;
+    case 104157:
+      fBIFactorA = 0.947312854998;
+      fBIFactorC = 1.01599706417;
+      break;
+    case 104159:
+      fBIFactorA = 0.93659320151;
+      fBIFactorC = 0.98580804207;
+      break;
+    case 104160:
+      fBIFactorA = 0.929664189926;
+      fBIFactorC = 0.963467679851;
+      break;
+    case 104315:
+      fBIFactorA = 1.08939104979;
+      fBIFactorC = 0.931113921925;
+      break;
+    case 104316:
+      fBIFactorA = 1.08351880974;
+      fBIFactorC = 0.916068345845;
+      break;
+    case 104320:
+      fBIFactorA = 1.07669281245;
+      fBIFactorC = 0.876818744763;
+      break;
+    case 104321:
+      fBIFactorA = 1.00971079602;
+      fBIFactorC = 0.773781299076;
+      break;
+    case 104792:
+      fBIFactorA = 0.787215863962;
+      fBIFactorC = 0.778253173071;
+      break;
+    case 104793:
+      fBIFactorA = 0.692211363661;
+      fBIFactorC = 0.733152456667;
+      break;
+    case 104799:
+      fBIFactorA = 1.04027825161;
+      fBIFactorC = 1.00530825942;
+      break;
+    case 104800:
+      fBIFactorA = 1.05309910671;
+      fBIFactorC = 1.00376801855;
+      break;
+    case 104801:
+      fBIFactorA = 1.0531231922;
+      fBIFactorC = 0.992439666758;
+      break;
+    case 104802:
+      fBIFactorA = 1.04191478134;
+      fBIFactorC = 0.979368585208;
+      break;
+    case 104803:
+      fBIFactorA = 1.03121314094;
+      fBIFactorC = 0.973379962609;
+      break;
+    case 104824:
+      fBIFactorA = 0.969945926722;
+      fBIFactorC = 0.39549745806;
+      break;
+    case 104825:
+      fBIFactorA = 0.968627213937;
+      fBIFactorC = 0.310100412205;
+      break;
+    case 104841:
+      fBIFactorA = 0.991601393212;
+      fBIFactorC = 0.83762204722;
+      break;
+    case 104845:
+      fBIFactorA = 0.98040863886;
+      fBIFactorC = 0.694824205793;
+      break;
+    case 104867:
+      fBIFactorA = 1.10646173412;
+      fBIFactorC = 0.841407246916;
+      break;
+    case 104876:
+      fBIFactorA = 1.12063452421;
+      fBIFactorC = 0.78726542895;
+      break;
+    case 104890:
+      fBIFactorA = 1.02346137453;
+      fBIFactorC = 1.03355663595;
+      break;
+    case 104892:
+      fBIFactorA = 1.05406025913;
+      fBIFactorC = 1.00029166135;
+      break;
+    case 105143:
+      fBIFactorA = 0.947343384349;
+      fBIFactorC = 0.972637444408;
+      break;
+    case 105160:
+      fBIFactorA = 0.908854622177;
+      fBIFactorC = 0.958851103977;
+      break; 
+    case 105256:
+      fBIFactorA = 0.810076150206;
+      fBIFactorC = 0.884663561883;
+      break;
+    case 105257:
+      fBIFactorA = 0.80974912303;
+      fBIFactorC = 0.878859123479;
+      break;
+    case 105268:
+      fBIFactorA = 0.809052110679;
+      fBIFactorC = 0.87233890989;
+      break;
+    default:
+      fBIFactorA = 1;
+      fBIFactorC = 1;
+    }
   }
+
+}
+
+const char * AliPhysicsSelection::GetTriggerString(TObjString * obj) { 
+  // Returns a formed objstring
+  static TString retString;
   
-  if (folder)
-    gDirectory->cd("..");
+  retString.Form("%s%s", 
+                obj->String().Data(), 
+                fUseBXNumbers ? fFillOADB->GetBXIDs(fPSOADB->GetBeamSide(obj->String().Data())) : ""  
+                );
+
+  if (fMC) {
+    TPRegexp stripClasses("\\+\\S* ");
+    stripClasses.Substitute(retString,"","g");
+    stripClasses=TPRegexp("\\-\\S* ");
+    stripClasses.Substitute(retString,"","g");
+  }
+
+  return retString.Data();
 }
 
-void AliPhysicsSelection::SetBIFactors(Int_t run) {
-
-  switch(run) {
-  case 104155:
-    fBIFactorA = 0.961912722908;
-    fBIFactorC = 1.04992336081;
-    break;
-  case 104157:
-    fBIFactorA = 0.947312854998;
-    fBIFactorC = 1.01599706417;
-    break;
-  case 104159:
-    fBIFactorA = 0.93659320151;
-    fBIFactorC = 0.98580804207;
-    break;
-  case 104160:
-    fBIFactorA = 0.929664189926;
-    fBIFactorC = 0.963467679851;
-    break;
-  case 104315:
-    fBIFactorA = 1.08939104979;
-    fBIFactorC = 0.931113921925;
-    break;
-  case 104316:
-    fBIFactorA = 1.08351880974;
-    fBIFactorC = 0.916068345845;
-    break;
-  case 104320:
-    fBIFactorA = 1.07669281245;
-    fBIFactorC = 0.876818744763;
-    break;
-  case 104321:
-    fBIFactorA = 1.00971079602;
-    fBIFactorC = 0.773781299076;
-    break;
-  case 104792:
-    fBIFactorA = 0.787215863962;
-    fBIFactorC = 0.778253173071;
-    break;
-  case 104793:
-    fBIFactorA = 0.692211363661;
-    fBIFactorC = 0.733152456667;
-    break;
-  case 104799:
-    fBIFactorA = 1.04027825161;
-    fBIFactorC = 1.00530825942;
-    break;
-  case 104800:
-    fBIFactorA = 1.05309910671;
-    fBIFactorC = 1.00376801855;
-    break;
-  case 104801:
-    fBIFactorA = 1.0531231922;
-    fBIFactorC = 0.992439666758;
-    break;
-  case 104802:
-    fBIFactorA = 1.04191478134;
-    fBIFactorC = 0.979368585208;
-    break;
-  case 104803:
-    fBIFactorA = 1.03121314094;
-    fBIFactorC = 0.973379962609;
-    break;
-  case 104824:
-    fBIFactorA = 0.969945926722;
-    fBIFactorC = 0.39549745806;
-    break;
-  case 104825:
-    fBIFactorA = 0.968627213937;
-    fBIFactorC = 0.310100412205;
-    break;
-  case 104841:
-    fBIFactorA = 0.991601393212;
-    fBIFactorC = 0.83762204722;
-    break;
-  case 104845:
-    fBIFactorA = 0.98040863886;
-    fBIFactorC = 0.694824205793;
-    break;
-  case 104867:
-    fBIFactorA = 1.10646173412;
-    fBIFactorC = 0.841407246916;
-    break;
-  case 104876:
-    fBIFactorA = 1.12063452421;
-    fBIFactorC = 0.78726542895;
-    break;
-  case 104890:
-    fBIFactorA = 1.02346137453;
-    fBIFactorC = 1.03355663595;
-    break;
-  case 104892:
-    fBIFactorA = 1.05406025913;
-    fBIFactorC = 1.00029166135;
-    break;
-  case 105143:
-    fBIFactorA = 0.947343384349;
-    fBIFactorC = 0.972637444408;
-    break;
-  case 105160:
-    fBIFactorA = 0.908854622177;
-    fBIFactorC = 0.958851103977;
-    break; 
-  case 105256:
-    fBIFactorA = 0.810076150206;
-    fBIFactorC = 0.884663561883;
-    break;
-  case 105257:
-    fBIFactorA = 0.80974912303;
-    fBIFactorC = 0.878859123479;
-    break;
-  case 105268:
-    fBIFactorA = 0.809052110679;
-    fBIFactorC = 0.87233890989;
-    break;
-  default:
-    fBIFactorA = 1;
-    fBIFactorC = 1;
+void AliPhysicsSelection::AddCollisionTriggerClass(const char* className){
+  AliError("This method is deprecated! Will be removed soon! Please use SetCustomOADBObjects() instead!");
+  if(!fPSOADB) {
+    fPSOADB = new AliOADBPhysicsSelection("CustomPS");   
+    fPSOADB->SetHardwareTrigger         ( 0,"SPDGFO >= 1 || V0A || V0C");
+    fPSOADB->SetOfflineTrigger          ( 0,"(SPDGFO >= 1 || V0A || V0C) && !V0ABG && !V0CBG");
   }
 
+  // Strip all which is not needed, if BX ids are provided, they are still used here
+  // offline trigger and logics are appended automagically, so we strip-em out if they are provided
+  TString classNameStripped = className;
+  if(classNameStripped.Index("*")>0)
+    classNameStripped.Remove(classNameStripped.Index("*")); // keep only the class name (no bx, offline trigger...)   
+  if(classNameStripped.Index("&")>0)
+    classNameStripped.Remove(classNameStripped.Index("&")); // keep only the class name (no bx, offline trigger...)   
+
+  fPSOADB->AddCollisionTriggerClass   ( AliVEvent::kUserDefined,classNameStripped.Data(),"B",0);
+  
+  fUsingCustomClasses = kTRUE;
+
 
 }
+
+void AliPhysicsSelection::AddBGTriggerClass(const char* className){
+  // Add custom BG trigger class
+  AliError("This method is deprecated! Will be removed soon! Please use SetCustomOADBObjects() instead!");
+  if(!fPSOADB) {
+    fPSOADB = new AliOADBPhysicsSelection("CustomPS");   
+    fPSOADB->SetHardwareTrigger         ( 0,"SPDGFO >= 1 || V0A || V0C");
+    fPSOADB->SetOfflineTrigger          ( 0,"(SPDGFO >= 1 || V0A || V0C) && !V0ABG && !V0CBG");
+  }
+
+  // Strip all which is not needed, if BX ids are provided, they are still used here
+  // offline trigger and logics are appended automagically, so we strip-em out if they are provided
+  TString classNameStripped = className;
+  if(classNameStripped.Index("*")>0)
+    classNameStripped.Remove(classNameStripped.Index("*")); // keep only the class name (no bx, offline trigger...)   
+  if(classNameStripped.Index("&")>0)
+    classNameStripped.Remove(classNameStripped.Index("&")); // keep only the class name (no bx, offline trigger...)   
+
+  fPSOADB->AddBGTriggerClass   ( AliVEvent::kUserDefined,classNameStripped.Data(),"AC",0);
+
+  fUsingCustomClasses = kTRUE;
+
+}