added AliHLTPreprocessor

diff --git a/HLT/libHLTrec.pkg b/HLT/libHLTrec.pkg
index 7f0f66759217c3621fa81ba6bf8a6a4583c8131e..e809eed79981ba1f9ec9020ce360240cc28d9493 100644 (file)
--- a/HLT/libHLTrec.pkg
+++ b/HLT/libHLTrec.pkg
@@ -6,6 +6,7 @@ include $(MODDIR)/hlt.conf
 LIBHLTREC_VERSION := 0
 
 CLASS_HDRS:=   AliHLTReconstructor.h \
 LIBHLTREC_VERSION := 0
 
 CLASS_HDRS:=   AliHLTReconstructor.h \

+               AliHLTPreprocessor.h \

                AliHLTOUTRawReader.h
 
 MODULE_SRCS:=  AliHLTDynamicAliLog.cxx \
                AliHLTOUTRawReader.h
 
 MODULE_SRCS:=  AliHLTDynamicAliLog.cxx \

diff --git a/HLT/rec/AliHLTPreprocessor.cxx b/HLT/rec/AliHLTPreprocessor.cxx
new file mode 100644 (file)
index 0000000..8501167
--- /dev/null
+++ b/HLT/rec/AliHLTPreprocessor.cxx
@@ -0,0 +1,197 @@
+// $Id$
+
+/**************************************************************************
+ * This file is property of and copyright by the ALICE HLT Project        * 
+ * ALICE Experiment at CERN, All rights reserved.                         *
+ *                                                                        *
+ * Primary Authors: Sebastian Bablok <Sebastian.Bablok@ift.uib.no>        *
+ *                  Kenneth Aamodt                                        *
+ *                  for The ALICE HLT Project.                            *
+ *                                                                        *
+ * 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.                  *
+ **************************************************************************/
+
+/**
+ * @file   AliHLTPreprocessor.cxx
+ * @author Kenneth Aamodt, Sebastian Bablok
+ * @date   2007-12-06
+ * @brief  Implementation of the HLT preprocessor (used by the Offline Shuttle) 
+ */
+
+// see header file for class documentation
+// or
+// refer to README to build package
+// or
+// visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
+
+#include "AliHLTPreprocessor.h"
+
+//#include <AliCDBMetaData.h>
+//#include <AliCDBEntry.h>
+
+#include <AliCDBMetaData.h>
+
+
+#include <TObjString.h>
+#include <TString.h>
+#include <TList.h>
+#include <TFile.h>
+
+
+ClassImp(AliHLTPreprocessor)
+
+const Int_t AliHLTPreprocessor::fgkHuffmanTablesNum = 6;
+
+const char* AliHLTPreprocessor::fgkHLTPreproc = "HLT";
+
+const char* AliHLTPreprocessor::fgkHuffmanFileBase = "huffmanData_";
+
+const char* AliHLTPreprocessor::fgkHuffmanFileDetector = "TPC_";       // at the moment only one
+
+const char* AliHLTPreprocessor::fgkTempHistoFileName = "HLTTemperatureHistograms.root";
+
+AliHLTPreprocessor::AliHLTPreprocessor(AliShuttleInterface* shuttle) 
+  :
+  AliPreprocessor(fgkHLTPreproc, shuttle),
+  fRun(0),
+  fStartTime(0),
+  fEndTime(0)
+{
+// see header file for class documentation
+// or
+// refer to README to build package
+// or
+// visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
+}
+
+
+AliHLTPreprocessor::~AliHLTPreprocessor() {
+// see header file for function documentation
+}
+
+void AliHLTPreprocessor::Initialize(Int_t run, UInt_t startTime, 
+                       UInt_t endTime) {
+// see header file for function documentation
+       fRun = run;
+       fStartTime = startTime;
+       fEndTime = endTime;
+
+       TString msg("Preprocessor for HLT initialized for run: ");
+       msg += run;
+//     Log(msg.Data());
+}
+
+
+UInt_t AliHLTPreprocessor::Process(TMap* dcsAliasMap) {
+// see header file for function documentation
+       UInt_t retVal = 0;
+//     const char* localFileName = 0;
+
+       if (!GetHLTStatus()) {
+               return 0;
+       }
+
+       // get Huffman tables
+       for (Int_t i = 0; i < fgkHuffmanTablesNum; i++) {
+               TString runNumberString;
+               runNumberString.Form("%08d", fRun);
+               TString filename(fgkHuffmanFileBase);
+               filename += fgkHuffmanFileDetector;
+               filename += runNumberString;
+               filename += "_0x23000";
+               filename += i;
+               filename += "0";
+               filename += i;
+               filename += ".root";
+
+               //spec 0x23000Y0Y -> huffmanData_<detector>_<runnumber>_<specification>.root
+               TList* HLTlist = GetFileSources(kHLT, filename.Data()); 
+               if (!HLTlist) {
+                       Log("Missing list for the HLT");
+                   continue;
+               }
+
+               if (HLTlist->GetSize() != 1) {
+                       Log(Form("Problem on the size of the list: %d (HLT)", 
+                                               HLTlist->GetSize()));
+                       continue;
+               }
+
+               TObjString* location = (TObjString*) HLTlist->At(0);
+               if (location == 0) {
+                       Log("Error in location HLT list.");
+                       continue;
+               }
+               TString localFileName = GetFile(kHLT, filename.Data(), 
+                                       location->String().Data()); 
+               
+/*             
+               TFile localFile(localFileName);
+               
+               AliCDBMetaData meta("Jennifer Wagner");
+               TString name("huffmanData_");
+               name += kDetector;
+               name += "Patch_";
+               name += i;
+
+               if (!(Store("CalibTPC", name.Data(), (TObject*) &localFile, &meta, 0, kTRUE))) {
+*/
+               if (!(StoreReferenceFile(localFileName.Data(), filename.Data()))) {
+                       TString msg("Storing of object '");
+                       msg += filename;
+                       msg += "' to Reference Storage failed!";
+               Log(msg.Data());
+                       retVal = 1; 
+                       // I think this is then really an error and should return an error code
+               }
+       }
+       
+       // get Temp Histogram map
+       TList* HLTlist = GetFileSources(kHLT, fgkTempHistoFileName);
+       if (!HLTlist) {
+       Log("Missing list for the HLT");
+               return 0;
+       }
+
+       if (HLTlist->GetSize() != 1) {
+               Log(Form("Problem on the size of the list: %d (HLT)", HLTlist->GetSize()));
+               return 0;
+       }
+
+       TObjString* location = (TObjString*) HLTlist->At(0);
+       if (location == 0) {
+               Log("Error in location HLT list.");
+               return 0;
+       }
+       TString localFileName = GetFile(kHLT, fgkTempHistoFileName, 
+                               location->String().Data());
+/*
+       TFile localFile(localFileName);
+       AliCDBMetaData meta("Sebastian Bablok");
+
+       if (!(Store("Calib", kTempHistoFileName, (TObject*) &localFile, &meta, 0, kTRUE))) {
+*/
+       if (!(StoreReferenceFile(localFileName.Data(), fgkTempHistoFileName))) {
+               TString msg("Storing of object '");
+               msg += fgkTempHistoFileName;
+               msg += "' to Reference Storage failed!";
+               Log(msg.Data());
+               retVal = 1;
+               // I think this is then really an error and should return an error code
+       }
+
+       return retVal;
+}
+
+
+Bool_t AliHLTPreprocessor::ProcessDCS() {
+// see header file for function documentation
+    return kFALSE;
+}
+

