ipc_manager.h

Go to the documentation of this file.

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

    class IpcManager
    {
        public:
        IpcManager();
        ~IpcManager();
 
        IpcManager(const IpcManager &) = delete;
        IpcManager &operator=(const IpcManager &) = delete;
        IpcManager(IpcManager &&) noexcept;
        IpcManager &operator=(IpcManager &&) noexcept;

        [[nodiscard]] Result<void> createPipe(const std::string &name, std::size_t capacity = 1024);

        [[nodiscard]] Result<void> createSharedMemory(const std::string &name, std::size_t bytes);

        [[nodiscard]] Result<void>
        createMessageQueue(const std::string &name, std::size_t maxMessages = 64, bool priorityMode = false);

        [[nodiscard]] Result<std::reference_wrapper<IIpcChannel>> getChannel(const std::string &name);

        [[nodiscard]] Result<void> destroyChannel(const std::string &name);

        [[nodiscard]] bool exists(const std::string &name) const noexcept;

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