TOF Preprocessor for FDR

diff --git a/TOF/AliTOFPreprocessorFDR.cxx b/TOF/AliTOFPreprocessorFDR.cxx
new file mode 100644 (file)
index 0000000..82a11df
--- /dev/null
+++ b/TOF/AliTOFPreprocessorFDR.cxx
@@ -0,0 +1,297 @@
+/**************************************************************************
+ * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
+ *                                                                        *
+ * Author: The ALICE Off-line Project.                                    *
+ * Contributors are mentioned in the code where appropriate.              *
+ *                                                                        *
+ * Permission to use, copy, modify and distribute this software and its   *
+ * documentation strictly for non-commercial purposes is hereby granted   *
+ * without fee, provided that the above copyright notice appears in all   *
+ * copies and that both the copyright notice and this permission notice   *
+ * appear in the supporting documentation. The authors make no claims     *
+ * about the suitability of this software for any purpose. It is          *
+ * provided "as is" without express or implied warranty.                  *
+ **************************************************************************/
+
+/* 
+$Log$
+*/
+
+#include <Riostream.h>
+#include <stdio.h>
+#include <stdlib.h>
+
+#include <TFile.h>
+#include <TH1.h>
+#include <TH1F.h>
+#include <TH1S.h>
+#include <TH2S.h>
+#include <TMath.h>
+#include <TObjArray.h>
+#include <TObjString.h>
+#include <TTimeStamp.h>
+
+#include "AliCDBMetaData.h"
+#include "AliLog.h"
+#include "AliTOFChannelOnline.h"
+#include "AliTOFDataDCS.h"
+#include "AliTOFGeometry.h"
+#include "AliTOFPreprocessorFDR.h"
+#include "AliTOFFormatDCS.h"
+#include "AliDCSValue.h"
+
+class TF1;
+class AliDCSValue;
+class AliTOFGeometry;
+
+// TOF preprocessor class.
+// It takes data from DCS and passes them to the class AliTOFDataDCS, which
+// processes them. The result is then written to the CDB.
+// analogously, it takes data form DAQ (both at Run level and inclusive - 
+// of all the runs - level, processes them, and stores both Reference Data
+// and Online Calibration files in the CDB. 
+
+
+ClassImp(AliTOFPreprocessorFDR)
+
+//_____________________________________________________________________________
+
+AliTOFPreprocessorFDR::AliTOFPreprocessorFDR(AliShuttleInterface* shuttle) :
+  AliPreprocessor("TOF", shuttle),
+  fData(0),
+  fStoreRefData(kTRUE)
+{
+  // constructor
+
+}
+
+//_____________________________________________________________________________
+
+AliTOFPreprocessorFDR::~AliTOFPreprocessorFDR()
+{
+  // destructor
+  if (fData){
+    delete fData;
+    fData = 0;
+  }
+}
+
+//______________________________________________________________________________
+void AliTOFPreprocessorFDR::Initialize(Int_t run, UInt_t startTime,
+       UInt_t endTime)
+{
+  // Creates AliTOFDataDCS object
+
+  AliPreprocessor::Initialize(run, startTime, endTime);
+
+       AliInfo(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run,
+               TTimeStamp(startTime).AsString(),
+               TTimeStamp(endTime).AsString()));
+
+       fData = new AliTOFDataDCS(fRun, fStartTime, fEndTime);
+}
+
+//_____________________________________________________________________________
+
+UInt_t AliTOFPreprocessorFDR::ProcessDCSDataPoints(TMap* aliasMap)
+{
+  // Fills data into a AliTOFDataDCS object
+  // return codes:
+  // return=0 : all ok
+  // return=1 : no DCS input data Map
+  // return=2 : no DCS processed data was stored in Ref Data
+  // return=3 : no DCS processed data was stored in OCDB
+
+  if (!aliasMap){
+    Log("No DCS map found: TOF exiting from Shuttle");
+    return 1;// return error Code for DCS input data not found 
+  }
+
+  else {
+
+    AliDCSValue* aValue;
+    AliDCSValue* aValue1;
+    Float_t timeMin = (Float_t)fStartTime;
+    Float_t timeMax = (Float_t)fEndTime;
+    Float_t val=0;
+    Float_t val1=0;
+    Float_t time=0; 
+    Float_t delta[2];
+    Float_t timedelta[2];
+
+    TH1::AddDirectory(0);
+    
+    Bool_t resultDCSMap=kFALSE;
+    Bool_t resultDCSStore=kFALSE;
+    
+    TString aliasDP[4]={"tof_lv_i48_02","tof_lv_v48_02","tof_lv_i33_02","tof_lv_v33_02"};
+    
+    TObjArray *array = new TObjArray(4);
+    array->SetOwner();
+
+    AliTOFFormatDCS *lv_i48_02 = new AliTOFFormatDCS();
+    AliTOFFormatDCS *lv_v48_02 = new AliTOFFormatDCS();
+    AliTOFFormatDCS *lv_i33_02 = new AliTOFFormatDCS();
+    AliTOFFormatDCS *lv_v33_02 = new AliTOFFormatDCS();
+    
+    array->AddAt(lv_i48_02,0);
+    array->AddAt(lv_v48_02,1);
+    array->AddAt(lv_i33_02,2);
+    array->AddAt(lv_v33_02,3);
+
+    // processing DCS
+    
+    for (Int_t i=0;i<4;i++){
+      TObjArray *aliasArr = (TObjArray*) aliasMap->GetValue(aliasDP[i].Data());
+      
+      if(!aliasArr){
+       AliError(Form("Alias %s not found!", aliasDP[i].Data()));
+       return kFALSE;
+      }
+      
+      if(aliasArr->GetEntries()<3){
+       AliError(Form("Alias %s has just %d entries!",
+                     aliasDP[i].Data(),aliasArr->GetEntries()));
+       continue;
+      }
+      
+      TIter iterarray(aliasArr);
+      
+      Int_t nentries = aliasArr->GetEntries();
+      Int_t deltaTimeStamp = (Int_t) nentries/3;
+      Int_t deltaTimeStamp1 = (Int_t) nentries/2;
+      
+      // filling aliases with 10 floats+1 Usign
+      Int_t index = 0;
+      for (Int_t k=0;k<3;k++){
+       index = deltaTimeStamp*k;
+       if (k==0) {
+         index=0;
+       }
+       else if (k==1) {
+         index=deltaTimeStamp1;
+       } 
+       else if (k==2) {
+         index=nentries-1; 
+       }
+       aValue = (AliDCSValue*) aliasArr->At(index);
+       val = aValue->GetFloat();
+       time = (Float_t) (aValue->GetTimeStamp());
+       if (i==0){
+         AliDebug(1,Form("tof_lv_i48: setting value %i to %f at %f",k,val,time));
+         lv_i48_02->SetFloat(k,val);
+         lv_i48_02->SetTimeStampFloat(k,time);
+       }
+       else if (i==1){
+         AliDebug(1,Form("tof_lv_v48: setting value %i to %f at %f",k,val,time));
+         lv_v48_02->SetFloat(k,val);
+         lv_v48_02->SetTimeStampFloat(k,time);
+       }
+       else if (i==2){
+         AliDebug(1,Form("tof_lv_i33: setting value %i to %f at %f",k,val,time));
+         lv_i33_02->SetFloat(k,val);
+         lv_i33_02->SetTimeStampFloat(k,time);
+       }
+       else if (i==3){
+         AliDebug(1,Form("tof_lv_v33: setting value %i to %f at %f",k,val,time));
+         lv_v33_02->SetFloat(k,val);
+         lv_v33_02->SetTimeStampFloat(k,time);
+       }
+      }
+  
+      // computing the most significant variations
+      
+      Int_t deltamin = (Int_t)(60/(timeMax-timeMin)*nentries);
+      Int_t klast = nentries-deltamin;
+      
+      for (Int_t k=0;k<klast;k++){
+       aValue = (AliDCSValue*) aliasArr->At(k);
+       aValue1 = (AliDCSValue*) aliasArr->At(k+deltamin);
+       val = aValue->GetFloat();
+       val1 = aValue1->GetFloat();
+       if (delta[0]<=TMath::Abs(val1-val)) {
+         delta[0]=TMath::Abs(val1-val);
+         timedelta[0] = (Float_t)k;
+       }
+       if (delta[1]<=delta[0]) {
+         Float_t temp = delta[1];
+         Float_t timetemp = timedelta[1];
+         delta[1]=delta[0];
+         delta[0]=temp;
+         timedelta[1]=timedelta[0];
+         timedelta[0]=timetemp;
+       }
+      }
+      
+      for (Int_t kk=0;kk<2;kk++){
+       if (i==0){
+         AliDebug(1,Form("tof_lv_i48: setting variation %i to %f at %f",kk,delta[kk],timedelta[kk]));
+         lv_i48_02->SetDelta(kk,delta[kk]);
+         lv_i48_02->SetTimeStampDelta(kk,(Float_t)timedelta[kk]);
+       }
+       else if (i==1){
+         AliDebug(1,Form("tof_lv_v48: setting variation %i to %f at %f",kk,delta[kk],timedelta[kk]));
+         lv_v48_02->SetDelta(kk,delta[kk]);
+         lv_v48_02->SetTimeStampDelta(kk,(Float_t)timedelta[kk]);
+       }
+       else if (i==2){
+         AliDebug(1,Form("tof_lv_i33: setting variation %i to %f at %f",kk,delta[kk],timedelta[kk]));
+         lv_i33_02->SetDelta(kk,delta[kk]);
+         lv_i33_02->SetTimeStampDelta(kk,(Float_t)timedelta[kk]);
+       }
+       else if (i==3){
+         AliDebug(1,Form("tof_lv_v33: setting variation %i to %f at %f",kk,delta[kk],timedelta[kk]));
+         lv_v33_02->SetDelta(kk,delta[kk]);
+         lv_v33_02->SetTimeStampDelta(kk,(Float_t)timedelta[kk]);
+       }
+      }
+    }
+
+    AliCDBMetaData metaDataDCS;
+    metaDataDCS.SetBeamPeriod(0);
+    metaDataDCS.SetResponsible("Chiara Zampolli");
+    metaDataDCS.SetComment("This preprocessor fills an AliTOFDataDCS object.");
+    AliInfo("Storing DCS Data");
+    resultDCSStore = StoreReferenceData("Calib","DCSData",array, &metaDataDCS);
+    if (!resultDCSStore){
+      Log("Some problems occurred while storing DCS data results in Reference Data, TOF exiting from Shuttle");
+      return 2;// return error Code for processed DCS data not stored 
+      // in reference data
+    }
+    
+    AliInfo("Storing DCS Data in OCDB");
+    resultDCSMap = Store("Calib","DCSData",array, &metaDataDCS);
+    if (!resultDCSStore){
+      Log("Some problems occurred while storing DCS data results in OCDB, TOF exiting from Shuttle");
+      return 3;// return error Code for processed DCS data not stored 
+      // in reference data
+    }
+    
+    if (array) delete array;
+    return 0;
+
+  }
+
+}
+//_____________________________________________________________________________
+
+UInt_t AliTOFPreprocessorFDR::Process(TMap* dcsAliasMap)
+{
+  // Fills data into a AliTOFDataDCS object
+  // return codes:
+  // return=0  : all ok
+  // return=1  : no DCS input data Map
+  // return=2  : no DCS processed data was stored in Ref Data
+  // return=3  : no DCS processed data was stored in OCDB
+
+  TH1::AddDirectory(0);
+
+  // processing 
+
+  Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
+  if ((iresultDCS == 1) || (iresultDCS == 2) || (iresultDCS == 3)) return iresultDCS; 
+  
+  return 0;
+}
+
+

