[u/mrichter/AliRoot.git] / PWGPP / macros / runAnalysisTaskITSTPCalignment.C

void runAnalysisTaskITSTPCalignment()
{
  TStopwatch timer;
  timer.Start();

  //runProof("/ITS/dainesea/run104070#esdTree");
  //runProof("/ITS/dainesea/run104070_newTPCalign#esdTree");
  //runProof("/ALIREC/aliprod/run104671#esdTree");
  //runProof("/ITS/dainesea/run104070_newTPCcalib#esdTree");
  //runProof("/COMMON/COMMON/LHC09d9a_0.9TeV_0.5T#esdTree");
  //runLocal("find /data/alice3/mikolaj/runs_pp/pass1/ -name AliESDs.root","tree");
  //runLocal("find /data/alice3/mikolaj/ITSmisal -path */0.001/* -name AliESDs.root","tree");
  //runLocal("find /data/alice3/mikolaj/TPCfullmisalignmentB0 -name AliESDs.root","tree");
  //runLocal("find /data/alice3/mikolaj/TPCfullmisalignmentB5/ -name AliESDs.root -path \"*187824*\" ","tree");
  //runLocal("find /data/alice3/mikolaj/TPCfullmisalignmentB5/ -name AliESDs.root","tree");
  runLocal("fileList");
  //runAlienPlugin("terminate");

  timer.Stop();
  timer.Print();
}

//______________________________________________________________________________
void runLocal(TString inputFile = "fileList", TString options="")
{

  TString outputFilename = "outputITSTPCalignment.root";

  gSystem->Load("libCore");
  gSystem->Load("libTree");
  gSystem->Load("libGeom");
  gSystem->Load("libVMC");
  gSystem->Load("libXMLIO");
  gSystem->Load("libPhysics");
  gSystem->Load("libXMLParser");
  gSystem->Load("libProof");
  gSystem->Load("libMinuit");
  gSystem->Load("libSTEERBase");
  gSystem->Load("libCDB");
  gSystem->Load("libRAWDatabase");
  gSystem->Load("libRAWDatarec");
  gSystem->Load("libESD");
  gSystem->Load("libAOD");
  gSystem->Load("libSTEER");
  gSystem->Load("libANALYSIS");
  gSystem->Load("libANALYSISalice");
  gSystem->Load("libSTAT");
  gSystem->Load("libTPCbase");
  gSystem->Load("libTPCrec");
  gSystem->Load("libITSbase");
  gSystem->Load("libITSrec");
  gSystem->Load("libTRDbase");
  gSystem->Load("libTRDrec");
  gSystem->Load("libVZERObase");
  gSystem->Load("libVZEROrec");
  gSystem->Load("libHMPIDbase");
  gSystem->Load("libTENDER");
  gSystem->Load("libTENDERSupplies");
  gSystem->Load("libPWGPP");

  gSystem->AddIncludePath("-I$ALICE_ROOT/include");
  //gROOT->LoadMacro("AliRelAlignerKalman.cxx++");
  //gROOT->LoadMacro("AliRelAlignerKalmanArray.cxx++g");
  //gROOT->LoadMacro("AliAnalysisTaskITSTPCalignment.cxx++g");
  gROOT->LoadMacro("AddTaskITSTPCalignment.C");

  gROOT->LoadMacro("$ALICE_ROOT/PWG0/CreateESDChain.C");
  TChain* chain = CreateESDChain(inputFile,100000);

  // analysis manager
  AliAnalysisManager *mgr = new AliAnalysisManager("ITSTPCalignmentAnalysisManager");

  // input handlers
  AliESDInputHandler* esdH = new AliESDInputHandler();
  esdH->SetReadFriends(kTRUE);
  esdH->SetInactiveBranches("Calo FMD");
  mgr->SetInputEventHandler(esdH);
  
  //AliMCEventHandler* MCH = new AliMCEventHandler();
  //mgr->SetMCtruthEventHandler(MCH);

  //add the task
  AliAnalysisTaskITSTPCalignment *task = AddTaskITSTPCalignment();

  //start analysis
  if (!mgr->InitAnalysis()) return;
  mgr->PrintStatus();

  mgr->StartAnalysis("local",chain);
}

