carbon_client.hpp

Go to the documentation of this file.

// Copyright (c) 2024-2025 Voyant Photonics, Inc.
// All rights reserved.
 
#pragma once
 
#include <carbon_client_ffi.hpp>
#include <carbon_config.hpp>
#include <csignal>
#include <cstdint>
#include <memory>
#include <voyant_frame_wrapper.hpp>
 
class CarbonClient
{
public:
    explicit CarbonClient(const CarbonConfig& config);
 
    ~CarbonClient();
 
    // Non-copyable, non-movable (owns async runtime)
    CarbonClient(const CarbonClient&)            = delete;
    CarbonClient& operator=(const CarbonClient&) = delete;
    CarbonClient(CarbonClient&&)                 = delete;
    CarbonClient& operator=(CarbonClient&&)      = delete;
 
    bool start();
 
    void stop();
 
    bool isRunning() const;
 
    bool tryReceiveFrame();
 
    VoyantFrameWrapper&       latestFrame();
    const VoyantFrameWrapper& latestFrame() const;
 
    static void setupSignalHandling(int signal = SIGINT);
 
    static bool isTerminated();
 
    static void resetTerminationFlag();
 
private:
    CarbonClientHandleC*       handle_; // opaque pointer — type defined in carbon_client_ffi.hpp
    std::unique_ptr<uint8_t[]> buffer_;
    static constexpr size_t    kBufferSize_ = 8 * 1024 * 1024; // 8MB
    VoyantFrameWrapper         latestFrame_;
 
    static volatile std::sig_atomic_t terminated_;
    static void                       signalHandler(int);
};