PWGUD/macros/genLevelSimulation/runTaskProof.C

   1 void runTaskProof(const char * dataset, const char * datasetpath="/COMMON/COMMON/", const char * outdir="") {
   2   gEnv->SetValue("XSec.GSI.DelegProxy","2");
   3   TProof::Open("alice-caf","workers=1x");
   4   gProof->EnablePackage("VO_ALICE@AliRoot::v4-21-33-AN");
   5
   6   //  gSystem->AddIncludePath("-I${ALICE_ROOT}/include/ -I${ALICE_ROOT}/PWG0/ -I${ALICE_ROOT}/PWG0/dNdEta/");
   7   // gSystem->AddIncludePath("-I${ALICE_ROOT}/include/");
   8   // gProof->UploadPackage("$ALICE_ROOT/STEERBase");
   9   // gProof->EnablePackage("$ALICE_ROOT/STEERBase");
  10   // gProof->UploadPackage("$ALICE_ROOT/ESD");
  11   // gProof->EnablePackage("$ALICE_ROOT/ESD");
  12   // gProof->UploadPackage("$ALICE_ROOT/AOD");
  13   // gProof->EnablePackage("$ALICE_ROOT/AOD");
  14   // gProof->UploadPackage("$ALICE_ROOT/ANALYSIS");
  15   // gProof->EnablePackage("$ALICE_ROOT/ANALYSIS");
  16   // gProof->UploadPackage("$ALICE_ROOT/ANALYSISalice");
  17   // gProof->EnablePackage("$ALICE_ROOT/ANALYSISalice");
  18
  19
  20     // Make the analysis manager
  21   AliAnalysisManager *mgr = new AliAnalysisManager("TestManager");
  22   //AliVEventHandler *esdH = new AliESDInputHandler();
  23   AliESDInputHandler* esdH = new AliESDInputHandler();
  24   //esdH->SetActiveBranches("ESDfriend");
  25   mgr->SetInputEventHandler(esdH);
  26
  27   AliMCEventHandler *mc = new AliMCEventHandler();
  28   mc->SetReadTR(kFALSE);
  29   mgr->SetMCtruthEventHandler(mc);
  30
  31   // assign simple task
  32   gProof->Load(gSystem->ExpandPathName("$(ALICE_ROOT)/PWG0/genLevelSimulation/AliAnalysisTaskdNdetaMC.cxx+g"));
  33   AliAnalysisTask *task = new AliAnalysisTaskdNdetaMC("TaskdNdeta");
  34   mgr->AddTask(task);
  35
  36   char outfname[1000];
  37   sprintf(outfname, "dndeta_%s.root",dataset);
  38
  39   // Create containers for input/output
  40   AliAnalysisDataContainer *cinput1 = mgr->GetCommonInputContainer();
  41
  42   AliAnalysisDataContainer *coutput1 = mgr->CreateContainer("clist1",TList::Class(),
  43                                                             AliAnalysisManager::kOutputContainer,outfname);
  44
  45   mgr->ConnectInput(task,0,cinput1);
  46   mgr->ConnectOutput(task,1,coutput1);
  47
  48   if (!mgr->InitAnalysis()) return;
  49
  50   mgr->PrintStatus();
  51   mgr->StartAnalysis("proof",Form("%s%s#TE",datasetpath,dataset),5000);
  52   // mgr->StartAnalysis("proof",Form("%s%s#TE",datasetpath,dataset),5000);
  53   //  mgr->StartAnalysis("proof","/COMMON/COMMON/LHC09b14_7TeV_0.5T_Phojet#esdTree");
  54
  55   if (!strcmp(outdir,"")){
  56     gSystem->Exec(Form("mv %s %s", outfname, outdir));
  57   }
  58
  59 }