message_queue.h

Go to the documentation of this file.

 
#pragma once
 
#include <cstdint>
#include <memory>
#include <string>
#include <vector>
 
#include "contur/ipc/i_ipc_channel.h"
 
namespace contur {

    struct Message
    {
        std::uint32_t type = 0;
        std::uint32_t priority = 0;
        std::vector<std::byte> payload;
    };

    class MessageQueue final : public IIpcChannel
    {
        public:
        explicit MessageQueue(std::string name, std::size_t maxMessages = 64, bool priorityMode = false);
        ~MessageQueue() override;
 
        MessageQueue(const MessageQueue &) = delete;
        MessageQueue &operator=(const MessageQueue &) = delete;
        MessageQueue(MessageQueue &&) noexcept;
        MessageQueue &operator=(MessageQueue &&) noexcept;

        [[nodiscard]] Result<std::size_t> write(std::span<const std::byte> data) override;

        [[nodiscard]] Result<std::size_t> read(std::span<std::byte> buffer) override;

        void close() override;

        [[nodiscard]] bool isOpen() const noexcept override;

        [[nodiscard]] std::string_view name() const noexcept override;

        [[nodiscard]] Result<void> send(const Message &message);

        [[nodiscard]] Result<Message> receive();

        [[nodiscard]] std::size_t size() const noexcept;

        [[nodiscard]] std::size_t maxMessages() const noexcept;

        [[nodiscard]] bool isPriorityMode() const noexcept;
 
        private:
        struct Impl;
        std::unique_ptr<Impl> impl_;
    };
 
} // namespace contur