HmpidDecodeRawFile.cxx

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
 
/* ------ HISTORY ---------
*/
#include <fairlogger/Logger.h> // for LOG
#include "Framework/Logger.h"
 
#include "HMPIDReconstruction/HmpidDecodeRawFile.h"
 
using namespace o2::hmpid;
 
HmpidDecodeRawFile::HmpidDecodeRawFile(int numOfEquipments)
  : HmpidDecoder(numOfEquipments)
{
  fh = 0;
}
 
HmpidDecodeRawFile::HmpidDecodeRawFile(int* EqIds, int* CruIds, int* LinkIds, int numOfEquipments)
  : HmpidDecoder(EqIds, CruIds, LinkIds, numOfEquipments)
{
  fh = 0;
}
 
HmpidDecodeRawFile::~HmpidDecodeRawFile()
{
}
 
bool HmpidDecodeRawFile::setUpStream(void* FileName, long Size)
{
  strcpy(mInputFile, (const char*)FileName);
  // files section ----
  if (!fileExists(mInputFile)) {
    LOG(error) << "The input file " << mInputFile << " does not exist at this time.";
    throw TH_FILENOTEXISTS;
  }
  // open the file
  fh = fopen(mInputFile, "rb");
  if (fh == 0) {
    LOG(error) << "ERROR to open Input file ! [" << mInputFile << "]";
    throw TH_OPENFILE;
  }
 
  mActualStreamPtr = 0; // sets the pointer to the Buffer
  mEndStreamPtr = 0;    //sets the End of buffer
  mStartStreamPtr = 0;
 
  return (true);
}
 
bool HmpidDecodeRawFile::getBlockFromStream(uint32_t** streamPtr, uint32_t Size)
{
  if (Size > MAXRAWFILEBUFFER)
    return (false);
  int nr = fread(mFileBuffer, sizeof(int32_t), HEADERDIMENSION_W, fh);
  if (nr != HEADERDIMENSION_W) {
    throw TH_WRONGFILELEN;
  }
  Size = ((mFileBuffer[2] & 0x0000FFFF) / sizeof(int32_t)) - HEADERDIMENSION_W;
  nr = fread(mFileBuffer + HEADERDIMENSION_W, sizeof(int32_t), Size, fh);
  LOG(debug) << " getBlockFromStream read " << nr << " of " << Size + HEADERDIMENSION_W << " words !";
  if (nr != Size) {
    throw TH_WRONGFILELEN;
  }
  *streamPtr = mFileBuffer;
  mStartStreamPtr = mFileBuffer;
  mActualStreamPtr = mFileBuffer;
  mEndStreamPtr = mFileBuffer + Size;
  return (true);
}
 
bool HmpidDecodeRawFile::getHeaderFromStream(uint32_t** streamPtr)
{
  bool flag = getBlockFromStream(streamPtr, RAWBLOCKDIMENSION_W); // reads the 8k block
  mActualStreamPtr += HEADERDIMENSION_W;                          // Move forward for the first word
  return (flag);
}
 
bool HmpidDecodeRawFile::getWordFromStream(uint32_t* word)
{
  *word = *mActualStreamPtr;
  mActualStreamPtr++;
  return (true);
}
 
void HmpidDecodeRawFile::setPad(HmpidEquipment* eq, int col, int dil, int ch, uint16_t charge)
{
  eq->setPad(col, dil, ch, charge);
  return;
}
 
int HmpidDecodeRawFile::fileExists(char* filewithpath)
{
  if (access(filewithpath, F_OK) != -1) {
    return (true);
  } else {
    return (false);
  }
}
o2::hmpid::Digit