[u/mrichter/AliRoot.git] / PWGHF / vertexingHF / RunAnalysisAODVertexingHF.C

class AliAnalysisGrid;
class AliAnalysisAlien;

void RunAnalysisAODVertexingHF()
{
  //
  // Test macro for AliAnalysisTaskSE's for heavy-flavour candidates
  // It has the structure of a Analysis Train:
  // - in this macro, change things related to running mode
  //   and input preparation 
  // - add your task using a AddTaskXXX macro 
  //
  // A.Dainese, andrea.dainese@lnl.infn.it
  // "grid" mode added by R.Bala, bala@to.infn.it
  //


  gSystem->SetIncludePath("-I. -I$ROOTSYS/include -I$ALICE_ROOT -I$ALICE_ROOT/include -I$ALICE_ROOT/ITS -I$ALICE_ROOT/TPC -I$ALICE_ROOT/CONTAINERS -I$ALICE_ROOT/STEER/STEER -I$ALICE_ROOT/STEER/STEERBase -I$ALICE_ROOT/STEER/ESD -I$ALICE_ROOT/STEER/AOD -I$ALICE_ROOT/TRD -I$ALICE_ROOT/macros -I$ALICE_ROOT/ANALYSIS  -I$ALICE_ROOT/OADB -I$ALICE_ROOT/PWGHF -I$ALICE_ROOT/PWGHF/base -I$ALICE_ROOT/PWGHF/vertexingHF -I$ALICE_ROOT/PWG/FLOW/Base -I$ALICE_ROOT/PWG/FLOW/Tasks -I$ALICE_ROOT/PWG -g"); 
  //
  TString trainName = "D2H";
  TString analysisMode = "grid"; // "local", "grid", or "proof"
  TString inputMode    = "list"; // "list", "xml", or "dataset"
  Long64_t nentries=123567890,firstentry=0;
  Bool_t useParFiles=kFALSE;
  Bool_t useAlienPlugin=kTRUE;
  TString pluginmode="full";
  TString testfileslistWithPlugin="";
  Bool_t saveProofToAlien=kFALSE;
  TString proofOutdir = "";
  TString loadMacroPath="$ALICE_ROOT/PWGHF/vertexingHF/macros/";
  //TString loadMacroPath="./"; // this is normally needed for CAF
  //

  if(analysisMode=="grid") {
    // Connect to AliEn
    TGrid::Connect("alien://");
  } else if(analysisMode=="proof") {
    // Connect to the PROOF cluster
    if(inputMode!="dataset") {printf("Input mode must be dataset, for proof analysis\n"); return;}
    gEnv->SetValue("XSec.GSI.DelegProxy","2");
    TProof::Open("alicecaf");
    //TProof::Reset("alicecaf");
    if(saveProofToAlien) {
      TGrid::Connect("alien://");
      if(gGrid) {
	TString homedir = gGrid->GetHomeDirectory();
	TString workdir = homedir + trainName;
	if(!gGrid->Cd(workdir)) {
	  gGrid->Cd(homedir);
	  if(gGrid->Mkdir(workdir)) {
	    gGrid->Cd(trainName);
	    ::Info("VertexingTrain::Connect()", "Directory %s created", gGrid->Pwd());
	  }
	}	   
	gGrid->Mkdir("proof_output");
	gGrid->Cd("proof_output");
	proofOutdir = Form("alien://%s", gGrid->Pwd());
      } 
    }
  }


  // AliRoot libraries
  if(analysisMode=="local" || analysisMode=="grid") {
    TString loadLibraries="LoadLibraries.C"; loadLibraries.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(loadLibraries.Data());
    LoadLibraries(useParFiles);
    gSystem->Load("libGui");
    gSystem->Load("libRAWDatabase");
    gSystem->Load("libCDB");
    gSystem->Load("libSTEER");
    gSystem->Load("libTRDbase");
    gSystem->Load("libPWGTRD");
  } else if (analysisMode=="proof") {
    gSystem->Load("libTree");
    gSystem->Load("libGeom");
    gSystem->Load("libPhysics");
    gSystem->Load("libVMC");
    gSystem->Load("libMinuit");
    gSystem->Load("libGui");
    gSystem->Load("libRAWDatabase");
    gSystem->Load("libCDB");
    gSystem->Load("libSTEER");
    gSystem->Load("libTRDbase");
    gSystem->Load("libPWGTRD");
    // Enable the needed packages
    //gProof->ClearPackages();
    TString parDir="/afs/cern.ch/user/d/dainesea/code/";
    TString parFile;
    if(!useParFiles) {
      gProof->UploadPackage("AF-v4-17");
      gProof->EnablePackage("AF-v4-17");
      // --- Enable the PWGHFvertexingHF Package
      parFile="PWGHFvertexingHF.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("PWGHFvertexingHF");
    } else {
      // --- Enable the STEERBase Package
      parFile="STEERBase.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("STEERBase");
      // --- Enable the ESD Package
      parFile="ESD.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("ESD");
      // --- Enable the AOD Package
      parFile="AOD.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("AOD");
      // --- Enable the ANALYSIS Package
      parFile="ANALYSIS.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("ANALYSIS");
      // --- Enable the ANALYSISalice Package
      parFile="ANALYSISalice.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("ANALYSISalice");
      // --- Enable the CORRFW Package
      parFile="CORRFW.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("CORRFW");
      // --- Enable the PWGHFbase Package
      parFile="PWGHFbase.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("PWGHFbase");
      // --- Enable the PWGHFvertexingHF Package
      parFile="PWGHFvertexingHF.par"; parFile.Prepend(parDir.Data());
      gProof->UploadPackage(parFile.Data());
      gProof->EnablePackage("PWGHFvertexingHF");
    }
    gProof->ShowEnabledPackages(); // show a list of enabled packages
  }


  // Create Alien plugin, if requested
  if(useAlienPlugin) {  
    //    if(analysisMode!="grid") {printf("Analysis mode must be grid, to use alien plugin\n"); return;}
    AliAnalysisGrid *alienHandler = CreateAlienHandler(pluginmode,useParFiles,testfileslistWithPlugin);  
    if(!alienHandler) return;
  }


  //-------------------------------------------------------------------
  // Prepare input
  TChain *chainAOD = 0;
  TString dataset; // for proof

  if(!useAlienPlugin) {
    TString makeAODInputChain="../MakeAODInputChain.C"; makeAODInputChain.Prepend(loadMacroPath.Data());
    if(inputMode=="list") {
      // Local files
      gROOT->LoadMacro(makeAODInputChain.Data());
      chainAOD = MakeAODInputChain();// with this it reads ./AliAOD.root and ./AliAOD.VertexingHF.root
      //chainAOD = MakeAODInputChain("alien:///alice/cern.ch/user/r/rbala/newtrain/out_lhc08x/180100/",1,1);
      printf("ENTRIES %d\n",chainAOD->GetEntries());
    } else if(inputMode=="xml") {
      // xml
      gROOT->LoadMacro(makeAODInputChain.Data());
      chainAOD = MakeAODInputChain("collection_aod.xml","collection_aodHF.xml");
    } else if(inputMode=="dataset") {
      // CAF dataset
      //gProof->ShowDataSets();
      dataset="/ITS/dainesea/AODVertexingHF_LHC08x_180100";
    }
  }

  // Create the analysis manager
  AliAnalysisManager *mgr  = new AliAnalysisManager("My Manager","My Manager");
  mgr->SetDebugLevel(10);
  // Connect plug-in to the analysis manager
  if(useAlienPlugin) mgr->SetGridHandler(alienHandler);

  // Input
  AliAODInputHandler *inputHandler = new AliAODInputHandler("handler","handler for D2H");
  if(analysisMode=="proof" ) {
    inputHandler->AddFriend("./AliAOD.VertexingHF.root");
    //inputHandler->AddFriend("deltas/AliAOD.VertexingHF.root");
    if(saveProofToAlien) mgr->SetSpecialOutputLocation(proofOutdir);
  }
  mgr->SetInputEventHandler(inputHandler);
  //-------------------------------------------------------------------

  
  //-------------------------------------------------------------------
  // Analysis tasks (wagons of the train)   
  //
  // First add the task for the PID response setting
  gROOT->LoadMacro("$ALICE_ROOT/ANALYSIS/macros/AddTaskPIDResponse.C");
  AliAnalysisTaskSE *setupTask = AddTaskPIDResponse(kFALSE,kTRUE);

  gROOT->LoadMacro("$ALICE_ROOT/ANALYSIS/macros/AddTaskPIDqa.C");
  AliAnalysisTaskPIDqa *pidQA = AddTaskPIDqa();


  TString taskName;
  
  ////// ADD THE FULL D2H TRAIN
  /*taskName="../AddD2HTrain.C"; taskName.Prepend(loadMacroPath.Data());
  gROOT->LoadMacro(taskName.Data());
  Bool_t readMC=kFALSE;
  AddD2HTrain(readMC);//,1,0,0,0,0,0,0,0,0,0,0);*/
  
  ////// OR ADD INDIVIDUAL TASKS
  
  taskName="AddTaskHFQA.C"; taskName.Prepend(loadMacroPath.Data());
  gROOT->LoadMacro(taskName.Data());
  AliAnalysisTaskSEHFQA *qaTask = AddTaskHFQA(0,"",kFALSE, kTRUE, 0 , "QApp",kTRUE,kTRUE,kFALSE, kTRUE, kFALSE,kTRUE);

  /*  taskName="AddTaskCompareHF.C"; taskName.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(taskName.Data());
    AliAnalysisTaskSECompareHF *cmpTask = AddTaskCompareHF();
    */  
    taskName="AddTaskD0Mass.C"; taskName.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(taskName.Data());
    AliAnalysisTaskSED0Mass *d0massTask = AddTaskD0Mass();
    AliAnalysisTaskSED0Mass *d0massLikeSignTask = AddTaskD0Mass(1); 
    /*
    taskName="AddTaskDplus.C"; taskName.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(taskName.Data());
    AliAnalysisTaskSEDplus *dplusTask = AddTaskDplus();

    taskName="AddTaskDs.C"; taskName.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(taskName.Data());
    AliAnalysisTaskSEDs *dsTask = AddTaskDs();
    
    //taskName="AddTaskSelectHF.C"; taskName.Prepend(loadMacroPath.Data());
    //gROOT->LoadMacro(taskName.Data());
    //AliAnalysisTaskSESelectHF *seleTask = AddTaskSelectHF();
    
    taskName="AddTaskBkgLikeSignD0.C"; taskName.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(taskName.Data());
    AliAnalysisTaskSEBkgLikeSignD0 *lsD0Task = AddTaskBkgLikeSignD0();
    
    taskName="AddTaskCFMultiVarMultiStep.C"; taskName.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(taskName.Data());
    AliCFHeavyFlavourTaskMultiVarMultiStep *cfmvmsTask = AddTaskCFMultiVarMultiStep();
    

    taskName="AddTaskSECharmFraction.C"; 
    taskName.Prepend(loadMacroPath.Data());
    gROOT->LoadMacro(taskName.Data());
    Int_t switchMC[5]={0,0,0,0,0};
    Int_t ppPbPb=1;// 0 for pp, 1 for PbPb, used to siwtch on/off the removal of daughters from the primary vertex
    AliAnalysisTaskSECharmFraction *cFractTask = AddTaskSECharmFraction("standard",switchMC,readMC,kTRUE,kFALSE,"D0toKpiCharmFractCuts.root","c",ppPbPb);
    // arguments: filename,switchMC,readmc,usepid,likesign,cutfilename,containerprefix

    
    // attach a private task (not committed)
    // (the files MyTask.h MyTask.cxx AddMyTask.C have to be declared in plugin
    // configuration, see below)
    
    if(analysisMode.Data()=="proof") {
    gProof->LoadMacro("MyTask.cxx++g");
    } else {
    gROOT->LoadMacro("MyTask.cxx++g");
    }
    gROOT->LoadMacro("AddMyTask.C");
    MyTask *myTask = AddMyTask();
    
    
    if(analysisMode.Data()=="proof") {
    gProof->LoadMacro("AliDStarJets.cxx++g");
    } else {
    gROOT->LoadMacro("AliDStarJets.cxx++g");
    }
    gROOT->LoadMacro("AddTaskDStarJets.C");
    AliDStarJets *myTask = AddTaskDStarJets();
  */
  //-------------------------------------------------------------------
  
  //
  // Run the analysis
  //    
  if(chainAOD) printf("CHAIN HAS %d ENTRIES\n",(Int_t)chainAOD->GetEntries());
  
  if(!mgr->InitAnalysis()) return;
  mgr->PrintStatus();
  if(analysisMode=="grid" && !useAlienPlugin) analysisMode="local";
  if(analysisMode!="proof") {
    mgr->StartAnalysis(analysisMode.Data(),chainAOD,nentries,firstentry);
  } else {
    // proof
    mgr->StartAnalysis(analysisMode.Data(),dataset.Data(),nentries,firstentry);
  }
  
  return;
}
//_____________________________________________________________________________
//
AliAnalysisGrid* CreateAlienHandler(TString pluginmode="test",Bool_t useParFiles=kFALSE, TString testfileslistWithPlugin="")
{
  // Check if user has a valid token, otherwise make one. This has limitations.
  // One can always follow the standard procedure of calling alien-token-init then
  //   source /tmp/gclient_env_$UID in the current shell.
   AliAnalysisAlien *plugin = new AliAnalysisAlien();
   // Set the run mode (can be "full", "test", "offline", "submit" or "terminate")
   plugin->SetRunMode(pluginmode.Data());
   plugin->SetUser();
   // Set versions of used packages
   plugin->SetAPIVersion("V1.1x");
   plugin->SetROOTVersion();
   plugin->SetAliROOTVersion();
   plugin->SetNtestFiles(1);
   gROOT->LoadMacro("$ALICE_ROOT/PWGHF/vertexingHF/AddGoodRuns.C");

   // Declare input data to be processed.
   //************************************************
   // Set data file list to test on local mode
   //************************************************  
   plugin->SetFileForTestMode(testfileslistWithPlugin.Data());

   //************************************************
   // Set data search pattern for DATA
   //************************************************  
   //Method 1: To create automatically xml through plugin  
   plugin->SetGridDataDir("/alice/data/2010/LHC10d"); // specify LHC period
   plugin->SetDataPattern("pass2/AOD018/*AliAOD.root"); // specify reco pass and AOD set
   plugin->SetFriendChainName("./AliAOD.VertexingHF.root");
   // OR plugin->SetFriendChainName("deltas/AliAOD.VertexingHF.root");
   // Adds only the good runs from the Monalisa Run Condition Table
   // More than one period can be added but the period name has to be removed from GridDataDir (to be tested)
   Int_t totruns=0;
   //totruns += AddGoodRuns(plugin,"LHC10b"); // specify LHC period
   //totruns += AddGoodRuns(plugin,"LHC10c"); // specify LHC period
   totruns += AddGoodRuns(plugin,"LHC10d"); // specify LHC period
   plugin->SetNrunsPerMaster(totruns);

   // Method 2: Declare existing data files (e.g xml collections)

   //plugin->AddDataFile("/alice/cern.ch/user/r/rbala/000168068_000170593.xml");
   //  plugin->SetDataPattern("*AliAOD.root");
   //  plugin->SetFriendChainName("./AliAOD.VertexingHF.root"); 

   //************************************************
   // Set data search pattern for MONTECARLO
   //************************************************
   /* 
   plugin->SetGridDataDir("/alice/sim/LHC10d3"); // specify MC sample
   plugin->SetDataPattern("AOD005/*AliAOD.root"); // specify AOD set
   plugin->SetFriendChainName("./AliAOD.VertexingHF.root");
   // OR plugin->SetFriendChainName("deltas/AliAOD.VertexingHF.root");
   // Adds only the good runs from the Monalisa Run Condition Table 
   // More than one period can be added!
   Int_t totruns=0;
   totruns += AddGoodRuns(plugin,"LHC10b","LHC10d3"); // specify LHC period for anchor runs; and the name of the MC production
   //totruns += AddGoodRuns(plugin,"LHC10c","LHC10f7"); // specify LHC period for anchor runs;  and the name of the MC production
   //totruns += AddGoodRuns(plugin,"LHC10d","LHC10f7"); // specify LHC period for anchor runs;  and the name of the MC production
   plugin->SetNrunsPerMaster(totruns);
   */
   //
   // Define alien work directory where all files will be copied. Relative to alien $HOME.
   plugin->SetGridWorkingDir("myHFanalysis");
   // Name of executable
   plugin->SetExecutable("myHFanalysis.sh");
   // Declare alien output directory. Relative to working directory.
   plugin->SetGridOutputDir("output"); // In this case will be $HOME/work/output
   // Declare the analysis source files names separated by blancs. To be compiled runtime
   // using ACLiC on the worker nodes.
   //plugin->SetAnalysisSource("AliDStarJets.cxx");
   // Declare all libraries (other than the default ones for the framework. These will be
   // loaded by the generated analysis macro. Add all extra files (task .cxx/.h) here.
   plugin->SetAdditionalLibs("libPWGflowBase.so libPWGflowTasks.so libPWGHFbase.so libPWGHFvertexingHF.so libGui.so libRAWDatabase.so libCDB.so libSTEER.so libTRDbase.so libPWGTRD.so");
   // use par files
   if(useParFiles) {
     plugin->EnablePackage("STEERBase.par");
     plugin->EnablePackage("ESD.par");
     plugin->EnablePackage("AOD.par");
     plugin->EnablePackage("ANALYSIS.par");
     plugin->EnablePackage("OADB.par");
     plugin->EnablePackage("ANALYSISalice.par");
     plugin->EnablePackage("CORRFW.par");
     plugin->EnablePackage("PWGHFbase.par");
     plugin->EnablePackage("PWGHFvertexingHF.par");
   }
   plugin->AddIncludePath("-I. -I$ROOTSYS/include -I$ALICE_ROOT -I$ALICE_ROOT/include -I$ALICE_ROOT/ITS -I$ALICE_ROOT/TPC -I$ALICE_ROOT/CONTAINERS -I$ALICE_ROOT/STEER/STEER -I$ALICE_ROOT/STEER/STEERBase -I$ALICE_ROOT/STEER/ESD -I$ALICE_ROOT/STEER/AOD -I$ALICE_ROOT/TRD -I$ALICE_ROOT/macros -I$ALICE_ROOT/ANALYSIS  -I$ALICE_ROOT/OADB -I$ALICE_ROOT/PWGHF -I$ALICE_ROOT/PWGHF/base -I$ALICE_ROOT/PWGHF/vertexingHF -I$ALICE_ROOT/PWG/FLOW/Base -I$ALICE_ROOT/PWG/FLOW/Tasks -I$ALICE_ROOT/PWG -g");

   plugin->SetDefaultOutputs(kTRUE);
   // merging via jdl
   plugin->SetMergeViaJDL(kTRUE);
   plugin->SetOneStageMerging(kFALSE);
   plugin->SetMaxMergeStages(2);

   // Optionally set a name for the generated analysis macro (default MyAnalysis.C)
   plugin->SetAnalysisMacro("AnalysisHF.C");
   // Optionally set maximum number of input files/subjob (default 100, put 0 to ignore)
   // Optionally modify the name of the generated JDL (default analysis.jdl)
   plugin->SetJDLName("TaskHF.jdl");

   return plugin;
}
Commit	Line	Data
8931206f	1	class AliAnalysisGrid;
54d54d1a	2	class AliAnalysisAlien;
8931206f	3
	4	void RunAnalysisAODVertexingHF()
	5	{
	6	//
	7	// Test macro for AliAnalysisTaskSE's for heavy-flavour candidates
	8	// It has the structure of a Analysis Train:
	9	// - in this macro, change things related to running mode
	10	// and input preparation
	11	// - add your task using a AddTaskXXX macro
	12	//
	13	// A.Dainese, andrea.dainese@lnl.infn.it
	14	// "grid" mode added by R.Bala, bala@to.infn.it
	15	//
	16
	17
da8287a2	18	gSystem->SetIncludePath("-I. -I$ROOTSYS/include -I$ALICE_ROOT -I$ALICE_ROOT/include -I$ALICE_ROOT/ITS -I$ALICE_ROOT/TPC -I$ALICE_ROOT/CONTAINERS -I$ALICE_ROOT/STEER/STEER -I$ALICE_ROOT/STEER/STEERBase -I$ALICE_ROOT/STEER/ESD -I$ALICE_ROOT/STEER/AOD -I$ALICE_ROOT/TRD -I$ALICE_ROOT/macros -I$ALICE_ROOT/ANALYSIS -I$ALICE_ROOT/OADB -I$ALICE_ROOT/PWGHF -I$ALICE_ROOT/PWGHF/base -I$ALICE_ROOT/PWGHF/vertexingHF -I$ALICE_ROOT/PWG/FLOW/Base -I$ALICE_ROOT/PWG/FLOW/Tasks -I$ALICE_ROOT/PWG -g");
8931206f	19	//
	20	TString trainName = "D2H";
	21	TString analysisMode = "grid"; // "local", "grid", or "proof"
	22	TString inputMode = "list"; // "list", "xml", or "dataset"
	23	Long64_t nentries=123567890,firstentry=0;
9124d874	24	Bool_t useParFiles=kFALSE;
8931206f	25	Bool_t useAlienPlugin=kTRUE;
7dc1b6b2	26	TString pluginmode="full";
4637c72d	27	TString testfileslistWithPlugin="";
8931206f	28	Bool_t saveProofToAlien=kFALSE;
8931206f	29	TString proofOutdir = "";
0694cdc8	30	TString loadMacroPath="$ALICE_ROOT/PWGHF/vertexingHF/macros/";
8931206f	31	//TString loadMacroPath="./"; // this is normally needed for CAF
	32	//
	33
	34	if(analysisMode=="grid") {
	35	// Connect to AliEn
	36	TGrid::Connect("alien://");
	37	} else if(analysisMode=="proof") {
	38	// Connect to the PROOF cluster
	39	if(inputMode!="dataset") {printf("Input mode must be dataset, for proof analysis\n"); return;}
	40	gEnv->SetValue("XSec.GSI.DelegProxy","2");
	41	TProof::Open("alicecaf");
	42	//TProof::Reset("alicecaf");
	43	if(saveProofToAlien) {
	44	TGrid::Connect("alien://");
	45	if(gGrid) {
	46	TString homedir = gGrid->GetHomeDirectory();
	47	TString workdir = homedir + trainName;
	48	if(!gGrid->Cd(workdir)) {
	49	gGrid->Cd(homedir);
	50	if(gGrid->Mkdir(workdir)) {
	51	gGrid->Cd(trainName);
	52	::Info("VertexingTrain::Connect()", "Directory %s created", gGrid->Pwd());
	53	}
	54	}
	55	gGrid->Mkdir("proof_output");
	56	gGrid->Cd("proof_output");
	57	proofOutdir = Form("alien://%s", gGrid->Pwd());
	58	}
	59	}
	60	}
	61
	62
	63	// AliRoot libraries
	64	if(analysisMode=="local" \|\| analysisMode=="grid") {
	65	TString loadLibraries="LoadLibraries.C"; loadLibraries.Prepend(loadMacroPath.Data());
	66	gROOT->LoadMacro(loadLibraries.Data());
	67	LoadLibraries(useParFiles);
4070f709	68	gSystem->Load("libGui");
	69	gSystem->Load("libRAWDatabase");
	70	gSystem->Load("libCDB");
	71	gSystem->Load("libSTEER");
	72	gSystem->Load("libTRDbase");
	73	gSystem->Load("libPWGTRD");
8931206f	74	} else if (analysisMode=="proof") {
4070f709	75	gSystem->Load("libTree");
	76	gSystem->Load("libGeom");
	77	gSystem->Load("libPhysics");
	78	gSystem->Load("libVMC");
	79	gSystem->Load("libMinuit");
	80	gSystem->Load("libGui");
	81	gSystem->Load("libRAWDatabase");
	82	gSystem->Load("libCDB");
	83	gSystem->Load("libSTEER");
	84	gSystem->Load("libTRDbase");
	85	gSystem->Load("libPWGTRD");
8931206f	86	// Enable the needed packages
	87	//gProof->ClearPackages();
	88	TString parDir="/afs/cern.ch/user/d/dainesea/code/";
	89	TString parFile;
	90	if(!useParFiles) {
	91	gProof->UploadPackage("AF-v4-17");
	92	gProof->EnablePackage("AF-v4-17");
0694cdc8	93	// --- Enable the PWGHFvertexingHF Package
0694cdc8	94	parFile="PWGHFvertexingHF.par"; parFile.Prepend(parDir.Data());
8931206f	95	gProof->UploadPackage(parFile.Data());
0694cdc8	96	gProof->EnablePackage("PWGHFvertexingHF");
8931206f	97	} else {
	98	// --- Enable the STEERBase Package
	99	parFile="STEERBase.par"; parFile.Prepend(parDir.Data());
	100	gProof->UploadPackage(parFile.Data());
	101	gProof->EnablePackage("STEERBase");
	102	// --- Enable the ESD Package
	103	parFile="ESD.par"; parFile.Prepend(parDir.Data());
	104	gProof->UploadPackage(parFile.Data());
	105	gProof->EnablePackage("ESD");
	106	// --- Enable the AOD Package
	107	parFile="AOD.par"; parFile.Prepend(parDir.Data());
	108	gProof->UploadPackage(parFile.Data());
	109	gProof->EnablePackage("AOD");
	110	// --- Enable the ANALYSIS Package
	111	parFile="ANALYSIS.par"; parFile.Prepend(parDir.Data());
	112	gProof->UploadPackage(parFile.Data());
	113	gProof->EnablePackage("ANALYSIS");
	114	// --- Enable the ANALYSISalice Package
	115	parFile="ANALYSISalice.par"; parFile.Prepend(parDir.Data());
	116	gProof->UploadPackage(parFile.Data());
	117	gProof->EnablePackage("ANALYSISalice");
	118	// --- Enable the CORRFW Package
	119	parFile="CORRFW.par"; parFile.Prepend(parDir.Data());
	120	gProof->UploadPackage(parFile.Data());
	121	gProof->EnablePackage("CORRFW");
0694cdc8	122	// --- Enable the PWGHFbase Package
0694cdc8	123	parFile="PWGHFbase.par"; parFile.Prepend(parDir.Data());
8931206f	124	gProof->UploadPackage(parFile.Data());
0694cdc8	125	gProof->EnablePackage("PWGHFbase");
	126	// --- Enable the PWGHFvertexingHF Package
	127	parFile="PWGHFvertexingHF.par"; parFile.Prepend(parDir.Data());
8931206f	128	gProof->UploadPackage(parFile.Data());
0694cdc8	129	gProof->EnablePackage("PWGHFvertexingHF");
8931206f	130	}
	131	gProof->ShowEnabledPackages(); // show a list of enabled packages
	132	}
	133
	134
	135	// Create Alien plugin, if requested
	136	if(useAlienPlugin) {
4637c72d	137	// if(analysisMode!="grid") {printf("Analysis mode must be grid, to use alien plugin\n"); return;}
4637c72d	138	AliAnalysisGrid *alienHandler = CreateAlienHandler(pluginmode,useParFiles,testfileslistWithPlugin);
8931206f	139	if(!alienHandler) return;
	140	}
	141
	142
	143	//-------------------------------------------------------------------
	144	// Prepare input
	145	TChain *chainAOD = 0;
	146	TString dataset; // for proof
	147
	148	if(!useAlienPlugin) {
cc3209fb	149	TString makeAODInputChain="../MakeAODInputChain.C"; makeAODInputChain.Prepend(loadMacroPath.Data());
8931206f	150	if(inputMode=="list") {
	151	// Local files
	152	gROOT->LoadMacro(makeAODInputChain.Data());
	153	chainAOD = MakeAODInputChain();// with this it reads ./AliAOD.root and ./AliAOD.VertexingHF.root
	154	//chainAOD = MakeAODInputChain("alien:///alice/cern.ch/user/r/rbala/newtrain/out_lhc08x/180100/",1,1);
	155	printf("ENTRIES %d\n",chainAOD->GetEntries());
	156	} else if(inputMode=="xml") {
	157	// xml
	158	gROOT->LoadMacro(makeAODInputChain.Data());
	159	chainAOD = MakeAODInputChain("collection_aod.xml","collection_aodHF.xml");
	160	} else if(inputMode=="dataset") {
	161	// CAF dataset
	162	//gProof->ShowDataSets();
	163	dataset="/ITS/dainesea/AODVertexingHF_LHC08x_180100";
	164	}
	165	}
	166
	167	// Create the analysis manager
	168	AliAnalysisManager *mgr = new AliAnalysisManager("My Manager","My Manager");
	169	mgr->SetDebugLevel(10);
	170	// Connect plug-in to the analysis manager
	171	if(useAlienPlugin) mgr->SetGridHandler(alienHandler);
	172
	173	// Input
5b37c6e5	174	AliAODInputHandler *inputHandler = new AliAODInputHandler("handler","handler for D2H");
8931206f	175	if(analysisMode=="proof" ) {
efb0a9e5	176	inputHandler->AddFriend("./AliAOD.VertexingHF.root");
efb0a9e5	177	//inputHandler->AddFriend("deltas/AliAOD.VertexingHF.root");
8931206f	178	if(saveProofToAlien) mgr->SetSpecialOutputLocation(proofOutdir);
	179	}
	180	mgr->SetInputEventHandler(inputHandler);
	181	//-------------------------------------------------------------------
	182
	183
	184	//-------------------------------------------------------------------
	185	// Analysis tasks (wagons of the train)
	186	//
b79bfc3e	187	// First add the task for the PID response setting
	188	gROOT->LoadMacro("$ALICE_ROOT/ANALYSIS/macros/AddTaskPIDResponse.C");
	189	AliAnalysisTaskSE *setupTask = AddTaskPIDResponse(kFALSE,kTRUE);
	190
da8287a2	191	gROOT->LoadMacro("$ALICE_ROOT/ANALYSIS/macros/AddTaskPIDqa.C");
47d08691	192	AliAnalysisTaskPIDqa *pidQA = AddTaskPIDqa();
	193
	194
8931206f	195	TString taskName;
	196
	197	////// ADD THE FULL D2H TRAIN
cc3209fb	198	/*taskName="../AddD2HTrain.C"; taskName.Prepend(loadMacroPath.Data());
8931206f	199	gROOT->LoadMacro(taskName.Data());
8931206f	200	Bool_t readMC=kFALSE;
efb0a9e5	201	AddD2HTrain(readMC);//,1,0,0,0,0,0,0,0,0,0,0);*/
8931206f	202
	203	////// OR ADD INDIVIDUAL TASKS
	204
da8287a2	205	taskName="AddTaskHFQA.C"; taskName.Prepend(loadMacroPath.Data());
	206	gROOT->LoadMacro(taskName.Data());
	207	AliAnalysisTaskSEHFQA *qaTask = AddTaskHFQA(0,"",kFALSE, kTRUE, 0 , "QApp",kTRUE,kTRUE,kFALSE, kTRUE, kFALSE,kTRUE);
	208
efb0a9e5	209	/* taskName="AddTaskCompareHF.C"; taskName.Prepend(loadMacroPath.Data());
8931206f	210	gROOT->LoadMacro(taskName.Data());
8931206f	211	AliAnalysisTaskSECompareHF *cmpTask = AddTaskCompareHF();
c1179c57	212	*/
8931206f	213	taskName="AddTaskD0Mass.C"; taskName.Prepend(loadMacroPath.Data());
	214	gROOT->LoadMacro(taskName.Data());
	215	AliAnalysisTaskSED0Mass *d0massTask = AddTaskD0Mass();
	216	AliAnalysisTaskSED0Mass *d0massLikeSignTask = AddTaskD0Mass(1);
efb0a9e5	217	/*
8931206f	218	taskName="AddTaskDplus.C"; taskName.Prepend(loadMacroPath.Data());
	219	gROOT->LoadMacro(taskName.Data());
	220	AliAnalysisTaskSEDplus *dplusTask = AddTaskDplus();
c1179c57	221
8931206f	222	taskName="AddTaskDs.C"; taskName.Prepend(loadMacroPath.Data());
	223	gROOT->LoadMacro(taskName.Data());
	224	AliAnalysisTaskSEDs *dsTask = AddTaskDs();
	225
	226	//taskName="AddTaskSelectHF.C"; taskName.Prepend(loadMacroPath.Data());
	227	//gROOT->LoadMacro(taskName.Data());
	228	//AliAnalysisTaskSESelectHF *seleTask = AddTaskSelectHF();
	229
	230	taskName="AddTaskBkgLikeSignD0.C"; taskName.Prepend(loadMacroPath.Data());
	231	gROOT->LoadMacro(taskName.Data());
	232	AliAnalysisTaskSEBkgLikeSignD0 *lsD0Task = AddTaskBkgLikeSignD0();
	233
8931206f	234	taskName="AddTaskCFMultiVarMultiStep.C"; taskName.Prepend(loadMacroPath.Data());
	235	gROOT->LoadMacro(taskName.Data());
	236	AliCFHeavyFlavourTaskMultiVarMultiStep *cfmvmsTask = AddTaskCFMultiVarMultiStep();
	237
e047b348	238
	239	taskName="AddTaskSECharmFraction.C";
	240	taskName.Prepend(loadMacroPath.Data());
8931206f	241	gROOT->LoadMacro(taskName.Data());
e047b348	242	Int_t switchMC[5]={0,0,0,0,0};
cc3209fb	243	Int_t ppPbPb=1;// 0 for pp, 1 for PbPb, used to siwtch on/off the removal of daughters from the primary vertex
cc3209fb	244	AliAnalysisTaskSECharmFraction *cFractTask = AddTaskSECharmFraction("standard",switchMC,readMC,kTRUE,kFALSE,"D0toKpiCharmFractCuts.root","c",ppPbPb);
e047b348	245	// arguments: filename,switchMC,readmc,usepid,likesign,cutfilename,containerprefix
cc3209fb	246
8931206f	247
	248	// attach a private task (not committed)
	249	// (the files MyTask.h MyTask.cxx AddMyTask.C have to be declared in plugin
	250	// configuration, see below)
	251
	252	if(analysisMode.Data()=="proof") {
	253	gProof->LoadMacro("MyTask.cxx++g");
	254	} else {
	255	gROOT->LoadMacro("MyTask.cxx++g");
	256	}
	257	gROOT->LoadMacro("AddMyTask.C");
	258	MyTask *myTask = AddMyTask();
	259
	260
	261	if(analysisMode.Data()=="proof") {
	262	gProof->LoadMacro("AliDStarJets.cxx++g");
	263	} else {
	264	gROOT->LoadMacro("AliDStarJets.cxx++g");
	265	}
	266	gROOT->LoadMacro("AddTaskDStarJets.C");
	267	AliDStarJets *myTask = AddTaskDStarJets();
	268	*/
	269	//-------------------------------------------------------------------
	270
	271	//
	272	// Run the analysis
	273	//
	274	if(chainAOD) printf("CHAIN HAS %d ENTRIES\n",(Int_t)chainAOD->GetEntries());
	275
	276	if(!mgr->InitAnalysis()) return;
	277	mgr->PrintStatus();
	278	if(analysisMode=="grid" && !useAlienPlugin) analysisMode="local";
	279	if(analysisMode!="proof") {
	280	mgr->StartAnalysis(analysisMode.Data(),chainAOD,nentries,firstentry);
	281	} else {
	282	// proof
	283	mgr->StartAnalysis(analysisMode.Data(),dataset.Data(),nentries,firstentry);
	284	}
	285
	286	return;
	287	}
	288	//_____________________________________________________________________________
	289	//
