Using proper file IDs in DAs

[u/mrichter/AliRoot.git] / STEER / AliGRPDCS.cxx

diff --git a/STEER/AliGRPDCS.cxx b/STEER/AliGRPDCS.cxx
index 7994e5ee269a24ec181a514d9d6c32e6820f6d06..d3b539b1c81319a303de2a76c485861913cf3458 100644 (file)
--- a/STEER/AliGRPDCS.cxx
+++ b/STEER/AliGRPDCS.cxx
@@ -20,54 +20,178 @@
 //   This class deals with the DCS related info of the GRP
 //   Origin: Panos Christakoglou, UOA-CERN, Panos.Christakoglou@cern.ch
 //-----------------------------------------------------------------
+#include "Riostream.h"
+#include "TError.h"
 
 #include "AliGRPDCS.h"
-
 #include "AliDCSValue.h"
+#include "AliLog.h"
 
-//#include <TObjString.h>
 class TObjString;
 
-#include <TH1.h>
 #include <TObjArray.h>
 
 ClassImp(AliGRPDCS)
 
 //_______________________________________________________________
 AliGRPDCS::AliGRPDCS():
-  TObject(), fDCSArray(new TObjArray()) {
+  TObject(), fStartTime(0), fStopTime(0), fDCSArray(new TObjArray()) {
   // default constructor
   
 }
 
 //_______________________________________________________________
-AliGRPDCS::AliGRPDCS(TObjArray *dcsArray):
-  TObject() {
+AliGRPDCS::AliGRPDCS(TObjArray *dcsArray, UInt_t fStart, UInt_t fStop):
+  TObject(), fStartTime(fStart), fStopTime(fStop), fDCSArray(new TObjArray()) {
   // constructor
-  fDCSArray = new TObjArray();
   fDCSArray = dcsArray;
 }
 
 //___________________________________________________________________________
 AliGRPDCS::AliGRPDCS(const AliGRPDCS& grpDcs):
-  TObject(grpDcs) {
+  TObject(grpDcs), 
+  fStartTime(grpDcs.fStartTime), fStopTime(grpDcs.fStopTime), 
+  fDCSArray(grpDcs.fDCSArray) {
   //copy constructor
 
-  if (grpDcs.fDCSArray) fDCSArray = new TObjArray();
+  //if (grpDcs.fDCSArray) fDCSArray = new TObjArray();
+}
+
+//_______________________________________________________________
+const char* AliGRPDCS::ProcessDCS(Int_t iType) {
+  // process the dcs dps
+  if(!fDCSArray->GetEntries()) {
+    Error("AliGRPDCS::ProcessDCS","No entries in array!!!");
+    return 0;
+  }
+
+  //0:Int - 1:UInt - 2:Float - 3:String - 4:Bool
+  TString fDCSDataPointValue;
+  switch (iType) {
+  case 0: {
+    fDCSDataPointValue += ProcessInt();
+    break;
+  }
+  case 1: {
+    fDCSDataPointValue += ProcessUInt();
+    break;
+  }
+  case 2: {
+    fDCSDataPointValue += ProcessFloat();
+    break;
+  }
+  case 3: {
+    fDCSDataPointValue += ProcessString();
+    break;
+  }
+  case 4: {
+    fDCSDataPointValue += ProcessBoolean();
+    break;
+  }
+  default: break;
+  }//switch
+
+  //cout<<fDCSDataPointValue.Data()<<endl;
+  return fDCSDataPointValue.Data();
+}
+
+//_______________________________________________________________
+const char* AliGRPDCS::ProcessInt() {
+  Float_t fFDCSArraySum = 0.0, fFDCSArrayMean = 0.0;
+  Int_t iCounts = 0;
+  for(Int_t i = 0; i < fDCSArray->GetEntries(); i++) {
+    AliDCSValue *v = (AliDCSValue *)fDCSArray->At(i);
+    if((v->GetTimeStamp() >= fStartTime) &&(v->GetTimeStamp() <= fStopTime)) {
+      fFDCSArraySum += v->GetInt();
+      iCounts += 1;
+    }
+  }
+  if(iCounts != 0) fFDCSArrayMean = fFDCSArraySum/iCounts;
+  else fFDCSArrayMean = -10.;
+ 
+  TString fDCSDataPointValue; fDCSDataPointValue += fFDCSArrayMean;
+
+  return fDCSDataPointValue.Data();
 }
 
 //_______________________________________________________________
-const char* AliGRPDCS::ProcessDCS(TH1 *h) {
-  // process the dcs float values
+const char* AliGRPDCS::ProcessUInt() {
   Float_t fFDCSArraySum = 0.0, fFDCSArrayMean = 0.0;
+  Int_t iCounts = 0;
   for(Int_t i = 0; i < fDCSArray->GetEntries(); i++) {
     AliDCSValue *v = (AliDCSValue *)fDCSArray->At(i);
-    h->Fill(v->GetFloat());
-    fFDCSArraySum += v->GetFloat();
+    if((v->GetTimeStamp() >= fStartTime) &&(v->GetTimeStamp() <= fStopTime)) {
+      fFDCSArraySum += v->GetUInt();
+      iCounts += 1;
+    }
   }
-  fFDCSArrayMean = fFDCSArraySum/fDCSArray->GetEntries();
+  if(iCounts != 0) fFDCSArrayMean = fFDCSArraySum/iCounts;
+  else fFDCSArrayMean = -10.;
+   
   TString fDCSDataPointValue; fDCSDataPointValue += fFDCSArrayMean;
 
   return fDCSDataPointValue.Data();
 }
 
+//_______________________________________________________________
+const char* AliGRPDCS::ProcessFloat() {
+  Float_t fFDCSArraySum = 0.0, fFDCSArrayMean = 0.0;
+  Int_t iCounts = 0;
+  //printf("Entries: %d\n",fDCSArray->GetEntries());
+  //printf("Start: %d - Stop: %d\n",fStartTime,fStopTime);
+  for(Int_t i = 0; i < fDCSArray->GetEntries(); i++) {
+    AliDCSValue *v = (AliDCSValue *)fDCSArray->At(i);
+    if((v->GetTimeStamp() >= fStartTime) &&(v->GetTimeStamp() <= fStopTime)) {
+      fFDCSArraySum += v->GetFloat();
+      iCounts += 1;
+    }
+  }
+  if(iCounts != 0) fFDCSArrayMean = fFDCSArraySum/iCounts;
+  else fFDCSArrayMean = -10.;
+   
+  TString fDCSDataPointValue; fDCSDataPointValue += fFDCSArrayMean;
+
+  return fDCSDataPointValue.Data();
+}
+
+//_______________________________________________________________
+const char* AliGRPDCS::ProcessString() {
+  TString fDCSString, fDCSTemp;
+
+  AliDCSValue *v = 0x0;
+
+  //printf("Entries: %d\n",fDCSArray->GetEntries());
+  //printf("Start: %d - Stop: %d\n",fStartTime,fStopTime);
+  
+  for(Int_t iCount = 0; iCount < fDCSArray->GetEntries(); iCount++) {
+    v = (AliDCSValue *)fDCSArray->At(iCount);
+    if ((v->GetTimeStamp() >= fStartTime) && (v->GetTimeStamp() <= fStopTime)) 
+      AliError(Form("DCS values for the parameter changed within the queried interval"));
+    if (v->GetTimeStamp() > fStopTime) continue;
+    fDCSString = v->GetChar();    
+  }
+  
+  TString fDCSDataPointValue = fDCSString;
+  //cout<<"Returned String: "<<fDCSDataPointValue.Data()<<endl;
+
+  return fDCSDataPointValue.Data();
+}
+
+//_______________________________________________________________
+const char* AliGRPDCS::ProcessBoolean() {
+  Bool_t fDCSBool = kTRUE;
+
+  AliDCSValue *v = 0x0;
+
+  for(Int_t iCount = 0; iCount < fDCSArray->GetEntries(); iCount++) {
+    v = (AliDCSValue *)fDCSArray->At(iCount);
+    if ((v->GetTimeStamp() >= fStartTime) && (v->GetTimeStamp() <= fStopTime)) 
+      AliError(Form("DCS values for the parameter changed within the queried interval"));
+    if (v->GetTimeStamp() > fStopTime) continue;
+    fDCSBool = v->GetBool();    
+  }
+
+  TString fDCSDataPointValue = fDCSBool;
+
+  return fDCSDataPointValue.Data();
+}