HLT/rec/AliHLTOUTRawReader.cxx

   1 // $Id$
   2
   3 /**************************************************************************
   4  * This file is property of and copyright by the ALICE HLT Project        *
   5  * ALICE Experiment at CERN, All rights reserved.                         *
   6  *                                                                        *
   7  * Primary Authors: Matthias Richter <Matthias.Richter@ift.uib.no>        *
   8  *                  for The ALICE HLT Project.                            *
   9  *                                                                        *
  10  * Permission to use, copy, modify and distribute this software and its   *
  11  * documentation strictly for non-commercial purposes is hereby granted   *
  12  * without fee, provided that the above copyright notice appears in all   *
  13  * copies and that both the copyright notice and this permission notice   *
  14  * appear in the supporting documentation. The authors make no claims     *
  15  * about the suitability of this software for any purpose. It is          *
  16  * provided "as is" without express or implied warranty.                  *
  17  **************************************************************************/
  18
  19 /** @file   AliHLTOUTRawReader.cxx
  20     @author Matthias Richter
  21     @date
  22     @brief  HLTOUT data wrapper for AliRawReader.                         */
  23
  24 // see header file for class documentation
  25 // or
  26 // refer to README to build package
  27 // or
  28 // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
  29
  30 #include "AliHLTOUTRawReader.h"
  31 #include "AliHLTHOMERLibManager.h"
  32 #include "AliRawReader.h"
  33 #include "AliHLTHOMERReader.h"
  34
  35 /** ROOT macro for the implementation of ROOT specific class methods */
  36 ClassImp(AliHLTOUTRawReader)
  37
  38 AliHLTOUTRawReader::AliHLTOUTRawReader(AliRawReader* pRawreader)
  39   :
  40   AliHLTOUTHomerBuffer(NULL, 0),
  41   fpRawreader(pRawreader),
  42   fpCurrent(NULL)
  43 {
  44   // see header file for class documentation
  45   // or
  46   // refer to README to build package
  47   // or
  48   // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
  49 }
  50
  51 const int AliHLTOUTRawReader::fgkIdShift=16;
  52
  53 AliHLTOUTRawReader::~AliHLTOUTRawReader()
  54 {
  55   // see header file for class documentation
  56   if (fpManager) {
  57     if (fpCurrent) fpManager->DeleteReader(fpCurrent);
  58     fpCurrent=NULL;
  59   }
  60 }
  61
  62 int AliHLTOUTRawReader::GenerateIndex()
  63 {
  64   // see header file for class documentation
  65   // step through all HLT ddls, create HOMER reader and
  66   // scan data block
  67   int iResult=0;
  68   if (fpRawreader && fpManager) {
  69     fpRawreader->Reset();
  70     fpRawreader->Select("HLT");
  71     UChar_t* pSrc=NULL;
  72     while (fpRawreader->ReadNextData(pSrc) && pSrc!=NULL && iResult>=0) {
  73       AliHLTUInt32_t id=(fpRawreader->GetEquipmentId())<<fgkIdShift;
  74       int size=fpRawreader->GetDataSize();
  75       int offset=sizeof(AliHLTOUT::AliHLTOUTEventHeader);
  76       AliHLTHOMERReader* pReader=fpManager->OpenReaderBuffer(pSrc+offset, size-offset);
  77       if (pReader) {
  78         iResult=ScanReader(pReader, id);
  79         fpManager->DeleteReader(pReader);
  80       }
  81     }
  82   } else {
  83     iResult=-ENODEV;
  84   }
  85   return iResult;
  86 }
  87
  88 int AliHLTOUTRawReader::GetDataBuffer(AliHLTUInt32_t index, const AliHLTUInt8_t* &pBuffer,
  89                                       AliHLTUInt32_t& size)
  90 {
  91   // see header file for class documentation
  92   int iResult=0;
  93   pBuffer=NULL;
  94   size=0;
  95   if (fpManager) {
  96     Int_t id = Int_t(index>>fgkIdShift);
  97     AliHLTUInt32_t blockNo=index&((0x1<<fgkIdShift)-1);
  98
  99     // block from the same ddl requested?
 100     if (fpCurrent && fpRawreader->GetEquipmentId()!=id) {
 101       fpManager->DeleteReader(fpCurrent);
 102       fpCurrent=NULL;
 103     }
 104
 105     // open ddl for equipment id and create HOMER reader
 106     if (!fpCurrent) {
 107       fpRawreader->Reset();
 108       fpRawreader->SelectEquipment(-1, id, id);
 109       UChar_t* pSrc=NULL;
 110       if (fpRawreader->ReadNextData(pSrc) && pSrc!=NULL) {
 111         int srcSize=fpRawreader->GetDataSize();
 112         int offset=sizeof(AliHLTOUT::AliHLTOUTEventHeader);
 113         fpCurrent=fpManager->OpenReaderBuffer(pSrc+offset, srcSize-offset);
 114         if (fpCurrent && fpCurrent->ReadNextEvent()!=0) {
 115           iResult=-ENODATA;
 116         }
 117       } else {
 118         iResult=-ENOSYS;
 119       }
 120     }
 121
 122     // get data
 123     if (fpCurrent) {
 124       AliHLTMonitoringReader* pReader=fpCurrent;
 125       if ((pBuffer=static_cast<const AliHLTUInt8_t*>(pReader->GetBlockData(blockNo)))!=NULL) {
 126         size=pReader->GetBlockDataLength(blockNo);
 127       } else {
 128         iResult=-ENOENT;
 129       }
 130     }
 131   } else {
 132     iResult=-ENODEV;
 133   }
 134   return iResult;
 135 }