VtFeeder.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 "FeederOptions.h"
#include "VtSource.h"
 
#include <StorableTimeslice.hpp>
 
#include <Sink.hpp>
#include <Source.hpp>
#include <chrono>
#include <csignal>
#include <zmq.hpp>
 
class VtFeeder {
 public:
  explicit VtFeeder(const FeederOptions& options, volatile sig_atomic_t* signalStatus);
 
  void Run();
 
 private:
  const FeederOptions& fOptions;
  volatile sig_atomic_t* fSignalStatus;
 
  std::unique_ptr<VtSource> fSource;
  std::vector<std::unique_ptr<fles::TimesliceSink>> fPublishers;
 
  uint64_t fCount;
};