ipc_client.hpp

Go to the documentation of this file.

#pragma once
 
#include <cstddef>
#include <cstdint>
#include <memory>
#include <span>
#include <string>
#include <sys/types.h>
 
namespace bb::ipc {
 
class IpcClient {
  public:
    IpcClient() = default;
    virtual ~IpcClient() = default;
 
    // Abstract interface - no copy or move
    IpcClient(const IpcClient&) = delete;
    IpcClient& operator=(const IpcClient&) = delete;
    IpcClient(IpcClient&&) = delete;
    IpcClient& operator=(IpcClient&&) = delete;
 
    virtual bool connect() = 0;
 
    virtual bool send(const void* data, size_t len, uint64_t timeout_ns) = 0;
 
    virtual std::span<const uint8_t> receive(uint64_t timeout_ns) = 0;
 
    virtual void release(size_t message_size) = 0;
 
    virtual void close() = 0;
 
    // Factory methods
    static std::unique_ptr<IpcClient> create_socket(const std::string& socket_path);
    static std::unique_ptr<IpcClient> create_shm(const std::string& base_name);
};
 
} // namespace bb::ipc