SHUTTLE/DCSClient/macros/TestClientDP.C

   1 void GetValues(const char* host, Int_t port, const char* request,
   2         Long_t startTime, Long_t endTime)
   3 {
   4
   5         AliDCSClient client(host, port, 10000, 5);
   6
   7         Int_t result;
   8
   9         TTimeStamp currentTime;
  10         TMap values;
  11         values.SetOwner(1);
  12
  13         TString rString(request);
  14
  15         TObjArray* requests = rString.Tokenize(",");
  16
  17         cout<<"Requests: "<<requests->GetEntries()<<endl;
  18
  19         TStopwatch sw;
  20         sw.Start();
  21
  22         if (requests->GetEntries() > 1) {
  23
  24                 TIter iter(requests);
  25                 TObjString* aString;
  26                 while ((aString = (TObjString*) iter.Next())) {
  27                         TObjArray* valueSet = new TObjArray();
  28                         valueSet->SetOwner(1);
  29
  30                         result = client.GetDPValues(request, startTime,
  31                                 endTime, valueSet);
  32                         values.Add(new TObjString(request), valueSet);
  33                 }
  34
  35
  36         } else {
  37                 TObjArray* valueSet = new TObjArray();
  38                 valueSet->SetOwner(1);
  39
  40
  41                 result = client.GetDPValues(request, startTime,
  42                                 endTime, valueSet);
  43                 values.Add(new TObjString(request), valueSet);
  44         }
  45
  46         if (result < 0) {
  47                 cout<<"Communication failure: "<<
  48                         AliDCSClient::GetErrorString(result)<<endl;
  49
  50                 if (result == AliDCSClient::fgkServerError) {
  51                         cout<<"Server error code: "<<
  52                                 client.GetServerErrorCode()<<endl;
  53                         cout<<client.GetServerError()<<endl;
  54                 }
  55         }
  56
  57         sw.Stop();
  58         cout<<"Elapsed time: "<<sw.RealTime()<<endl;
  59         if (result > 0) {
  60                 cout<<"Time per value: "<<sw.RealTime()/result<<endl;
  61         }
  62         cout<<"Received values: "<<result<<endl;
  63
  64         TIter iter(&values);
  65         TObjString* aRequest;
  66         while ((aRequest = (TObjString*) iter.Next())) {
  67
  68                 TObjArray* valueSet = (TObjArray*) values.GetValue(aRequest);
  69
  70                 cout<<" '"<<aRequest->String()<<"' values: "
  71                         <<valueSet->GetEntriesFast()<<endl;
  72
  73                 TIter valIter(valueSet);
  74                 AliDCSValue* aValue;
  75                 while ((aValue = (AliDCSValue*) valIter.Next())) {
  76                         cout<<aValue->ToString()<<endl;
  77                 }
  78         }
  79
  80
  81
  82         TFile file("DCSMap.root", "UPDATE");
  83         file.cd();
  84         values.Write("DCSMap",TObject::kSingleKey);
  85         file.Close();
  86
  87
  88         values.DeleteAll();
  89         delete requests;
  90
  91         cout<<"All values returned in runrange:  "<<endl;
  92         cout<<"StartTime: "<<TTimeStamp(startTime).AsString()<<endl;
  93         cout<<"EndTime: "<<TTimeStamp(endTime).AsString()<<endl;
  94 }
  95
  96 void TestClientDP(const char* host, Int_t port, const char* request,
  97         UInt_t startShift, UInt_t endShift) {
  98
  99         gSystem->Load("AliDCSClient");
 100
 101 //      AliLog::EnableDebug(kFALSE);
 102 //      AliLog::SetGlobalDebugLevel(3);
 103
 104         TTimeStamp currentTime;
 105
 106         GetValues(host, port, request,
 107                 currentTime.GetSec() - startShift,
 108                 currentTime.GetSec() - endShift);
 109
 110         cout<<"Client done"<<endl;
 111 }