tcp.h

#ifndef UVW_TCP_INCLUDE_H
#define UVW_TCP_INCLUDE_H
 
#include <chrono>
#include <memory>
#include <string>
#include <type_traits>
#include <utility>
#include <uv.h>
#include "config.h"
#include "enum.hpp"
#include "request.hpp"
#include "stream.h"
#include "util.h"
 
namespace uvw {
 
namespace details {
 
enum class uvw_tcp_flags : std::underlying_type_t<uv_tcp_flags> {
    IPV6ONLY = UV_TCP_IPV6ONLY,
    _UVW_ENUM = 0
};
 
}
 
class tcp_handle final: public stream_handle<tcp_handle, uv_tcp_t> {
public:
    using time = std::chrono::duration<unsigned int>;
    using tcp_flags = details::uvw_tcp_flags;
    using ipv4 = uvw::ipv4;
    using ipv6 = uvw::ipv6;
 
    explicit tcp_handle(loop::token token, std::shared_ptr<loop> ref, unsigned int f = {});
 
    int init() final;
 
    int open(os_socket_handle socket);
 
    bool no_delay(bool value = false);
 
    bool keep_alive(bool enable = false, time val = time{0});
 
    bool simultaneous_accepts(bool enable = true);
 
    int bind(const sockaddr &addr, tcp_flags opts = tcp_flags::_UVW_ENUM);
 
    int bind(const std::string &ip, unsigned int port, tcp_flags opts = tcp_flags::_UVW_ENUM);
 
    int bind(socket_address addr, tcp_flags opts = tcp_flags::_UVW_ENUM);
 
    socket_address sock() const noexcept;
 
    socket_address peer() const noexcept;
 
    int connect(const sockaddr &addr);
 
    int connect(const std::string &ip, unsigned int port);
 
    int connect(socket_address addr);
 
    int close_reset();
 
private:
    enum {
        DEFAULT,
        FLAGS
    } tag;
 
    unsigned int flags;
};
 
} // namespace uvw
 
#ifndef UVW_AS_LIB
#    include "tcp.cpp"
#endif
 
#endif // UVW_TCP_INCLUDE_H