missing forward declaration of THashList added
[u/mrichter/AliRoot.git] / SHUTTLE / Shuttle.C
index a6e40b4..5848170 100644 (file)
-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("libRLDAP.so");
+       gSystem->Load("libRAliEn");
+       gSystem->Load("libRLDAP");
+       gSystem->Load("libMonaLisa");
        gSystem->Load("libSHUTTLE");
-       gSystem->Load("$ROOTSYS/lib/libThread");
-       gSystem->Load("$ALICE_ROOT/SHUTTLE/test/libTest.so");
+       gSystem->Load("libThread");
+//     gSystem->Load("$ALICE_ROOT/SHUTTLE/test/libTest");
 
-//     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");
-
-//     AliShuttle::SetMainCDB("local://testLeakCDB");
-//     AliShuttle::SetMainRefStorage("local://testLeakRef");
-
-       AliShuttle::SetLocalCDB("local://LocalShuttleCDB");
-       AliShuttle::SetLocalRefStorage("local://LocalShuttleRefStorage");
+       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"));
+       }
 
-       AliShuttle::SetProcessDCS(kFALSE);
+//     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");
 
-//     AliCDBManager *man = AliCDBManager::Instance();
-//     man->SetDefaultStorage("local://MainCDB");
-//     man->SetDefaultStorage("alien://DBFolder=ShuttleMainCDB");
+       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);
 
-       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();
 }