//______________________________________________________________________________
void runProof(const char* dataset, TString options="" )
{

  TString outputFilename = "outputITSTPCalignment.root";

  printf("****** Connect to PROOF *******\n");
  gEnv->SetValue("XSec.GSI.DelegProxy","2");
  TProof::Open("mkrzewic@alicecaf.cern.ch");
  //gProof->SetParallel();
  gProof->ClearPackages();

  // Enable the Analysis Package
  gProof->UploadPackage("STEERBase.par");
  gProof->EnablePackage("STEERBase");
  gProof->UploadPackage("ESD.par");
  gProof->EnablePackage("ESD");
  gProof->UploadPackage("AOD.par");
  gProof->EnablePackage("AOD");
  gProof->UploadPackage("ANALYSIS.par");
  gProof->EnablePackage("ANALYSIS");
  gProof->UploadPackage("ANALYSISalice.par");
  gProof->EnablePackage("ANALYSISalice");
  gProof->UploadPackage("CORRFW.par");
  gProof->EnablePackage("CORRFW");

  //gProof->UploadPackage("/afs/cern.ch/alice/caf/sw/ALICE/PARs/v4-18-12-AN/AF-v4-18-12-AN");
  //gProof->EnablePackage("/afs/cern.ch/alice/caf/sw/ALICE/PARs/v4-18-12-AN/AF-v4-18-12-AN");

  gProof->Load("AliRelAlignerKalman.cxx++g");
  gProof->Load("AliRelAlignerKalmanArray.cxx++g");
  gProof->Load("AliAnalysisTaskITSTPCalignment.cxx++g");
  gProof->Load("AddTaskITSTPCalignment.C");

  // analysis manager
  AliAnalysisManager *mgr = new AliAnalysisManager("ITSTPCalignmentAnalysisManager");

  // input handlers
  AliVEventHandler* esdH = new AliESDInputHandler();
  ((AliESDInputHandler*)esdH)->SetReadFriends(kTRUE);
  mgr->SetInputEventHandler(esdH);

  //add the task
  AliAnalysisTaskITSTPCalignment *task = AddTaskITSTPCalignment();

  //start analysis
  if (!mgr->InitAnalysis()) return;
  mgr->PrintStatus();

  mgr->StartAnalysis("proof",dataset,10000,0);
}

