uds.h

Go to the documentation of this file.

// uvco (c) 2024 Lewin Bormann. See LICENSE for specific terms.
 
#pragma once
 
#include <fmt/core.h>
#include <uv.h>
 
#include "uvco/internal/internal_utils.h"
#include "uvco/promise/promise.h"
#include "uvco/run.h"
#include "uvco/stream_server_base.h"
#include "uvco/uds_stream.h"
 
#include <coroutine>
#include <memory>
#include <optional>
#include <string_view>
 
namespace uvco {
 
 
class UnixStreamClient {
public:
  UnixStreamClient(const UnixStreamClient &) = delete;
  UnixStreamClient(UnixStreamClient &&) = delete;
  UnixStreamClient &operator=(const UnixStreamClient &) = delete;
  UnixStreamClient &operator=(UnixStreamClient &&) = delete;
  ~UnixStreamClient() = default;
 
  explicit UnixStreamClient(const Loop &loop) : loop_{loop} {}
 
  Promise<UnixStream> connect(std::string_view path);
 
private:
  const Loop &loop_;
 
  struct ConnectAwaiter_ {
    explicit ConnectAwaiter_(const Loop &loop, std::string_view path);
 
    static void onConnect(uv_connect_t *req, uv_status status);
 
    [[nodiscard]] static bool await_ready();
    bool await_suspend(std::coroutine_handle<> handle);
    UnixStream await_resume();
 
    uv_connect_t request_{};
    std::unique_ptr<uv_pipe_t> pipe_;
    std::string_view path_;
    std::optional<std::coroutine_handle<>> handle_;
    std::optional<uv_status> status_;
  };
};
 
class UnixStreamServer : public StreamServerBase<uv_pipe_t, UnixStream> {
public:
  UnixStreamServer(const UnixStreamServer &) = delete;
  UnixStreamServer(UnixStreamServer &&) = default;
  UnixStreamServer &operator=(const UnixStreamServer &) = delete;
  UnixStreamServer &operator=(UnixStreamServer &&) = default;
  ~UnixStreamServer() = default;
 
  UnixStreamServer(const Loop &loop, std::string_view bindPath, int flags = 0);
 
  void chmod(int mode);
};
 
 
} // namespace uvco