4637c72d	290	AliAnalysisGrid* CreateAlienHandler(TString pluginmode="test",Bool_t useParFiles=kFALSE, TString testfileslistWithPlugin="")
8931206f	291	{
	292	// Check if user has a valid token, otherwise make one. This has limitations.
	293	// One can always follow the standard procedure of calling alien-token-init then
	294	// source /tmp/gclient_env_$UID in the current shell.
8931206f	295	AliAnalysisAlien *plugin = new AliAnalysisAlien();
	296	// Set the run mode (can be "full", "test", "offline", "submit" or "terminate")
	297	plugin->SetRunMode(pluginmode.Data());
a9e59aee	298	plugin->SetUser();
8931206f	299	// Set versions of used packages
8931206f	300	plugin->SetAPIVersion("V1.1x");
a9e59aee	301	plugin->SetROOTVersion();
a9e59aee	302	plugin->SetAliROOTVersion();
c1179c57	303	plugin->SetNtestFiles(1);
0694cdc8	304	gROOT->LoadMacro("$ALICE_ROOT/PWGHF/vertexingHF/AddGoodRuns.C");
9be57b17	305
8931206f	306	// Declare input data to be processed.
4637c72d	307	//************************************************
	308	// Set data file list to test on local mode
	309	//************************************************
	310	plugin->SetFileForTestMode(testfileslistWithPlugin.Data());
	311
b9015c51	312	//************************************************
b9015c51	313	// Set data search pattern for DATA
c1179c57	314	//************************************************
c1179c57	315	//Method 1: To create automatically xml through plugin
9124d874	316	plugin->SetGridDataDir("/alice/data/2010/LHC10d"); // specify LHC period
9124d874	317	plugin->SetDataPattern("pass2/AOD018/*AliAOD.root"); // specify reco pass and AOD set
b2b62321	318	plugin->SetFriendChainName("./AliAOD.VertexingHF.root");
b9015c51	319	// OR plugin->SetFriendChainName("deltas/AliAOD.VertexingHF.root");
46627015	320	// Adds only the good runs from the Monalisa Run Condition Table
b9015c51	321	// More than one period can be added but the period name has to be removed from GridDataDir (to be tested)
b2b62321	322	Int_t totruns=0;
9124d874	323	//totruns += AddGoodRuns(plugin,"LHC10b"); // specify LHC period
b9015c51	324	//totruns += AddGoodRuns(plugin,"LHC10c"); // specify LHC period
9124d874	325	totruns += AddGoodRuns(plugin,"LHC10d"); // specify LHC period
b2b62321	326	plugin->SetNrunsPerMaster(totruns);
c1179c57	327
	328	// Method 2: Declare existing data files (e.g xml collections)
	329
	330	//plugin->AddDataFile("/alice/cern.ch/user/r/rbala/000168068_000170593.xml");
	331	// plugin->SetDataPattern("*AliAOD.root");
	332	// plugin->SetFriendChainName("./AliAOD.VertexingHF.root");
	333
b9015c51	334	//************************************************
	335	// Set data search pattern for MONTECARLO
	336	//************************************************
9124d874	337	/*
b2b62321	338	plugin->SetGridDataDir("/alice/sim/LHC10d3"); // specify MC sample
b2b62321	339	plugin->SetDataPattern("AOD005/*AliAOD.root"); // specify AOD set
b9015c51	340	plugin->SetFriendChainName("./AliAOD.VertexingHF.root");
	341	// OR plugin->SetFriendChainName("deltas/AliAOD.VertexingHF.root");
	342	// Adds only the good runs from the Monalisa Run Condition Table
	343	// More than one period can be added!
	344	Int_t totruns=0;
b2b62321	345	totruns += AddGoodRuns(plugin,"LHC10b","LHC10d3"); // specify LHC period for anchor runs; and the name of the MC production
	346	//totruns += AddGoodRuns(plugin,"LHC10c","LHC10f7"); // specify LHC period for anchor runs; and the name of the MC production
	347	//totruns += AddGoodRuns(plugin,"LHC10d","LHC10f7"); // specify LHC period for anchor runs; and the name of the MC production
b9015c51	348	plugin->SetNrunsPerMaster(totruns);
9124d874	349	*/
b9015c51	350	//
8931206f	351	// Define alien work directory where all files will be copied. Relative to alien $HOME.
8931206f	352	plugin->SetGridWorkingDir("myHFanalysis");
c1179c57	353	// Name of executable
efc42c41	354	plugin->SetExecutable("myHFanalysis.sh");
8931206f	355	// Declare alien output directory. Relative to working directory.
	356	plugin->SetGridOutputDir("output"); // In this case will be $HOME/work/output
	357	// Declare the analysis source files names separated by blancs. To be compiled runtime
	358	// using ACLiC on the worker nodes.
	359	//plugin->SetAnalysisSource("AliDStarJets.cxx");
	360	// Declare all libraries (other than the default ones for the framework. These will be
	361	// loaded by the generated analysis macro. Add all extra files (task .cxx/.h) here.
da8287a2	362	plugin->SetAdditionalLibs("libPWGflowBase.so libPWGflowTasks.so libPWGHFbase.so libPWGHFvertexingHF.so libGui.so libRAWDatabase.so libCDB.so libSTEER.so libTRDbase.so libPWGTRD.so");
8931206f	363	// use par files
	364	if(useParFiles) {
	365	plugin->EnablePackage("STEERBase.par");
	366	plugin->EnablePackage("ESD.par");
	367	plugin->EnablePackage("AOD.par");
	368	plugin->EnablePackage("ANALYSIS.par");
1b575730	369	plugin->EnablePackage("OADB.par");
8931206f	370	plugin->EnablePackage("ANALYSISalice.par");
8931206f	371	plugin->EnablePackage("CORRFW.par");
0694cdc8	372	plugin->EnablePackage("PWGHFbase.par");
0694cdc8	373	plugin->EnablePackage("PWGHFvertexingHF.par");
8931206f	374	}
da8287a2	375	plugin->AddIncludePath("-I. -I$ROOTSYS/include -I$ALICE_ROOT -I$ALICE_ROOT/include -I$ALICE_ROOT/ITS -I$ALICE_ROOT/TPC -I$ALICE_ROOT/CONTAINERS -I$ALICE_ROOT/STEER/STEER -I$ALICE_ROOT/STEER/STEERBase -I$ALICE_ROOT/STEER/ESD -I$ALICE_ROOT/STEER/AOD -I$ALICE_ROOT/TRD -I$ALICE_ROOT/macros -I$ALICE_ROOT/ANALYSIS -I$ALICE_ROOT/OADB -I$ALICE_ROOT/PWGHF -I$ALICE_ROOT/PWGHF/base -I$ALICE_ROOT/PWGHF/vertexingHF -I$ALICE_ROOT/PWG/FLOW/Base -I$ALICE_ROOT/PWG/FLOW/Tasks -I$ALICE_ROOT/PWG -g");
a9e59aee	376
8931206f	377	plugin->SetDefaultOutputs(kTRUE);
9a36a6cc	378	// merging via jdl
	379	plugin->SetMergeViaJDL(kTRUE);
	380	plugin->SetOneStageMerging(kFALSE);
	381	plugin->SetMaxMergeStages(2);
	382
8931206f	383	// Optionally set a name for the generated analysis macro (default MyAnalysis.C)
	384	plugin->SetAnalysisMacro("AnalysisHF.C");
	385	// Optionally set maximum number of input files/subjob (default 100, put 0 to ignore)
8931206f	386	// Optionally modify the name of the generated JDL (default analysis.jdl)
8931206f	387	plugin->SetJDLName("TaskHF.jdl");
8931206f	388
	389	return plugin;
	390	}