//______________________________________________________________________________
void runAlienPlugin(const char* pluginmode="full")
{
  //must be configured in CreateAlienHandler.C file

  TString outputFilename = "outputITSTPCalignment.root";

  // Load common libraries
  gSystem->Load("libCore");
  gSystem->Load("libTree");
  gSystem->Load("libGeom");
  gSystem->Load("libVMC");
  gSystem->Load("libXMLIO");
  gSystem->Load("libPhysics");
  gSystem->Load("libXMLParser");
  gSystem->Load("libProof");
  gSystem->Load("libMinuit");
  gSystem->Load("libSTEERBase");
  gSystem->Load("libCDB");
  gSystem->Load("libRAWDatabase");
  gSystem->Load("libRAWDatarec");
  gSystem->Load("libESD");
  gSystem->Load("libAOD");
  gSystem->Load("libSTEER");
  gSystem->Load("libANALYSIS");
  gSystem->Load("libANALYSISalice");
  gSystem->Load("libSTAT");
  gSystem->Load("libTPCbase");
  gSystem->Load("libTPCrec");
  gSystem->Load("libITSbase");
  gSystem->Load("libITSrec");
  gSystem->Load("libTRDbase");
  gSystem->Load("libTRDrec");
  gSystem->Load("libVZERObase");
  gSystem->Load("libVZEROrec");
  gSystem->Load("libHMPIDbase");
  gSystem->Load("libTENDER");
  gSystem->Load("libTENDERSupplies");
  gSystem->Load("libPWGPP");

  // Use AliRoot includes to compile our task
  gSystem->AddIncludePath("-I$ALICE_ROOT/include");

  /////////////////////////////////////////////////////////////////////////////////////////////
  /////////////////////////////////////////////////////////////////////////////////////////////
  /////////////////////////////////////////////////////////////////////////////////////////////
  // Create and configure the alien handler plugin
  // 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.
  if (!AliAnalysisGrid::CreateToken()) return NULL;
  AliAnalysisAlien *plugin = new AliAnalysisAlien();
  // Set the run mode (can be "full", "test", "offline", "submit" or "terminate")
  plugin->SetRunMode(pluginmode);
  // Set versions of used packages
  plugin->SetAPIVersion("V1.1x");
  plugin->SetROOTVersion("v5-26-00b-4");
  plugin->SetAliROOTVersion("v4-19-11-AN");
  // Declare input data to be processed.
  // Method 1: Create automatically XML collections using alien 'find' command.
  // Define production directory LFN
  plugin->SetGridDataDir("/alice/data/2010/LHC10b");
  // Set data search pattern
  plugin->SetDataPattern("*/pass1/*AliESDs.root");
  // ...then add run numbers to be considered
  plugin->SetRunPrefix("000");
  plugin->AddRunNumber(117222);
  plugin->AddRunNumber(117220);
  plugin->AddRunNumber(117112);
  plugin->AddRunNumber(117099);
  plugin->AddRunNumber(117048);
  plugin->AddRunNumber(117048);
  plugin->AddRunNumber(116288);
  plugin->AddRunNumber(115322);
  plugin->AddRunNumber(114931);
  //plugin->AddRunNumber(117051);
  //plugin->SetRunRange(117029,117121);
  // Method 2: Declare existing data files (raw collections, xml collections, root file)
  // If no path mentioned data is supposed to be in the work directory (see SetGridWorkingDir())
  // XML collections added via this method can be combined with the first method if
  // the content is compatible (using or not tags)
  //   plugin->AddDataFile("/alice/cern.ch/user/m/mkrzewic/pp2009pass2.xml");
  //   plugin->AddDataFile("/alice/data/2008/LHC08c/000057657/raw/Run57657.Merged.RAW.tag.root");
  // Define alien work directory where all files will be copied. Relative to alien $HOME.
  plugin->SetGridWorkingDir("analysisGridLHC10bPass1_3runs");
  // 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("AliRelAlignerKalman.cxx AliRelAlignerKalmanArray.cxx AliAnalysisTaskITSTPCalignment.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("AliRelAlignerKalman.h AliRelAlignerKalman.cxx AliRelAlignerKalmanArray.h AliRelAlignerKalmanArray.cxx AliAnalysisTaskITSTPCalignment.h AliAnalysisTaskITSTPCalignment.cxx");// AddTaskITSTPCalignment.C");
  // Declare the output file names separated by blancs.
  // (can be like: file.root or file.root@ALICE::Niham::File)
  plugin->SetOutputFiles("outputITSTPCalignment.root");
  // Optionally define the files to be archived.
  //   plugin->SetOutputArchive("log_archive.zip:stdout,stderr@ALICE::NIHAM::File root_archive.zip:*.root@ALICE::NIHAM::File");
  plugin->SetOutputArchive("log_archive.zip:stdout,stderr");
  // Optionally set a name for the generated analysis macro (default MyAnalysis.C)
  plugin->SetAnalysisMacro("AnalysisITSTPCalignmentGenerated.C");
  // Optionally set maximum number of input files/subjob (default 100, put 0 to ignore)
  plugin->SetSplitMaxInputFileNumber(20);
  // Optionally set number of failed jobs that will trigger killing waiting sub-jobs.
  plugin->SetMaxInitFailed(5);
  // Optionally resubmit threshold.
  plugin->SetMasterResubmitThreshold(90);
  // Optionally set time to live (default 30000 sec)
  plugin->SetTTL(100000);
  // Optionally set input format (default xml-single)
  plugin->SetInputFormat("xml-single");
  // Optionally modify the name of the generated JDL (default analysis.jdl)
  plugin->SetJDLName("taskITSTPCalignment.jdl");
  // Optionally modify job price (default 1)
  plugin->SetPrice(1);
  // Optionally modify split mode (default 'se')
  plugin->SetSplitMode("se");
  /////////////////////////////////////////////////////////////////////////////////////////////
  /////////////////////////////////////////////////////////////////////////////////////////////
  /////////////////////////////////////////////////////////////////////////////////////////////

  // analysis manager
  AliAnalysisManager *mgr = new AliAnalysisManager("ITSTPCalignmentAnalysisManager");

  // input handlers
  mgr->SetGridHandler(plugin);

  //input handler
  AliESDInputHandler* esdH = new AliESDInputHandler();
  esdH->SetInactiveBranches("Calo FMD");
  esdH->SetReadFriends(kTRUE);
  mgr->SetInputEventHandler(esdH);

  gROOT->LoadMacro("AddTaskITSTPCalignment.C");

  //add the task
  AliAnalysisTaskITSTPCalignment *task = AddTaskITSTPCalignment();

  //mgr->SetDebugLevel(2);

  if (!mgr->InitAnalysis()) return;
  mgr->PrintStatus();
  mgr->StartAnalysis("grid");
}

