IPC.h

浏览该文件的文档.

// Copyright 2024 libsese
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//    http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#pragma once
 
#include <sese/system/Semaphore.h>
#include <sese/system/SharedMemory.h>
 
#include <list>
 
namespace sese::system {
 
struct MemInfo {
    size_t total_size;
    size_t tail;
};
 
class Message {
public:
    explicit Message(std::string message);
 
    [[nodiscard]] const std::string &getDataAsString() const;
 
    [[nodiscard]] const void *data() const;
 
    [[nodiscard]] size_t length() const;
 
private:
    std::string message;
};
 
struct MessageIterator {
    uint32_t id;
    uint32_t length;
    void *buffer;
};
 
class IPCChannel {
public:
    using Ptr = std::unique_ptr<IPCChannel>;
 
    static IPCChannel::Ptr create(const std::string &name, size_t buffer_size);
 
    static Result<Ptr> createEx(const std::string &name, size_t buffer_size);
 
    static IPCChannel::Ptr use(const std::string &name);
 
    static Result<Ptr> useEx(const std::string &name);
 
    bool write(uint32_t id, const void *data, uint32_t length);
 
    bool write(uint32_t id, const std::string &message);
 
    std::list<Message> read(uint32_t id);
 
private:
    IPCChannel() = default;
 
    MemInfo *mem_info{};
    void *buffer{};
    Semaphore::Ptr semaphore{};
    SharedMemory::Ptr shared_memory{};
};
 
}