X-Git-Url: http://git.uio.no/git/?p=u%2Fmrichter%2FAliRoot.git;a=blobdiff_plain;f=SHUTTLE%2FShuttle.C;h=f8ec03fcf4e34a7859803ca7c113a1de5438214c;hp=1226c464ad5a6e0cc051758031cefb640abdd940;hb=441b0e9c63faf95f5c4a1593a80a937fa2d1280b;hpb=40fb74aab4947d8e57e00314d9dd8cec962f6ee8

diff --git a/SHUTTLE/Shuttle.C b/SHUTTLE/Shuttle.C
index 1226c464ad5..f8ec03fcf4e 100644
--- a/SHUTTLE/Shuttle.C
+++ b/SHUTTLE/Shuttle.C
@@ -1,70 +1,121 @@
-Bool_t Shuttle(const char* param = "listen") {
+Bool_t Shuttle(const char* param = "listen", const char* dets=0) {
 
 	// WARNING: if ldap is built with ssl support it may cause confilcts with the 
 	// AliEn interface. If this happens, grid storage activation must be done BEFORE 
 	// loading LDAP libraries!!!
 
+	gSystem->Load("libRAliEn.so");
 	gSystem->Load("libRLDAP.so");
 	gSystem->Load("libMonaLisa");
 	gSystem->Load("libSHUTTLE");
-	gSystem->Load("$ROOTSYS/lib/libThread");
-	gSystem->Load("$ALICE_ROOT/SHUTTLE/test/libTest.so");
-	
-	// libRalien complains otherwise, weird...
-	//gSystem->Load("libNetx");
-
-
-//	AliLog::SetGlobalDebugLevel(1);
-
-	// Setting local CDB and reference storage locations
-	AliShuttle::SetMainCDB("alien://user=aliprod?folder=colla/GridShuttleCDB");
-	AliShuttle::SetMainRefStorage("alien://user=aliprod?folder=colla/GridShuttleRefStorage");
+	gSystem->Load("libThread");
+//	gSystem->Load("$ALICE_ROOT/SHUTTLE/test/libTest.so");
 
-//	AliShuttle::SetMainCDB("local://testLeakCDB");
-//	AliShuttle::SetMainRefStorage("local://testLeakRef");
+	AliLog::SetGlobalDebugLevel(2);
 
-	AliShuttle::SetLocalCDB("local://LocalShuttleCDB");
-	AliShuttle::SetLocalRefStorage("local://LocalShuttleRefStorage");
+// 	Setting local CDB and reference storage locations
+	  AliShuttle::SetMainCDB("alien://user=aliprod?folder=testShuttle/OCDB");
+	  AliShuttle::SetMainRefStorage("alien://user=aliprod?folder=testShuttle/Reference");
 
-	AliShuttle::SetProcessDCS(kFALSE);
+//        AliShuttle::SetMainCDB("local://$SHUTTLE_DIR/LocalShuttleCDB");
+//        AliShuttle::SetMainRefStorage("local://$SHUTTLE_DIR/LocalShuttleRefStorage");
 
+	AliShuttle::SetLocalCDB("local://$SHUTTLE_DIR/LocalShuttleCDB");
+	AliShuttle::SetLocalRefStorage("local://$SHUTTLE_DIR/LocalShuttleRefStorage");
 
-//	AliCDBManager *man = AliCDBManager::Instance();
-//	man->SetDefaultStorage("local://MainCDB");
-//	man->SetDefaultStorage("alien://DBFolder=ShuttleMainCDB");
-
+// 	Setting Shuttle log and temp folders
+	AliShuttle::SetShuttleLogDir("$SHUTTLE_DIR/log");
+	AliShuttle::SetShuttleTempDir("$SHUTTLE_DIR/temp");
+	
+	
+	
+	AliShuttle::SetProcessDCS(kTRUE);
 
-	AliShuttleConfig config("pcalice290.cern.ch", 389, "o=alice,dc=cern,dc=ch");
+//	AliShuttleConfig config("pcalice290.cern.ch", 389, "o=alice,dc=cern,dc=ch");
+	AliShuttleConfig config("pcalishuttle01.cern.ch", 389, "", "", "o=alice,dc=cern,dc=ch");
 	config.SetProcessAll(kTRUE);
         config.Print();
 
-	AliShuttleTrigger trigger(&config);
+	AliShuttleTrigger trigger(&config, 100000);
 
 	AliShuttle* shuttle = trigger.GetShuttle();
 
 	// Add here detectors preprocessor ...
-	TestTPCPreprocessor *tpcPrep = new TestTPCPreprocessor(shuttle);
-	TestITSPreprocessorSPD *spdPrep = new TestITSPreprocessorSPD(shuttle);
-	TestHMPIDPreprocessor *richPrep = new TestHMPIDPreprocessor(shuttle);
-	TestZDCPreprocessor *zdcPrep = new TestZDCPreprocessor(shuttle);
 
-	TString paramStr(param);
+	TString detector = dets;
 	
-	if (paramStr.IsDigit() || paramStr == "-1") {
-		Int_t run = paramStr.Atoi();
-		trigger.Collect(run);
-	} else if (paramStr == "new") {
-		Bool_t result = trigger.Collect();
-	} else if (paramStr == "listen") {
-		trigger.Run();
-	} else {
-		cout<<"Bad parameter: "<<param<<endl;
-		cout<<"Parameter options: "<<endl;
-		cout<<"<run> - collect data for the given run"<<endl;
-		cout<<"new - collect data only for the new runs"<<endl;
-		cout<<"listen - start listening for DAQ notification"<<endl;
-		cout<<"<empty parameter> - the same as 'listen'"<<endl;
+	printf ("Processing detectors: %s \n", detector.Data());
+
+	if (detector.Contains("SPD")) 
+		new AliITSPreprocessorSPD(shuttle);
+	if (detector.Contains("SDD")) 
+		new AliITSPreprocessorSDD(shuttle);
+	if (detector.Contains("SSD")) 
+		new AliITSPreprocessorSSD(shuttle);
+	if (detector.Contains("TPC")) 
+		new AliTPCPreprocessor(shuttle);
+	if (detector.Contains("TRD")) 
+		new AliTRDPreprocessor(shuttle);
+	if (detector.Contains("TOF")) 
+		new AliTOFPreprocessor(shuttle);
+	if (detector.Contains("PHS")) 
+	{
+		gSystem->Load("libPHOSshuttle");
+		new AliPHOSPreprocessor(shuttle);
+	}
+	if (detector.Contains("CPV")) 
+		new AliCPVPreprocessor(shuttle);
+	if (detector.Contains("HMP")) 
+		new AliHMPIDPreprocessor(shuttle);
+	if (detector.Contains("EMC")) 
+		new AliEMCALPreprocessor(shuttle);
+	if (detector.Contains("MCH")) 
+		new AliMUONPreprocessor(shuttle);
+	if (detector.Contains("MTR")) 
+		new AliMTRPreprocessor(shuttle);
+	if (detector.Contains("FMD")) 
+		new AliFMDPreprocessor(shuttle);
+	if (detector.Contains("ZDC")) 
+		new AliZDCPreprocessor(shuttle);
+	if (detector.Contains("PMD")) 
+		new AliPMDPreprocessor("PMD", shuttle);
+	if (detector.Contains("T00")) 
+	{
+		gSystem->Load("libT0shuttle");
+		new AliT0Preprocessor("T00", shuttle);
 	}
+	if (detector.Contains("V00")) 
+		new AliVZEROPreprocessor(shuttle);
+	if (detector.Contains("GRP")) 
+		new AliGRPPreprocessor(shuttle);
+
+//	AliTOFPreprocessor *tofPrep = new AliTOFPreprocessor(shuttle);
+//	AliTRDPreprocessor *trdPrep = new AliTRDPreprocessor(shuttle);
+//	AliGRPPreprocessor *grpPrep = new AliGRPPreprocessor(shuttle);
+	
+	TString paramStr(param);
+	
+	TStopwatch stopwatch;
+	stopwatch.Start();
+
+      if (paramStr.IsDigit() || paramStr == "-1") {
+	      Int_t run = paramStr.Atoi();
+	      trigger.Collect(run);
+      } else if (paramStr == "new") {
+	      Bool_t result = trigger.Collect();
+      } else if (paramStr == "listen") {
+	      trigger.Run();
+      } else {
+	      cout<<"Bad parameter: "<<param<<endl;
+	      cout<<"Parameter options: "<<endl;
+	      cout<<"<run> - collect data for the given run"<<endl;
+	      cout<<"new - collect data only for the new runs"<<endl;
+	      cout<<"listen - start listening for DAQ notification"<<endl;
+	      cout<<"<empty parameter> - the same as 'listen'"<<endl;
+      }
+
+	printf("Execution time: R:%.2fs C:%.2fs \n",
+	       stopwatch.RealTime(),stopwatch.CpuTime());
 
 	AliCDBManager::Destroy();
 }