//______________________________________________________________________________
Int_t setupPar(const char* pararchivename)
{
  ///////////////////
  // Setup PAR File//
  ///////////////////
  if (pararchivename)
  {
    char processline[1024];
    sprintf(processline,".! tar xvzf %s.par",pararchivename);
    gROOT->ProcessLine(processline);
    const char* ocwd = gSystem->WorkingDirectory();
    gSystem->ChangeDirectory(pararchivename);

    // check for BUILD.sh and execute
    if (!gSystem->AccessPathName("PROOF-INF/BUILD.sh"))
    {
      printf("*******************************\n");
      printf("*** Building PAR archive    ***\n");
      printf("*******************************\n");

      if (gSystem->Exec("PROOF-INF/BUILD.sh"))
      {
        Error("runAnalysis","Cannot Build the PAR Archive! - Abort!");
        return -1;
      }
    }
    // check for SETUP.C and execute
    if (!gSystem->AccessPathName("PROOF-INF/SETUP.C"))
    {
      printf("*******************************\n");
      printf("*** Setup PAR archive       ***\n");
      printf("*******************************\n");
      gROOT->Macro("PROOF-INF/SETUP.C");
    }

    gSystem->ChangeDirectory("../");
  }
  return 1;
}
Commit	Line	Data
51cfc50d	1	void runAnalysisTaskITSTPCalignment()
	2	{
	3	TStopwatch timer;
	4	timer.Start();
	5
	6	//runProof("/ITS/dainesea/run104070#esdTree");
	7	//runProof("/ITS/dainesea/run104070_newTPCalign#esdTree");
	8	//runProof("/ALIREC/aliprod/run104671#esdTree");
	9	//runProof("/ITS/dainesea/run104070_newTPCcalib#esdTree");
	10	//runProof("/COMMON/COMMON/LHC09d9a_0.9TeV_0.5T#esdTree");
	11	//runLocal("find /data/alice3/mikolaj/runs_pp/pass1/ -name AliESDs.root","tree");
	12	//runLocal("find /data/alice3/mikolaj/ITSmisal -path /0.001/ -name AliESDs.root","tree");
	13	//runLocal("find /data/alice3/mikolaj/TPCfullmisalignmentB0 -name AliESDs.root","tree");
	14	//runLocal("find /data/alice3/mikolaj/TPCfullmisalignmentB5/ -name AliESDs.root -path \"187824\" ","tree");
	15	//runLocal("find /data/alice3/mikolaj/TPCfullmisalignmentB5/ -name AliESDs.root","tree");
20ef1093	16	runLocal("fileList");
20ef1093	17	//runAlienPlugin("terminate");
51cfc50d	18
	19	timer.Stop();
	20	timer.Print();
	21	}
	22
	23	//______________________________________________________________________________
