basicExample.cpp

/**
 * @file
 * @copyright
 *   SPDX-FileCopyrightText: 2023-2023 European Southern Observatory (ESO)
 *
 *   SPDX-License-Identifier: LGPL-3.0-only
 */
#include <array>
#include <cstdint>
 
#include <ipcq/reader.hpp>
#include <ipcq/writer.hpp>
 
struct MyElement {
    enum class Status {
        Valid,
        Invalid,
    };
    Status status;
    std::size_t size;
    std::array<float, 64 * 64> data;
};
 
int main() {
    auto capacity = 64u;
    ipcq::Writer<MyElement> writer("topic", capacity);
    ipcq::Reader<MyElement> reader("topic");
 
    // Write
    {
        MyElement data = MyElement{MyElement::Status::Valid, 0u, {}};
        auto ec = writer.Write(data, ipcq::Notify::All);
        if (ec) {
            std::cerr << "Failed to write to queue: " << ec.message() << std::endl;
            return 1;
        }
    }
 
    // Read
    {
        using namespace std::chrono_literals;
        MyElement out;
        auto [ec, count] =
            reader.Read([&out](MyElement const& in) noexcept { out = in; }, 1u, 10ms);
        if (ec) {
            std::cerr << "Failed to read from queue: " << ec.message() << std::endl;
            return 1;
        } else {
            // out is OK
            // ...
        }
    }
}