Minor improvements
[u/mrichter/AliRoot.git] / MONITOR / onlineReco.C
1 UInt_t onlineReco(const char* param = "listen",const char *recMacroPath = "$ALICE_ROOT/test/cosmic/rec.C") {
2
3   TString paramStr(param);
4         
5   UInt_t run = 0;
6
7   TStopwatch stopwatch;
8   stopwatch.Start();
9
10   if (paramStr.IsDigit()) {
11     run = paramStr.Atoi();
12   } else if (paramStr == "listen") {
13     gSystem->Load("libMONITOR");
14     AliOnlineRecoTrigger trigger;
15     run = trigger.Run();
16   } else {
17     cout<<"Bad parameter: "<<param<<endl;
18     cout<<"Parameter options: "<<endl;
19     cout<<"<run> - run online reconstruction for the given run"<<endl;
20     cout<<"listen - start listening for ECS SOR notification"<<endl;
21     cout<<"<empty parameter> - the same as 'listen'"<<endl;
22   }
23
24   if (run > 0) {
25     TString gdc;
26     if (grp(run,gdc) > 0) {
27
28       // "t" stores the token on this disk, otherwise the alien connection is not thread/process-safe
29       TGrid::Connect("alien://", 0, 0, "t");
30
31       if (!gdc.IsNull()) {
32
33         TString dataSource = gdc;
34         dataSource.Prepend("mem://@");
35         dataSource.Append(":");
36
37         // Setting CDB
38         AliCDBManager * man = AliCDBManager::Instance();
39         //      man->SetDefaultStorage("raw://");
40         man->SetDefaultStorage("local://$ALICE_ROOT/OCDB");
41         man->SetSpecificStorage("GRP/GRP/Data",
42                               Form("local://%s",gSystem->pwd()));
43         man->SetSpecificStorage("GRP/CTP/Config",
44                               Form("local://%s",gSystem->pwd()));
45         man->SetLock(kTRUE);
46
47         gSystem->mkdir(Form("run%d",run));
48         gSystem->cd(Form("run%d",run));
49
50         gROOT->LoadMacro(gSystem->ExpandPathName(recMacroPath));
51         rec(dataSource.Data());
52
53         AliCDBManager::Destroy();
54       }
55       else {
56         cout << "No GDCs defined in the logbook entry for run " << run << endl;
57       }
58     }
59   }
60
61   printf("Execution time: R:%.2fs C:%.2fs \n",
62          stopwatch.RealTime(),stopwatch.CpuTime());
63
64   return run;
65
66 }
67
68 Int_t grp(UInt_t run, TString &gdc) {
69
70   Int_t ret=AliGRPPreprocessor::ReceivePromptRecoParameters(run, "aldaqdb", 0, "LOGBOOK", "logbook", "alice",
71                                                             Form("local://%s",gSystem->pwd()),
72                                                             gdc);
73   if(ret>0) cout << "Last run of the same type is: " << ret << endl;
74   else if(ret==0) cout << "No previous run of the same type found" << endl;
75   else if(ret<0) cout << "Error code while retrieving GRP parameters returned: " << ret << endl;
76   return(ret);
77 }