stream_server_base.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/name_resolution.h"
#include "uvco/promise/multipromise.h"
#include "uvco/promise/promise.h"
 
#include <memory>
 
namespace uvco {


template <typename UvStreamType> struct UvStreamInitHelper {
  static void init(uv_loop_t * /*loop*/, UvStreamType * /*stream*/) {
    BOOST_ASSERT_MSG(false, "UvStreamInit not specialized for this type");
  }
};

template <typename UvStreamType, typename StreamType> class StreamServerBase {
  struct ConnectionAwaiter_;
 
public:
  StreamServerBase(const StreamServerBase &) = delete;
  StreamServerBase(StreamServerBase &&) = default;
  StreamServerBase &operator=(const StreamServerBase &) = delete;
  StreamServerBase &operator=(StreamServerBase &&) = default;
  ~StreamServerBase();

  MultiPromise<StreamType> listen(int backlog = 128);

  [[nodiscard]] AddressHandle getSockname() const;

  void close();
 
protected:
  explicit StreamServerBase(std::unique_ptr<UvStreamType> socket)
      : socket_{std::move(socket)} {}
  std::unique_ptr<UvStreamType> socket_;
 
private:
  static void onNewConnection(uv_stream_t *stream, uv_status status);
};
 
// Implementation contained in stream_server_base_impl.cc, where it's
// instantiated for the currently two socket types using it (UnixServer and
// TcpServer). Include stream_server_base_impl.h to obtain declarations for
// those specializations.

 
} // namespace uvco