1 #include "AliDimIntNotifier.h"
2 #include "AliOnlineReco.h"
6 #include <TSQLServer.h>
7 #include <TSQLResult.h>
10 #include <TTimeStamp.h>
12 int main(int argc, char **argv)
14 AliDimIntNotifier::SetMainThreadId();
16 Bool_t test = argc > 1 && strcmp("-test", argv[1]) == 0;
18 TRint app("App", &argc, argv);
20 AliOnlineReco *win = new AliOnlineReco;
23 TString autoRun(gSystem->Getenv("ONLINERECO_AUTORUN"));
24 if (autoRun == "1" || autoRun.CompareTo("true", TString::kIgnoreCase) == 0)
26 win->SetAutoRunMode(kTRUE);
33 win->GetSOR(0)->infoHandlerTest(2214);
34 win->GetSOR(0)->infoHandlerTest(2215);
35 win->GetSOR(0)->infoHandlerTest(2224);
36 win->GetSOR(0)->infoHandlerTest(2244);
38 printf("win = (AliOnlineReco*) 0x%lx\n", (unsigned long)win);
42 TString baseDir = gSystem->Getenv("ONLINERECO_BASE_DIR");
45 printf("ERROR: ONLINERECO_BASE_DIR is not set. Exiting...");
49 const char *dbHost = "aldaqdb";
51 const char *dbName = "LOGBOOK";
52 const char *user = "logbook";
53 const char *password = "alice";
55 TSQLServer* server = TSQLServer::Connect(Form("mysql://%s:%d/%s", dbHost, dbPort, dbName), user, password);
57 printf("ERROR: Could not connect to DAQ Logbook");
62 sqlQuery.Form("SELECT run FROM logbook WHERE DAQ_time_start > %u AND DAQ_time_end IS NULL AND partition REGEXP 'PHYSICS.*'",
64 TSQLResult* result = server->Query(sqlQuery);
67 printf("ERROR: Can't execute query <%s>!", sqlQuery.Data());
70 if (result->GetRowCount() == 0)
72 printf("No active physics runs found");
76 for (Int_t iRow = 0; iRow < result->GetRowCount(); iRow++)
78 TSQLRow* row = result->Next();
79 TString runStr = row->GetField(0);
81 win->StartOfRun(runStr.Atoi());