RawReaderMemory.h

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.
#ifndef ALICEO2_PHOS_RAWREADERMEMORY_H
#define ALICEO2_PHOS_RAWREADERMEMORY_H
 
#include <gsl/span>
#include <Rtypes.h>
 
#include "PHOSBase/RCUTrailer.h"
#include "PHOSReconstruction/RawBuffer.h"
#include "PHOSReconstruction/RawPayload.h"
#include "Headers/RAWDataHeader.h"
#include "Headers/RDHAny.h"
 
namespace o2
{
 
namespace phos
{
 
class RawReaderMemory
{
 public:
  RawReaderMemory(const gsl::span<const char> rawmemory);
 
  ~RawReaderMemory() = default;
 
  void setRawMemory(const gsl::span<const char> rawmemory);
 
  void next();
 
  void nextPage(bool resetPayload = true);
 
  const o2::header::RDHAny& getRawHeader() const;
 
  // /// \brief access to the raw buffer (single DMA page)
  // /// \return Raw buffer of the current page
  // /// \throw Error with PAYLOAD_INCALID if payload was not decoded
  // const RawBuffer& getRawBuffer() const;
 
  const RawPayload& getPayload() const { return mRawPayload; }
 
  int getPayloadSize() const { return mRawPayload.getPayloadSize(); }
 
  int getFileSize() const noexcept { return mRawMemoryBuffer.size(); }
 
  int getNumberOfPages() const noexcept { return mNumData; }
 
  bool hasNext() const { return mCurrentPosition < mRawMemoryBuffer.size(); }
 
 protected:
  void init();
 
  o2::header::RDHAny decodeRawHeader(const void* headerwords);
 
 private:
  gsl::span<const char> mRawMemoryBuffer; 
  RawBuffer mRawBuffer;                   
  o2::header::RDHAny mRawHeader;          
  RawPayload mRawPayload;                 
  RCUTrailer mCurrentTrailer;             
  uint64_t mTrailerPayloadWords = 0;      
  uint32_t mCurrentPosition = 0;          
  int mNumData = 0;                       
  bool mRawHeaderInitialized = false;     
  bool mPayloadInitialized = false;       
 
  ClassDefNV(RawReaderMemory, 1);
};
 
} // namespace phos
 
} // namespace o2
 
#endif