diff --git a/HLT/rec/AliHLTPreprocessor.h b/HLT/rec/AliHLTPreprocessor.h
new file mode 100644 (file)
index 0000000..6dd3ac6
--- /dev/null
+++ b/HLT/rec/AliHLTPreprocessor.h
@@ -0,0 +1,134 @@
+//-*- Mode: C++ -*-
+// @(#) $Id$
+
+#ifndef ALI_HLT_PREPROCESSOR_H
+#define ALI_HLT_PREPROCESSOR_H
+/* This file is property of and copyright by the ALICE HLT Project        * 
+ * ALICE Experiment at CERN, All rights reserved.                         *
+ * See cxx source for full Copyright notice                               */
+
+/**
+ * @file   AliHLTPreprocessor.h
+ * @author Kenneth Aamodt, Sebastian Bablok
+ * @date   2007-12-06
+ * @brief  Declaration of the HLT preprocessor (used by the Offline Shuttle) 
+ */
+
+// see below for class documentation
+// or
+// refer to README to build package
+// or
+// visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
+
+#include "AliPreprocessor.h"
+
+/**
+ * @class AliHLTPreprocessor
+ * Implementation of the HLT version for the Shuttle Preprocessor. 
+ *
+ * @author Sebastian Bablok, Kenneth Aamodt
+ *
+ * @date 2007-12-05
+ */
+class AliHLTPreprocessor : public AliPreprocessor {
+    public:
+       
+               /**
+                * Constructor for AliHLTPreprocessor
+                *
+                * @param shuttle pointer to the hosting shuttle
+                */
+               AliHLTPreprocessor(AliShuttleInterface* shuttle);
+
+               /**
+                * Destructor for AliHLTPreprocessor
+                */
+               virtual ~AliHLTPreprocessor();
+               
+               /**
+                * Function to initilaize the Preprocessor.
+                *
+                * @param run run number
+                * @param startTime start time of data
+                * @param endTime end time of data
+                */
+               virtual void Initialize(Int_t run, UInt_t startTime, UInt_t endTime);
+
+               /**
+                * Function to process data. Inside the preparation and storing to OCDB
+                * should be handled.
+                *
+                * @param dcsAliasMap the map containing aliases and corresponding DCS
+                *                      values and timestamps
+                *
+                * @return 0 on success; a value greater than 0 refers to an error
+                */
+               virtual UInt_t Process(TMap* dcsAliasMap);
+
+               /**
+                * Indicates if DCS data can be processed.
+                *
+                * @return true if DCS data can be processed, else false. 
+                */
+               virtual Bool_t ProcessDCS();
+
+               /** Define for HuffmanTable number */
+               static const Int_t fgkHuffmanTablesNum;                 // see above
+
+               /** Define for HuffmanFileBase */
+               static const char* fgkHuffmanFileBase;                  // see above
+
+               /** Define for Detector used for Huffman table */
+               static const char* fgkHuffmanFileDetector;              // see above
+
+               /** Define for Temperature Histogram filename */
+               static const char* fgkTempHistoFileName;                // see above
+
+               /** Define for name of the HLT Preproc */
+               static const char* fgkHLTPreproc;                               // see above
+               
+       protected:
+
+       private:
+               /**
+                * Disabled Copy constructor 
+                * (parent class is disabled so derived class does the same)
+                *
+                * @param preproc would be the AliHLTPreproc object to make copy of
+                */
+               AliHLTPreprocessor(const AliHLTPreprocessor& preproc);
+
+               /**
+                * Disabled Assignment operator
+                * (parent class is disabled so derived class does the same)
+                *
+                * @param rhs the AliHLTPreproc to assign from
+                *
+                * @return reference to assinged AliHLTPreproc
+                */
+               AliHLTPreprocessor& operator=(const AliHLTPreprocessor& rhs);
+
+               /**
+                * Stores the run number
+                */
+               Int_t fRun;                                                                             // see above
+       
+               /**
+                * Stores the start time 
+                */     
+               UInt_t fStartTime;                                                              // see above
+       
+               /**
+                * Stores the end time 
+                */     
+               UInt_t fEndTime;                                                                // see above
+
+               
+               ClassDef(AliHLTPreprocessor, 2);
+       
+};
+
+
+#endif
+
+