]>
Commit | Line | Data |
---|---|---|
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 | if (test) | |
24 | { | |
25 | win->SetTestMode(); | |
26 | ||
27 | win->GetSOR()->infoHandlerTest(2214); | |
28 | win->GetSOR()->infoHandlerTest(2215); | |
29 | win->GetSOR()->infoHandlerTest(2224); | |
30 | win->GetSOR()->infoHandlerTest(2244); | |
31 | ||
32 | printf("win = (AliOnlineReco*) 0x%lx\n", (unsigned long)win); | |
33 | } | |
34 | else { | |
35 | ||
36 | const char *dbHost = "aldaqdb"; | |
37 | Int_t dbPort = 3306; | |
38 | const char *dbName = "LOGBOOK"; | |
39 | const char *user = "logbook"; | |
40 | const char *password = "alice"; | |
41 | ||
42 | TSQLServer* server = TSQLServer::Connect(Form("mysql://%s:%d/%s", dbHost, dbPort, dbName), user, password); | |
43 | if (!server) { | |
44 | printf("ERROR: Could not connect to DAQ Logbook"); | |
45 | return 0; | |
46 | } | |
47 | TString sqlQuery; | |
48 | TTimeStamp ts; | |
49 | sqlQuery.Form("SELECT run FROM logbook WHERE DAQ_time_start > %u AND DAQ_time_end IS NULL AND partition = 'PHYSICS'", | |
50 | ts.GetSec()-86400); | |
51 | TSQLResult* result = server->Query(sqlQuery); | |
52 | if (!result) { | |
53 | printf("ERROR: Can't execute query <%s>!", sqlQuery.Data()); | |
54 | return 0; | |
55 | } | |
56 | if (result->GetRowCount() == 0) { | |
57 | printf("No active physics runs found"); | |
58 | } | |
59 | else { | |
60 | for (Int_t iRow = 0; iRow < result->GetRowCount(); iRow++) { | |
61 | TSQLRow* row = result->Next(); | |
62 | TString runStr = row->GetField(0); | |
63 | if (runStr.IsDigit()) | |
64 | win->StartOfRun(runStr.Atoi()); | |
65 | delete row; | |
66 | } | |
67 | } | |
68 | delete result; | |
69 | } | |
70 | ||
71 | app.Run(kTRUE); | |
72 | return 0; | |
73 | } |