power_journal.h

Go to the documentation of this file.

// SPDX-License-Identifier: AGPL-3.0-or-later
// Commercial license available
// © Concepts 1996–2026 Miroslav Šotek. All rights reserved.
// © Code 2020–2026 Miroslav Šotek. All rights reserved.
// ORCID: 0009-0009-3560-0851
// Contact: www.anulum.li | protoscience@anulum.li
// Loop Timing Witness — bracketed real IIO acquisition journal

 
#ifndef WITNESS_POWER_JOURNAL_H
#define WITNESS_POWER_JOURNAL_H
#include "pac1934_device.h"
#include "../run_control.h"
#include "../exclusive_output.h"
#include <atomic>
#include <condition_variable>
#include <future>
#include <mutex>
#include <thread>
 
namespace witness {
class PowerJournal {
    const PowerConfiguration configuration;
    Pac1934Device &sensor;
    const std::function<std::uint64_t()> host_time;
    const std::function<std::uint32_t(std::uint8_t)> register_read;
    ExclusiveOutput output;
    std::thread worker;
    std::mutex mutex;
    std::condition_variable wake;
    bool stopping = false;
    std::atomic<bool> failed{false};
    std::exception_ptr failure;
    std::array<std::uint64_t, 4> previous_energy{};
    bool have_energy = false;
    std::uint64_t snapshot = 0;
    std::uint64_t ticks();
    void acquire();
    void collect(std::promise<void> ready) noexcept;
    void stop() noexcept;
    PowerJournal(const char *path, const PowerConfiguration &config, Pac1934Device &device,
                 std::function<std::uint64_t()> clock,
                 std::function<std::uint32_t(std::uint8_t)> read);
 
  public:
    template <class Device>
    PowerJournal(const char *path, const PowerConfiguration &config, Pac1934Device &device,
                 Device &fabric)
        : PowerJournal(
              path, config, device, [&fabric] { return fabric.time(); },
              [&fabric](std::uint8_t address) { return read_register(fabric, address); }) {}

    ~PowerJournal();
    PowerJournal(const PowerJournal &) = delete;
    PowerJournal &operator=(const PowerJournal &) = delete;
    void start();
    void check();
    void finish();
    RunHooks hooks();
};
} // namespace witness
#endif