TimeslicedDigiBuilder.h

Go to the documentation of this file.

/* Copyright (C) 2025 Jagiellonian University, Krakow
   SPDX-License-Identifier: GPL-3.0-only
   Authors: Bartosz Sobol [committer] */
 
#pragma once
 
#include <StorableTimeslice.hpp>
 
#include <boost/archive/binary_oarchive.hpp>
#include <boost/iostreams/device/back_inserter.hpp>
#include <boost/iostreams/stream.hpp>
 
#include <log.hpp>
#include <vector>
 
#include <fmt/format.h>
 
class TimeslicedDigiBuilder {
 
 public:
  TimeslicedDigiBuilder(const std::size_t bufferInitCapacity = 1 << 27 /* 128MB */);
 
  void init(uint32_t numCoreMicroslices, uint64_t index = UINT64_MAX, uint64_t tsPos = UINT64_MAX);
 
  template<typename ADigis>
  void addDigisToTs(const ADigis& digis, const fles::Subsystem subsystem)
  {
    L_(trace) << fmt::format("[TimeslicedDigiBuilder::addDigisToTs] Adding {} digis for subsystem {} to timeslice {}",
                             digis.size(), to_string(subsystem), fTs->index());
 
    if (fTs == nullptr) {
      throw std::runtime_error("[TimeslicedDigiBuilder::addDigisToTs] Underlying timeslice not initialized");
    }
 
    fBuffer.clear();
 
    boost::iostreams::stream stream{boost::iostreams::back_inserter(fBuffer)};
    boost::archive::binary_oarchive{stream} << digis;
    stream.flush();
 
    fles::MicrosliceDescriptor msDesc{.hdr_id  = 0xDD,
                                      .hdr_ver = 0x01,
                                      .eq_id   = 0xF000,
                                      .flags   = 0x0000,
                                      .sys_id  = static_cast<uint8_t>(subsystem),
                                      .sys_ver = 0xF0,
                                      .idx     = fTs->start_time(),
                                      .crc     = 0x00000000,
                                      .size    = static_cast<uint32_t>(fBuffer.size()),
                                      .offset  = 0};
 
    fTs->append_microslice(fTs->append_component(1), 0, msDesc, (uint8_t*) (fBuffer.data()));
  }
 
  fles::StorableTimeslice* getRelease();
 
 private:
  std::vector<char> fBuffer;
  std::unique_ptr<fles::StorableTimeslice> fTs;
};