Decoder.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 "MIDRaw/Decoder.h"
 
#include "Headers/RDHAny.h"
#include "DPLUtils/RawParser.h"
 
namespace o2
{
namespace mid
{
 
Decoder::Decoder(bool isDebugMode, bool isBare, const ElectronicsDelay& electronicsDelay, const CrateMasks& crateMasks, const FEEIdConfig& feeIdConfig) : mData(), mROFRecords(), mLinkDecoders()
{
  auto feeIds = isBare ? feeIdConfig.getConfiguredGBTUniqueIDs() : feeIdConfig.getConfiguredFEEIDs();
 
  for (auto& feeId : feeIds) {
#if defined(MID_RAW_VECTORS)
    mLinkDecoders.emplace_back(createLinkDecoder(feeId, isBare, isDebugMode, crateMasks.getMask(feeId), electronicsDelay, feeIdConfig));
#else
    mLinkDecoders.emplace(feeId, createLinkDecoder(feeId, isBare, isDebugMode, crateMasks.getMask(feeId), electronicsDelay, feeIdConfig));
#endif
  }
}
 
void Decoder::clear()
{
  mData.clear();
  mROFRecords.clear();
}
 
void Decoder::process(gsl::span<const uint8_t> bytes)
{
  clear();
  o2::framework::RawParser parser(bytes.data(), bytes.size());
  for (auto it = parser.begin(), end = parser.end(); it != end; ++it) {
    if (it.size() == 0) {
      continue;
    }
    gsl::span<const uint8_t> payload(it.data(), it.size());
    auto const* rdhPtr = reinterpret_cast<const o2::header::RDHAny*>(it.raw());
    process(payload, *rdhPtr);
  }
}
 
std::unique_ptr<Decoder> createDecoder(const o2::header::RDHAny& rdh, bool isDebugMode, const ElectronicsDelay& electronicsDelay, const CrateMasks& crateMasks, const FEEIdConfig& feeIdConfig)
{
  bool isBare = raw::isBare(rdh);
  return std::make_unique<Decoder>(isDebugMode, isBare, electronicsDelay, crateMasks, feeIdConfig);
}
std::unique_ptr<Decoder> createDecoder(const o2::header::RDHAny& rdh, bool isDebugMode, const char* electronicsDelayFile, const char* crateMasksFile, const char* feeIdConfigFile)
{
  o2::mid::ElectronicsDelay electronicsDelay;
  std::string filename = electronicsDelayFile;
  if (!filename.empty()) {
    electronicsDelay = o2::mid::readElectronicsDelay(filename.c_str());
  }
 
  o2::mid::CrateMasks crateMasks;
  filename = crateMasksFile;
  if (!filename.empty()) {
    crateMasks = o2::mid::CrateMasks(filename.c_str());
  }
 
  o2::mid::FEEIdConfig feeIdConfig;
  filename = feeIdConfigFile;
  if (!filename.empty()) {
    feeIdConfig = o2::mid::FEEIdConfig(filename.c_str());
  }
 
  return createDecoder(rdh, isDebugMode, electronicsDelay, crateMasks, feeIdConfig);
}
 
} // namespace mid
} // namespace o2