named_pipe.hpp

Go to the documentation of this file.

#pragma once
 
// Named pipe for IPC — POSIX mkfifo / Windows CreateNamedPipe.
 
#include <atomic>
#include <mutex>
#include <string>
#include <string_view>
#include <optional>
#include <vector>
#include <cstdint>
 
namespace pulp::runtime {
 
class NamedPipe {
public:
    NamedPipe() = default;
    ~NamedPipe();

    bool create_server(std::string_view name);

    bool connect_client(std::string_view name);

    int write(const uint8_t* data, size_t length);
    int write(std::string_view data);

    int read(uint8_t* buffer, size_t buffer_size);

    std::optional<std::string> read_string(size_t max_size = 65536);

    void close();

    bool is_open() const;
 
    // No copy, move OK
    NamedPipe(const NamedPipe&) = delete;
    NamedPipe& operator=(const NamedPipe&) = delete;
    NamedPipe(NamedPipe&& other) noexcept;
    NamedPipe& operator=(NamedPipe&& other) noexcept;
 
private:
    std::string name_;
    std::atomic<bool> is_server_{false};
#ifdef _WIN32
    void* handle_ = nullptr;
    std::atomic<bool> closing_{false};
    std::atomic<bool> connecting_{false};
#else
    std::string write_name_;
    std::atomic<int> read_fd_{-1};
    std::atomic<int> write_fd_{-1};
    mutable std::mutex read_fd_mutex_;
    mutable std::mutex write_fd_mutex_;
    std::atomic<bool> closing_{false};
    std::atomic<bool> read_peer_confirmed_{false};
#endif
};
 
}  // namespace pulp::runtime