diff --git a/TOF/AliTOFPreprocessorFDR.h b/TOF/AliTOFPreprocessorFDR.h
new file mode 100644 (file)
index 0000000..1e726a9
--- /dev/null
+++ b/TOF/AliTOFPreprocessorFDR.h
@@ -0,0 +1,42 @@
+#ifndef ALITOFPREPROCESSORFDR_H
+#define ALITOFPREPROCESSORFDR_H
+
+/* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
+ * See cxx source for full Copyright notice                               */
+
+/* 
+$Id$
+*/
+
+#include "AliPreprocessor.h"
+
+// TOF preprocessor. It takes care of both  
+// DCS Data Points
+// and DAQ histograms to compute online calibration constants
+
+class AliTOFDataDCS;
+class TObjArray;
+class TH2S;
+
+class AliTOFPreprocessorFDR : public AliPreprocessor
+{
+  public:
+    AliTOFPreprocessorFDR(AliShuttleInterface* shuttle);
+    virtual ~AliTOFPreprocessorFDR();
+    void   SetStoreRefData(Bool_t in){fStoreRefData=in;};
+    Bool_t GetStoreRefData() const {return fStoreRefData;};
+
+  protected:
+    virtual void Initialize(Int_t run, UInt_t startTime, UInt_t endTime);
+    virtual UInt_t Process(TMap* dcsAliasMap);
+
+  private:
+    AliTOFPreprocessorFDR(const AliTOFPreprocessorFDR & proc); // copy constructor
+    AliTOFPreprocessorFDR& operator=(const AliTOFPreprocessorFDR & proc);
+    UInt_t ProcessDCSDataPoints(TMap* dcsAliasMap);
+
+    AliTOFDataDCS *fData;                // CDB class that stores the data
+    Bool_t fStoreRefData;                // Flag to decide storage of Ref Data
+    ClassDef(AliTOFPreprocessorFDR, 1);
+};
+#endif