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/promise/promise.h"
#include "uvco/run.h"
#include "uvco/stream_server_base.h"
#include "uvco/uds_stream.h"
 
#include <string_view>
 
namespace uvco {


class UnixStreamClient {
  struct ConnectAwaiter_;
 
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_;
};

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