20ef1093	24	void runLocal(TString inputFile = "fileList", TString options="")
51cfc50d	25	{
	26
	27	TString outputFilename = "outputITSTPCalignment.root";
	28
20ef1093	29	gSystem->Load("libCore");
	30	gSystem->Load("libTree");
	31	gSystem->Load("libGeom");
	32	gSystem->Load("libVMC");
	33	gSystem->Load("libXMLIO");
	34	gSystem->Load("libPhysics");
	35	gSystem->Load("libXMLParser");
	36	gSystem->Load("libProof");
	37	gSystem->Load("libMinuit");
51cfc50d	38	gSystem->Load("libSTEERBase");
20ef1093	39	gSystem->Load("libCDB");
	40	gSystem->Load("libRAWDatabase");
	41	gSystem->Load("libRAWDatarec");
51cfc50d	42	gSystem->Load("libESD");
51cfc50d	43	gSystem->Load("libAOD");
20ef1093	44	gSystem->Load("libSTEER");
51cfc50d	45	gSystem->Load("libANALYSIS");
20ef1093	46	gSystem->Load("libANALYSISalice");
	47	gSystem->Load("libSTAT");
	48	gSystem->Load("libTPCbase");
	49	gSystem->Load("libTPCrec");
	50	gSystem->Load("libITSbase");
	51	gSystem->Load("libITSrec");
	52	gSystem->Load("libTRDbase");
	53	gSystem->Load("libTRDrec");
	54	gSystem->Load("libVZERObase");
	55	gSystem->Load("libVZEROrec");
	56	gSystem->Load("libHMPIDbase");
	57	gSystem->Load("libTENDER");
	58	gSystem->Load("libTENDERSupplies");
2bfe5463	59	gSystem->Load("libPWGPP");
51cfc50d	60
51cfc50d	61	gSystem->AddIncludePath("-I$ALICE_ROOT/include");
20ef1093	62	//gROOT->LoadMacro("AliRelAlignerKalman.cxx++");
	63	//gROOT->LoadMacro("AliRelAlignerKalmanArray.cxx++g");
	64	//gROOT->LoadMacro("AliAnalysisTaskITSTPCalignment.cxx++g");
51cfc50d	65	gROOT->LoadMacro("AddTaskITSTPCalignment.C");
51cfc50d	66
20ef1093	67	gROOT->LoadMacro("$ALICE_ROOT/PWG0/CreateESDChain.C");
20ef1093	68	TChain* chain = CreateESDChain(inputFile,100000);
51cfc50d	69
	70	// analysis manager
	71	AliAnalysisManager *mgr = new AliAnalysisManager("ITSTPCalignmentAnalysisManager");
	72
	73	// input handlers
20ef1093	74	AliESDInputHandler* esdH = new AliESDInputHandler();
	75	esdH->SetReadFriends(kTRUE);
	76	esdH->SetInactiveBranches("Calo FMD");
51cfc50d	77	mgr->SetInputEventHandler(esdH);
	78
	79	//AliMCEventHandler* MCH = new AliMCEventHandler();
	80	//mgr->SetMCtruthEventHandler(MCH);
	81
	82	//add the task
	83	AliAnalysisTaskITSTPCalignment *task = AddTaskITSTPCalignment();
	84
	85	//start analysis
	86	if (!mgr->InitAnalysis()) return;
	87	mgr->PrintStatus();
	88
	89	mgr->StartAnalysis("local",chain);
	90	}
	91
	92	//______________________________________________________________________________
	93	void runProof(const char* dataset, TString options="" )
	94	{
	95
	96	TString outputFilename = "outputITSTPCalignment.root";
	97
	98	printf("**** Connect to PROOF *****\n");
	99	gEnv->SetValue("XSec.GSI.DelegProxy","2");
	100	TProof::Open("mkrzewic@alicecaf.cern.ch");
	101	//gProof->SetParallel();
	102	gProof->ClearPackages();
	103
	104	// Enable the Analysis Package
	105	gProof->UploadPackage("STEERBase.par");
	106	gProof->EnablePackage("STEERBase");
	107	gProof->UploadPackage("ESD.par");
	108	gProof->EnablePackage("ESD");
	109	gProof->UploadPackage("AOD.par");
	110	gProof->EnablePackage("AOD");
	111	gProof->UploadPackage("ANALYSIS.par");
	112	gProof->EnablePackage("ANALYSIS");
	113	gProof->UploadPackage("ANALYSISalice.par");
	114	gProof->EnablePackage("ANALYSISalice");
	115	gProof->UploadPackage("CORRFW.par");
	116	gProof->EnablePackage("CORRFW");
	117
	118	//gProof->UploadPackage("/afs/cern.ch/alice/caf/sw/ALICE/PARs/v4-18-12-AN/AF-v4-18-12-AN");
	119	//gProof->EnablePackage("/afs/cern.ch/alice/caf/sw/ALICE/PARs/v4-18-12-AN/AF-v4-18-12-AN");
	120
	121	gProof->Load("AliRelAlignerKalman.cxx++g");
	122	gProof->Load("AliRelAlignerKalmanArray.cxx++g");
	123	gProof->Load("AliAnalysisTaskITSTPCalignment.cxx++g");
	124	gProof->Load("AddTaskITSTPCalignment.C");
	125
	126	// analysis manager
	127	AliAnalysisManager *mgr = new AliAnalysisManager("ITSTPCalignmentAnalysisManager");
	128
	129	// input handlers
	130	AliVEventHandler* esdH = new AliESDInputHandler();
20ef1093	131	((AliESDInputHandler*)esdH)->SetReadFriends(kTRUE);
51cfc50d	132	mgr->SetInputEventHandler(esdH);
	133
	134	//add the task
	135	AliAnalysisTaskITSTPCalignment *task = AddTaskITSTPCalignment();
	136
	137	//start analysis
	138	if (!mgr->InitAnalysis()) return;
	139	mgr->PrintStatus();
	140
	141	mgr->StartAnalysis("proof",dataset,10000,0);
	142	}
	143
	144	//______________________________________________________________________________
	145	void runAlienPlugin(const char* pluginmode="full")
	146	{
	147	//must be configured in CreateAlienHandler.C file
	148
	149	TString outputFilename = "outputITSTPCalignment.root";
	150
	151	// Load common libraries
20ef1093	152	gSystem->Load("libCore");
	153	gSystem->Load("libTree");
	154	gSystem->Load("libGeom");
	155	gSystem->Load("libVMC");
	156	gSystem->Load("libXMLIO");
	157	gSystem->Load("libPhysics");
	158	gSystem->Load("libXMLParser");
	159	gSystem->Load("libProof");
	160	gSystem->Load("libMinuit");
51cfc50d	161	gSystem->Load("libSTEERBase");
20ef1093	162	gSystem->Load("libCDB");
	163	gSystem->Load("libRAWDatabase");
	164	gSystem->Load("libRAWDatarec");
51cfc50d	165	gSystem->Load("libESD");
51cfc50d	166	gSystem->Load("libAOD");
20ef1093	167	gSystem->Load("libSTEER");
51cfc50d	168	gSystem->Load("libANALYSIS");
20ef1093	169	gSystem->Load("libANALYSISalice");
	170	gSystem->Load("libSTAT");
	171	gSystem->Load("libTPCbase");
	172	gSystem->Load("libTPCrec");
	173	gSystem->Load("libITSbase");
	174	gSystem->Load("libITSrec");
	175	gSystem->Load("libTRDbase");
	176	gSystem->Load("libTRDrec");
	177	gSystem->Load("libVZERObase");
	178	gSystem->Load("libVZEROrec");
	179	gSystem->Load("libHMPIDbase");
	180	gSystem->Load("libTENDER");
	181	gSystem->Load("libTENDERSupplies");
2bfe5463	182	gSystem->Load("libPWGPP");
51cfc50d	183
	184	// Use AliRoot includes to compile our task
	185	gSystem->AddIncludePath("-I$ALICE_ROOT/include");
	186
	187	/////////////////////////////////////////////////////////////////////////////////////////////
	188	/////////////////////////////////////////////////////////////////////////////////////////////
	189	/////////////////////////////////////////////////////////////////////////////////////////////
	190	// Create and configure the alien handler plugin
	191	// Check if user has a valid token, otherwise make one. This has limitations.
	192	// One can always follow the standard procedure of calling alien-token-init then
	193	// source /tmp/gclient_env_$UID in the current shell.
	194	if (!AliAnalysisGrid::CreateToken()) return NULL;
	195	AliAnalysisAlien *plugin = new AliAnalysisAlien();
	196	// Set the run mode (can be "full", "test", "offline", "submit" or "terminate")
	197	plugin->SetRunMode(pluginmode);
	198	// Set versions of used packages
	199	plugin->SetAPIVersion("V1.1x");
	200	plugin->SetROOTVersion("v5-26-00b-4");
	201	plugin->SetAliROOTVersion("v4-19-11-AN");
	202	// Declare input data to be processed.
	203	// Method 1: Create automatically XML collections using alien 'find' command.
	204	// Define production directory LFN
	205	plugin->SetGridDataDir("/alice/data/2010/LHC10b");
	206	// Set data search pattern
	207	plugin->SetDataPattern("/pass1/AliESDs.root");
	208	// ...then add run numbers to be considered
	209	plugin->SetRunPrefix("000");
	210	plugin->AddRunNumber(117222);
	211	plugin->AddRunNumber(117220);
	212	plugin->AddRunNumber(117112);
	213	plugin->AddRunNumber(117099);
	214	plugin->AddRunNumber(117048);
	215	plugin->AddRunNumber(117048);
	216	plugin->AddRunNumber(116288);
	217	plugin->AddRunNumber(115322);
	218	plugin->AddRunNumber(114931);
	219	//plugin->AddRunNumber(117051);
	220	//plugin->SetRunRange(117029,117121);
	221	// Method 2: Declare existing data files (raw collections, xml collections, root file)
	222	// If no path mentioned data is supposed to be in the work directory (see SetGridWorkingDir())
	223	// XML collections added via this method can be combined with the first method if
	224	// the content is compatible (using or not tags)
	225	// plugin->AddDataFile("/alice/cern.ch/user/m/mkrzewic/pp2009pass2.xml");
	226	// plugin->AddDataFile("/alice/data/2008/LHC08c/000057657/raw/Run57657.Merged.RAW.tag.root");
	227	// Define alien work directory where all files will be copied. Relative to alien $HOME.
	228	plugin->SetGridWorkingDir("analysisGridLHC10bPass1_3runs");
	229	// Declare alien output directory. Relative to working directory.
	230	plugin->SetGridOutputDir("output"); // In this case will be $HOME/work/output
	231	// Declare the analysis source files names separated by blancs. To be compiled runtime
	232	// using ACLiC on the worker nodes.
	233	plugin->SetAnalysisSource("AliRelAlignerKalman.cxx AliRelAlignerKalmanArray.cxx AliAnalysisTaskITSTPCalignment.cxx");
	234	// Declare all libraries (other than the default ones for the framework. These will be
	235	// loaded by the generated analysis macro. Add all extra files (task .cxx/.h) here.
	236	plugin->SetAdditionalLibs("AliRelAlignerKalman.h AliRelAlignerKalman.cxx AliRelAlignerKalmanArray.h AliRelAlignerKalmanArray.cxx AliAnalysisTaskITSTPCalignment.h AliAnalysisTaskITSTPCalignment.cxx");// AddTaskITSTPCalignment.C");
	237	// Declare the output file names separated by blancs.
	238	// (can be like: file.root or file.root@ALICE::Niham::File)
	239	plugin->SetOutputFiles("outputITSTPCalignment.root");
	240	// Optionally define the files to be archived.
	241	// plugin->SetOutputArchive("log_archive.zip:stdout,stderr@ALICE::NIHAM::File root_archive.zip:*.root@ALICE::NIHAM::File");
	242	plugin->SetOutputArchive("log_archive.zip:stdout,stderr");
	243	// Optionally set a name for the generated analysis macro (default MyAnalysis.C)
	244	plugin->SetAnalysisMacro("AnalysisITSTPCalignmentGenerated.C");
	245	// Optionally set maximum number of input files/subjob (default 100, put 0 to ignore)
	246	plugin->SetSplitMaxInputFileNumber(20);
247	// Optionally set number of failed jobs that will trigger killing waiting sub-jobs.
248	plugin->SetMaxInitFailed(5);
249	// Optionally resubmit threshold.
250	plugin->SetMasterResubmitThreshold(90);
251	// Optionally set time to live (default 30000 sec)
252	plugin->SetTTL(100000);
253	// Optionally set input format (default xml-single)
254	plugin->SetInputFormat("xml-single");
255	// Optionally modify the name of the generated JDL (default analysis.jdl)
256	plugin->SetJDLName("taskITSTPCalignment.jdl");
257	// Optionally modify job price (default 1)
258	plugin->SetPrice(1);
259	// Optionally modify split mode (default 'se')
260	plugin->SetSplitMode("se");
261	/////////////////////////////////////////////////////////////////////////////////////////////
262	/////////////////////////////////////////////////////////////////////////////////////////////
263	/////////////////////////////////////////////////////////////////////////////////////////////
264
265	// analysis manager
266	AliAnalysisManager *mgr = new AliAnalysisManager("ITSTPCalignmentAnalysisManager");
267
268	// input handlers
269	mgr->SetGridHandler(plugin);
270
271	//input handler
272	AliESDInputHandler* esdH = new AliESDInputHandler();
273	esdH->SetInactiveBranches("Calo FMD");
20ef1093	274	esdH->SetReadFriends(kTRUE);
51cfc50d	275	mgr->SetInputEventHandler(esdH);
51cfc50d	276
51cfc50d	277	gROOT->LoadMacro("AddTaskITSTPCalignment.C");
	278
	279	//add the task
	280	AliAnalysisTaskITSTPCalignment *task = AddTaskITSTPCalignment();
	281
	282	//mgr->SetDebugLevel(2);
	283
	284	if (!mgr->InitAnalysis()) return;
	285	mgr->PrintStatus();
	286	mgr->StartAnalysis("grid");
	287	}
	288
	289	//______________________________________________________________________________
	290	Int_t setupPar(const char* pararchivename)
	291	{
	292	///////////////////
	293	// Setup PAR File//
	294	///////////////////
	295	if (pararchivename)
	296	{
	297	char processline[1024];
	298	sprintf(processline,".! tar xvzf %s.par",pararchivename);
	299	gROOT->ProcessLine(processline);
	300	const char* ocwd = gSystem->WorkingDirectory();
	301	gSystem->ChangeDirectory(pararchivename);
	302
	303	// check for BUILD.sh and execute
	304	if (!gSystem->AccessPathName("PROOF-INF/BUILD.sh"))
	305	{
	306	printf("*******************************\n");
	307	printf("* Building PAR archive *\n");
	308	printf("*******************************\n");
	309
	310	if (gSystem->Exec("PROOF-INF/BUILD.sh"))
	311	{
	312	Error("runAnalysis","Cannot Build the PAR Archive! - Abort!");
	313	return -1;
	314	}
	315	}
	316	// check for SETUP.C and execute
	317	if (!gSystem->AccessPathName("PROOF-INF/SETUP.C"))
	318	{
	319	printf("*******************************\n");
	320	printf("* Setup PAR archive *\n");
	321	printf("*******************************\n");
	322	gROOT->Macro("PROOF-INF/SETUP.C");
	323	}
	324
	325	gSystem->ChangeDirectory("../");
	326	}
	327	return 1;
	328	}
	329
	330