MONITOR/alionlinemonitor.cxx

   1 #include "AliDimIntNotifier.h"
   2 #include "AliOnlineReco.h"
   3
   4 #include <TRint.h>
   5
   6 #include <TSQLServer.h>
   7 #include <TSQLResult.h>
   8 #include <TSQLRow.h>
   9
  10 #include <TTimeStamp.h>
  11
  12 int main(int argc, char **argv)
  13 {
  14   AliDimIntNotifier::SetMainThreadId();
  15
  16   Bool_t test = argc > 1 && strcmp("-test", argv[1]) == 0;
  17
  18   TRint app("App", &argc, argv);
  19
  20   AliOnlineReco *win = new AliOnlineReco;
  21   win->MapWindow();
  22
  23   TString autoRun(gSystem->Getenv("ONLINERECO_AUTORUN"));
  24   if (autoRun == "1" || autoRun.CompareTo("true", TString::kIgnoreCase) == 0)
  25   {
  26     win->SetAutoRunMode(kTRUE);
  27   }
  28
  29   if (test)
  30   {
  31     win->SetTestMode();
  32
  33     win->GetSOR(0)->infoHandlerTest(2214);
  34     win->GetSOR(0)->infoHandlerTest(2215);
  35     win->GetSOR(0)->infoHandlerTest(2224);
  36     win->GetSOR(0)->infoHandlerTest(2244);
  37
  38     printf("win = (AliOnlineReco*) 0x%lx\n", (unsigned long)win);
  39   }
  40   else
  41   {
  42     TString baseDir = gSystem->Getenv("ONLINERECO_BASE_DIR");
  43     if (baseDir.IsNull())
  44     {
  45       printf("ERROR: ONLINERECO_BASE_DIR is not set. Exiting...");
  46       return 0;
  47     }
  48
  49     const char *dbHost = "aldaqdb";
  50     Int_t dbPort = 3306;
  51     const char *dbName = "LOGBOOK";
  52     const char *user = "logbook";
  53     const char *password = "alice";
  54
  55     TSQLServer* server = TSQLServer::Connect(Form("mysql://%s:%d/%s", dbHost, dbPort, dbName), user, password);
  56     if (!server) {
  57       printf("ERROR: Could not connect to DAQ Logbook");
  58       return 0;
  59     }
  60     TString sqlQuery;
  61     TTimeStamp ts;
  62     sqlQuery.Form("SELECT run FROM logbook WHERE DAQ_time_start > %u AND DAQ_time_end IS NULL AND partition REGEXP 'PHYSICS.*'",
  63                   ts.GetSec()-86400);
  64     TSQLResult* result = server->Query(sqlQuery);
  65     if (!result)
  66     {
  67       printf("ERROR: Can't execute query <%s>!", sqlQuery.Data());
  68       return 0;
  69     }
  70     if (result->GetRowCount() == 0)
  71     {
  72       printf("No active physics runs found");
  73     }
  74     else
  75     {
  76       for (Int_t iRow = 0; iRow < result->GetRowCount(); iRow++)
  77       {
  78         TSQLRow* row = result->Next();
  79         TString runStr = row->GetField(0);
  80         if (runStr.IsDigit())
  81           win->StartOfRun(runStr.Atoi());
  82         delete row;
  83       }
  84     }
  85     delete result;
  86   }
  87
  88   app.Run(kTRUE);
  89   return 0;
  90 }