[u/mrichter/AliRoot.git] / PWG0 / multVScentPbPb / runAAFglob.C

//
void runAAFglob(TString dataset="/alice/data/LHC10h_000137161_p1_plusplusplus",
		TString outFName = "globs.root",
		Int_t  nEvents     = 50000000,
		Int_t  nEventsSkip = 0,
		TString alirootVer = "VO_ALICE@AliRoot::v4-21-04-AN",
		TString rootVer    = "VO_ALICE@ROOT::v5-27-06b",
		TString proofCluster="shahoian@alice-caf.cern.ch"
		//TString proofCluster="shahoian@skaf.saske.sk"
		) 
{ 
  //  
  Bool_t runLocal = kFALSE; // true only for local test mode
  if (runLocal) {
    dataset = "/default/shahoian/test_pp";
    //dataset = "/default/shahoian/test";
    proofCluster = "";
    alirootVer = "AliRootProofLite";
    nEvents = 500;
  }
  //
  printf("Requested: %s %s\n",alirootVer.Data(), rootVer.Data());
  printf("Output expected in %s\n",outFName.Data());
  //
  gEnv->SetValue("XSec.GSI.DelegProxy","2");
  //
  TString alirootMode="REC";
  TString extraLibs;
  extraLibs+= "ANALYSIS:ANALYSISalice";
  TList *list = new TList();
  // sets $ALIROOT_MODE on each worker to let proof to know to run in special mode
  list->Add(new TNamed("ALIROOT_MODE"      , alirootMode.Data()));
  list->Add(new TNamed("ALIROOT_EXTRA_LIBS", extraLibs.Data()));
  //  list->Add(new TNamed("ALIROOT_ENABLE_ALIEN","1"));
  //
  //REM: same version of AliRoot on client!!!!! Otherwise error!! 
  TProof::Mgr(proofCluster.Data())->SetROOTVersion(rootVer.Data());
  TProof::Open(proofCluster.Data());//,"workers=10x");
  //  TProof::Open(proofCluster.Data(),"workers=1x");
  if (!gProof) {
    Error("runAAFglob.C","Connection to AF failed.");
    return;
  }
  gProof->Exec("TObject *o = gEnv->GetTable()->FindObject(\"Proof.UseMergers\");"
	       "gEnv->GetTable()->Remove(o);", kTRUE);
  //  gProof->SetParameter("PROOF_UseMergers", 0);
  // Lets enable aliroot + extra libs on proof cluster
  if (runLocal) gProof->UploadPackage(alirootVer.Data());
  gProof->EnablePackage(alirootVer.Data(), list);
  //
  gROOT->LoadMacro("AnalysisMacroGlob.C");
  //
  if (runLocal) {
    Int_t numWorkers = gProof->GetParallel();
    if (numWorkers<1) {printf("No workers\n"); return;}
    gProof->SetParameter("PROOF_PacketizerStrategy", (Int_t)0);
    int frac = (Int_t) 5 / numWorkers;
    if (frac<1) frac = 1;
    gProof->SetParameter("PROOF_PacketAsAFraction", frac);
  }
  AnalysisMacroGlob(dataset,outFName,nEvents,nEventsSkip);
  //
}
Commit	Line	Data
a9a39f46	1	//
	2	void runAAFglob(TString dataset="/alice/data/LHC10h_000137161_p1_plusplusplus",
	3	TString outFName = "globs.root",
	4	Int_t nEvents = 50000000,
	5	Int_t nEventsSkip = 0,
	6	TString alirootVer = "VO_ALICE@AliRoot::v4-21-04-AN",
	7	TString rootVer = "VO_ALICE@ROOT::v5-27-06b",
	8	TString proofCluster="shahoian@alice-caf.cern.ch"
	9	//TString proofCluster="shahoian@skaf.saske.sk"
	10	)
	11	{
	12	//
	13	Bool_t runLocal = kFALSE; // true only for local test mode
	14	if (runLocal) {
	15	dataset = "/default/shahoian/test_pp";
	16	//dataset = "/default/shahoian/test";
	17	proofCluster = "";
	18	alirootVer = "AliRootProofLite";
	19	nEvents = 500;
	20	}
	21	//
	22	printf("Requested: %s %s\n",alirootVer.Data(), rootVer.Data());
	23	printf("Output expected in %s\n",outFName.Data());
	24	//
	25	gEnv->SetValue("XSec.GSI.DelegProxy","2");
	26	//
	27	TString alirootMode="REC";
	28	TString extraLibs;
	29	extraLibs+= "ANALYSIS:ANALYSISalice";
	30	TList *list = new TList();
	31	// sets $ALIROOT_MODE on each worker to let proof to know to run in special mode
	32	list->Add(new TNamed("ALIROOT_MODE" , alirootMode.Data()));
	33	list->Add(new TNamed("ALIROOT_EXTRA_LIBS", extraLibs.Data()));
	34	// list->Add(new TNamed("ALIROOT_ENABLE_ALIEN","1"));
	35	//
	36	//REM: same version of AliRoot on client!!!!! Otherwise error!!
	37	TProof::Mgr(proofCluster.Data())->SetROOTVersion(rootVer.Data());
	38	TProof::Open(proofCluster.Data());//,"workers=10x");
	39	// TProof::Open(proofCluster.Data(),"workers=1x");
	40	if (!gProof) {
	41	Error("runAAFglob.C","Connection to AF failed.");
	42	return;
	43	}
	44	gProof->Exec("TObject *o = gEnv->GetTable()->FindObject(\"Proof.UseMergers\");"
	45	"gEnv->GetTable()->Remove(o);", kTRUE);
	46	// gProof->SetParameter("PROOF_UseMergers", 0);
	47	// Lets enable aliroot + extra libs on proof cluster
	48	if (runLocal) gProof->UploadPackage(alirootVer.Data());
	49	gProof->EnablePackage(alirootVer.Data(), list);
	50	//
	51	gROOT->LoadMacro("AnalysisMacroGlob.C");
	52	//
	53	if (runLocal) {
	54	Int_t numWorkers = gProof->GetParallel();
	55	if (numWorkers<1) {printf("No workers\n"); return;}
	56	gProof->SetParameter("PROOF_PacketizerStrategy", (Int_t)0);
	57	int frac = (Int_t) 5 / numWorkers;
	58	if (frac<1) frac = 1;
	59	gProof->SetParameter("PROOF_PacketAsAFraction", frac);
	60	}
	61	AnalysisMacroGlob(dataset,outFName,nEvents,nEventsSkip);
	62	//
	63	}