RawBuffer.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.
#include <fstream>
#include <iostream>
#include <cstring>
#include <fairlogger/Logger.h>
#include "PHOSReconstruction/RawBuffer.h"
 
using namespace o2::phos;
 
void RawBuffer::flush()
{
  mCurrentDataWord = 0;
  mNDataWords = 0;
  memset(mDataWords.data(), 0, sizeof(uint32_t) * mDataWords.size());
}
 
void RawBuffer::readFromStream(std::istream& in, uint32_t payloadsize)
{
  flush();
  uint32_t word(0);
  auto address = reinterpret_cast<char*>(&word);
  uint32_t nbyte = 0;
  while (nbyte < payloadsize) {
    in.read(address, sizeof(word));
    nbyte += sizeof(word);
    if ((word & 0xFFFFFF) == 0x1d3082) {
      LOG(error) << "Found stop word" << std::endl;
      // Termination word
      // should normally not be decoded in case the payload size
      // is determined correctly
      break;
    }
    mDataWords[mNDataWords++] = word;
  }
}
 
void RawBuffer::readFromMemoryBuffer(const gsl::span<const char> rawmemory)
{
  flush();
  auto address = reinterpret_cast<const uint32_t*>(rawmemory.data());
  for (unsigned int iword = 0; iword < static_cast<uint32_t>(rawmemory.size() / sizeof(uint32_t)); iword++) {
    // Run2 code, probably not needed for run3
    // if ((address[iword] & 0xFFF) == 0x082) {
    // Termination word
    // should normally not be decoded in case the payload size
    // is determined correctly
    // std::cout << "Found termination word" << std::endl;
    // break;
    // }
    mDataWords[mNDataWords++] = address[iword];
  }
}