missing forward declaration of THashList added

[u/mrichter/AliRoot.git] / SHUTTLE / Shuttle.C

diff --git a/SHUTTLE/Shuttle.C b/SHUTTLE/Shuttle.C
index 9341df2cfce709d9dc990897660864e4d36b48d5..5848170c8d1347a8b42e9daa494f264a9aaef443 100644 (file)
--- a/SHUTTLE/Shuttle.C
+++ b/SHUTTLE/Shuttle.C
@@ -1,44 +1,131 @@
-void 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");
+       gSystem->Load("libRLDAP");
+       gSystem->Load("libMonaLisa");
        gSystem->Load("libSHUTTLE");
-        gSystem->Load("$ROOTSYS/lib/libRLDAP");
-       gSystem->Load("$ROOTSYS/lib/libThread");
+       gSystem->Load("libThread");
+//     gSystem->Load("$ALICE_ROOT/SHUTTLE/test/libTest");
 
-//     AliLog::SetGlobalDebugLevel(1);
+       AliLog::SetGlobalDebugLevel(2);
+       
+       const char* pwd = gSystem->pwd();
+       
+       if( !gSystem->Getenv("SHUTTLE_DIR")) 
+       {
+               printf("Setting base SHUTTLE folder to %s\n", pwd);
+               gSystem->Setenv("SHUTTLE_DIR", pwd);
+       } else {
+               printf("Shuttle base folder is %s\n", gSystem->Getenv("SHUTTLE_DIR"));
+       }
 
-        AliShuttleConfig config("pcepalice60.cern.ch", 389,
-                       "cn=Shuttle,dc=alice,dc=cern,dc=ch", "passhuttle");
-        config.Print();
+//     Setting local CDB and reference storage locations
+         AliShuttle::SetMainCDB("alien://user=aliprod?folder=testShuttle/OCDB");
+         AliShuttle::SetMainRefStorage("alien://user=aliprod?folder=testShuttle/Reference");
+
+//        AliShuttle::SetMainCDB("local://$SHUTTLE_DIR/LocalShuttleCDB");
+//        AliShuttle::SetMainRefStorage("local://$SHUTTLE_DIR/LocalShuttleRefStorage");
+
+       AliShuttle::SetLocalCDB("local://$SHUTTLE_DIR/LocalShuttleCDB");
+       AliShuttle::SetLocalRefStorage("local://$SHUTTLE_DIR/LocalShuttleRefStorage");
+
+//     Setting Shuttle log and temp folders
+       AliShuttle::SetShuttleLogDir("$SHUTTLE_DIR/log");
+       AliShuttle::SetShuttleTempDir("$SHUTTLE_DIR/temp");
+       
+       
+       
+       AliShuttle::SetProcessDCS(kTRUE);
 
-       AliCDBStorage* cdbStorage = AliCDBManager::Instance()->
-                       GetStorage("local://~/temp/DCS");
+//     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, cdbStorage);
+       AliShuttleTrigger trigger(&config, 100000);
 
        AliShuttle* shuttle = trigger.GetShuttle();
+
        // Add here detectors preprocessor ...
-       //shuttle->RegisterCDBPreProcessor(new TestITSPreProcessor());
 
-       TString paramStr(param);
+       TString detector = dets;
        
-       if (paramStr.IsDigit()) {
-               Int_t run = paramStr.Atoi();
-               trigger.Collect(run);
-       } else if (paramStr == "new") {
-               trigger.CollectNew();
-       } else if (paramStr == "all") {
-               trigger.CollectAll();
-       } 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<<"all - collect data for all 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();
 }