HmpidDecodeRawMem.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 "DataFormatsHMP/Digit.h"
#include "HMPIDBase/Geo.h"
#include "HMPIDReconstruction/HmpidDecodeRawMem.h"
 
using namespace o2::hmpid;
 
HmpidDecodeRawMem::HmpidDecodeRawMem(int numOfEquipments)
  : HmpidDecoder(numOfEquipments)
{
}
 
HmpidDecodeRawMem::HmpidDecodeRawMem(int* EqIds, int* CruIds, int* LinkIds, int numOfEquipments)
  : HmpidDecoder(EqIds, CruIds, LinkIds, numOfEquipments)
{
}
 
HmpidDecodeRawMem::~HmpidDecodeRawMem() = default;
 
bool HmpidDecodeRawMem::setUpStream(void* Buffer, long BufferLen)
{
  long wordsBufferLen = BufferLen / (sizeof(int32_t) / sizeof(char)); // Converts the len in words
  if (Buffer == nullptr) {
    LOG(error) << "Raw data buffer null Pointer ! ";
    throw TH_NULLBUFFERPOINTER;
  }
  if (wordsBufferLen == 0) {
    LOG(error) << "Raw data buffer Empty ! ";
    throw TH_BUFFEREMPTY;
  }
  if (wordsBufferLen < 16) {
    LOG(error) << "Raw data buffer less then the Header Dimension = " << wordsBufferLen;
    throw TH_WRONGBUFFERDIM;
  }
 
  mActualStreamPtr = (uint32_t*)Buffer;                 // sets the pointer to the Buffer
  mEndStreamPtr = ((uint32_t*)Buffer) + wordsBufferLen; //sets the End of buffer
  mStartStreamPtr = ((uint32_t*)Buffer);
  //  std::cout << " setUpStrem : StPtr=" << mStartStreamPtr << " EndPtr=" << mEndStreamPtr << " Len=" << wordsBufferLen << std::endl;
  return (true);
}
 
bool HmpidDecodeRawMem::getBlockFromStream(uint32_t** streamPtr, uint32_t Size)
{
  *streamPtr = mActualStreamPtr;
  mActualStreamPtr += Size;
  if (mActualStreamPtr > mEndStreamPtr) {
    //    std::cout << " getBlockFromStream : StPtr=" << mActualStreamPtr << " EndPtr=" << mEndStreamPtr << " Len=" << Size << std::endl;
    //    std::cout << "Beccato " << std::endl;
    //    throw TH_WRONGBUFFERDIM;
    return (false);
  }
  return (true);
}
 
bool HmpidDecodeRawMem::getHeaderFromStream(uint32_t** streamPtr)
{
  return (getBlockFromStream(streamPtr, mRDHSize));
}
 
bool HmpidDecodeRawMem::getWordFromStream(uint32_t* word)
{
  uint32_t* appo;
  *word = *mActualStreamPtr;
  return (getBlockFromStream(&appo, 1));
}
 
void HmpidDecodeRawMem::setPad(HmpidEquipment* eq, int col, int dil, int ch, uint16_t charge)
{
  eq->setPad(col, dil, ch, charge);
  return;
}
 
// ========================================================================================
 
HmpidDecodeRawDigit::HmpidDecodeRawDigit(int numOfEquipments)
  : HmpidDecodeRawMem(numOfEquipments)
{
}
 
HmpidDecodeRawDigit::HmpidDecodeRawDigit(int* EqIds, int* CruIds, int* LinkIds, int numOfEquipments)
  : HmpidDecodeRawMem(EqIds, CruIds, LinkIds, numOfEquipments)
{
}
 
HmpidDecodeRawDigit::~HmpidDecodeRawDigit() = default;
 
void HmpidDecodeRawDigit::setPad(HmpidEquipment* eq, int col, int dil, int ch, uint16_t charge)
{
  eq->setPad(col, dil, ch, charge);
  mDigits.push_back(o2::hmpid::Digit(charge, eq->getEquipmentId(), col, dil, ch));
  //std::cout << "DI " << mDigits.back() << " "<<col<<","<< dil<<","<< ch<<"="<< charge<<std::endl;
  return;
}