Socket.hpp

Go to the documentation of this file.

// The Reactive C++ Toolbox.
// Copyright (C) 2013-2019 Swirly Cloud Limited
// Copyright (C) 2022 Reactive Markets Limited
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#ifndef TOOLBOX_NET_SOCKET_HPP
#define TOOLBOX_NET_SOCKET_HPP
 
#include <toolbox/net/Error.hpp>
 
#include <toolbox/io/File.hpp>
 
#include <net/if.h>
#include <netdb.h>
#include <netinet/tcp.h>
 
namespace toolbox {
inline namespace net {
using AddrInfoPtr = std::unique_ptr<addrinfo, void (*)(addrinfo*)>;
} // namespace net
namespace os {
 
inline AddrInfoPtr getaddrinfo(const char* node, const char* service, const addrinfo& hints,
                               std::error_code& ec) noexcept
{
    addrinfo* ai{nullptr};
    const auto err = ::getaddrinfo(node, service, &hints, &ai);
    if (err != 0) {
        ec = make_gai_error_code(err);
    }
    return {ai, freeaddrinfo};
}
 
inline AddrInfoPtr getaddrinfo(const char* node, const char* service, const addrinfo& hints)
{
    addrinfo* ai{nullptr};
    const auto err = ::getaddrinfo(node, service, &hints, &ai);
    if (err != 0) {
        throw std::system_error{make_gai_error_code(err),
                                "getaddrinfo (" + std::string{node ? node : ""} + ")"};
    }
    return {ai, freeaddrinfo};
}
 
inline AddrInfoPtr getaddrinfo(const char* node, const char* service, int family, int type,
                               int protocol, std::error_code& ec) noexcept
{
    addrinfo hints{};
    // If node is not specified, then return a wildcard address suitable for bind()ing.
    hints.ai_flags = node ? 0 : AI_PASSIVE;
    hints.ai_family = family;
    hints.ai_socktype = type;
    hints.ai_protocol = protocol;
    return getaddrinfo(node, service, hints, ec);
}
 
inline AddrInfoPtr getaddrinfo(const char* node, const char* service, int family, int type,
                               int protocol)
{
    addrinfo hints{};
    // If node is not specified, then return a wildcard address suitable for bind()ing.
    hints.ai_flags = node ? 0 : AI_PASSIVE;
    hints.ai_family = family;
    hints.ai_socktype = type;
    hints.ai_protocol = protocol;
    return getaddrinfo(node, service, hints);
}
 
template <typename ProtocolT>
inline AddrInfoPtr getaddrinfo(const char* node, const char* service, ProtocolT protocol,
                               std::error_code& ec) noexcept
{
    return getaddrinfo(node, service, protocol.family(), protocol.type(), protocol.protocol(), ec);
}
 
template <typename ProtocolT>
inline AddrInfoPtr getaddrinfo(const char* node, const char* service, ProtocolT protocol)
{
    return getaddrinfo(node, service, protocol.family(), protocol.type(), protocol.protocol());
}
 
inline unsigned if_nametoindex(const char* ifname, std::error_code& ec) noexcept
{
    unsigned ifindex{0};
    if (ifname) {
        if (!(ifindex = ::if_nametoindex(ifname))) {
            ec = make_error(errno);
        }
    }
    return ifindex;
}
 
inline unsigned if_nametoindex(const char* ifname)
{
    unsigned ifindex{0};
    if (ifname) {
        if (!(ifindex = ::if_nametoindex(ifname))) {
            throw std::system_error{make_error(errno), "if_nametoindex"};
        }
    }
    return ifindex;
}
 
inline FileHandle socket(int family, int type, int protocol, std::error_code& ec) noexcept
{
    const auto sockfd = ::socket(family, type, protocol);
    if (sockfd < 0) {
        ec = make_error(errno);
    }
    return sockfd;
}
 
inline FileHandle socket(int family, int type, int protocol)
{
    const auto sockfd = ::socket(family, type, protocol);
    if (sockfd < 0) {
        throw std::system_error{make_error(errno), "socket"};
    }
    return sockfd;
}
 
template <typename ProtocolT>
inline FileHandle socket(ProtocolT protocol, std::error_code& ec) noexcept
{
    return socket(protocol.family(), protocol.type(), protocol.protocol(), ec);
}
 
template <typename ProtocolT>
inline FileHandle socket(ProtocolT protocol)
{
    return socket(protocol.family(), protocol.type(), protocol.protocol());
}
 
inline std::pair<FileHandle, FileHandle> socketpair(int family, int type, int protocol,
                                                    std::error_code& ec) noexcept
{
    int sv[2];
    if (::socketpair(family, type, protocol, sv) < 0) {
        ec = make_error(errno);
    }
    return {FileHandle{sv[0]}, FileHandle{sv[1]}};
}
 
inline std::pair<FileHandle, FileHandle> socketpair(int family, int type, int protocol)
{
    int sv[2];
    if (::socketpair(family, type, protocol, sv) < 0) {
        throw std::system_error{make_error(errno), "socketpair"};
    }
    return {FileHandle{sv[0]}, FileHandle{sv[1]}};
}
 
template <typename ProtocolT>
inline std::pair<FileHandle, FileHandle> socketpair(ProtocolT protocol,
                                                    std::error_code& ec) noexcept
{
    return socketpair(protocol.family(), protocol.type(), protocol.protocol(), ec);
}
 
template <typename ProtocolT>
inline std::pair<FileHandle, FileHandle> socketpair(ProtocolT protocol)
{
    return socketpair(protocol.family(), protocol.type(), protocol.protocol());
}
 
inline FileHandle accept(int sockfd, sockaddr& addr, socklen_t& addrlen,
                         std::error_code& ec) noexcept
{
    // The addrlen argument is updated to contain the actual size of the source address.
    // The returned address is truncated if the buffer provided is too small.
    const auto fd = ::accept(sockfd, &addr, &addrlen);
    if (fd < 0) {
        ec = make_error(errno);
    }
    return fd;
}
 
inline FileHandle accept(int sockfd, sockaddr& addr, socklen_t& addrlen)
{
    // The addrlen argument is updated to contain the actual size of the source address.
    // The returned address is truncated if the buffer provided is too small.
    const auto fd = ::accept(sockfd, &addr, &addrlen);
    if (fd < 0) {
        throw std::system_error{make_error(errno), "accept"};
    }
    return fd;
}
 
inline FileHandle accept(int sockfd, std::error_code& ec) noexcept
{
    const auto fd = ::accept(sockfd, nullptr, nullptr);
    if (fd < 0) {
        ec = make_error(errno);
    }
    return fd;
}
 
inline FileHandle accept(int sockfd)
{
    const auto fd = ::accept(sockfd, nullptr, nullptr);
    if (fd < 0) {
        throw std::system_error{make_error(errno), "accept"};
    }
    return fd;
}
 
template <typename EndpointT>
inline FileHandle accept(int sockfd, EndpointT& ep, std::error_code& ec) noexcept
{
    socklen_t addrlen = ep.capacity();
    FileHandle fh{accept(sockfd, *ep.data(), addrlen, ec)};
    if (!ec) {
        ep.resize(std::min<std::size_t>(addrlen, ep.capacity()));
    }
    return fh;
}
 
template <typename EndpointT>
inline FileHandle accept(int sockfd, EndpointT& ep)
{
    socklen_t addrlen = ep.capacity();
    FileHandle fh{accept(sockfd, *ep.data(), addrlen)};
    ep.resize(std::min<std::size_t>(addrlen, ep.capacity()));
    return fh;
}
 
inline void bind(int sockfd, const sockaddr& addr, socklen_t addrlen, std::error_code& ec) noexcept
{
    if (::bind(sockfd, &addr, addrlen) < 0) {
        ec = make_error(errno);
    }
}
 
inline void bind(int sockfd, const sockaddr& addr, socklen_t addrlen)
{
    if (::bind(sockfd, &addr, addrlen) < 0) {
        throw std::system_error{make_error(errno), "bind"};
    }
}
 
template <typename EndpointT>
inline void bind(int sockfd, const EndpointT& ep, std::error_code& ec) noexcept
{
    bind(sockfd, *ep.data(), ep.size(), ec);
}
 
template <typename EndpointT>
inline void bind(int sockfd, const EndpointT& ep)
{
    bind(sockfd, *ep.data(), ep.size());
}
 
inline void connect(int sockfd, const sockaddr& addr, socklen_t addrlen,
                    std::error_code& ec) noexcept
{
    if (::connect(sockfd, &addr, addrlen) < 0) {
        ec = make_error(errno);
    }
}
 
inline void connect(int sockfd, const sockaddr& addr, socklen_t addrlen)
{
    if (::connect(sockfd, &addr, addrlen) < 0) {
        throw std::system_error{make_error(errno), "connect"};
    }
}
 
template <typename EndpointT>
inline void connect(int sockfd, const EndpointT& ep, std::error_code& ec) noexcept
{
    connect(sockfd, *ep.data(), ep.size(), ec);
}
 
template <typename EndpointT>
inline void connect(int sockfd, const EndpointT& ep)
{
    connect(sockfd, *ep.data(), ep.size());
}
 
inline void listen(int sockfd, int backlog, std::error_code& ec) noexcept
{
    if (::listen(sockfd, backlog) < 0) {
        ec = make_error(errno);
    }
}
 
inline void listen(int sockfd, int backlog)
{
    if (::listen(sockfd, backlog) < 0) {
        throw std::system_error{make_error(errno), "listen"};
    }
}
 
inline void shutdown(int sockfd, int how, std::error_code& ec) noexcept
{
    if (::shutdown(sockfd, how) < 0) {
        ec = make_error(errno);
    }
}
 
inline void shutdown(int sockfd, int how)
{
    if (::shutdown(sockfd, how) < 0) {
        throw std::system_error{make_error(errno), "shutdown"};
    }
}
 
inline ssize_t recv(int sockfd, void* buf, std::size_t len, int flags, std::error_code& ec) noexcept
{
    const auto ret = ::recv(sockfd, buf, len, flags);
    if (ret < 0) {
        ec = make_error(errno);
    }
    return ret;
}
 
inline std::size_t recv(int sockfd, void* buf, std::size_t len, int flags)
{
    const auto ret = ::recv(sockfd, buf, len, flags);
    if (ret < 0) {
        throw std::system_error{make_error(errno), "recv"};
    }
    return ret;
}
 
inline ssize_t recv(int sockfd, MutableBuffer buf, int flags, std::error_code& ec) noexcept
{
    return recv(sockfd, buffer_cast<void*>(buf), buffer_size(buf), flags, ec);
}
 
inline std::size_t recv(int sockfd, MutableBuffer buf, int flags)
{
    return recv(sockfd, buffer_cast<void*>(buf), buffer_size(buf), flags);
}
 
inline ssize_t recvfrom(int sockfd, void* buf, std::size_t len, int flags, sockaddr& addr,
                        socklen_t& addrlen, std::error_code& ec) noexcept
{
    // The addrlen argument is updated to contain the actual size of the source address.
    // The returned address is truncated if the buffer provided is too small.
    const auto ret = ::recvfrom(sockfd, buf, len, flags, &addr, &addrlen);
    if (ret < 0) {
        ec = make_error(errno);
    }
    return ret;
}
 
inline std::size_t recvfrom(int sockfd, void* buf, std::size_t len, int flags, sockaddr& addr,
                            socklen_t& addrlen)
{
    // The addrlen argument is updated to contain the actual size of the source address.
    // The returned address is truncated if the buffer provided is too small.
    const auto ret = ::recvfrom(sockfd, buf, len, flags, &addr, &addrlen);
    if (ret < 0) {
        throw std::system_error{make_error(errno), "recvfrom"};
    }
    return ret;
}
 
template <typename EndpointT>
inline ssize_t recvfrom(int sockfd, void* buf, std::size_t len, int flags, EndpointT& ep,
                        std::error_code& ec) noexcept
{
    socklen_t addrlen = ep.capacity();
    const auto ret = recvfrom(sockfd, buf, len, flags, *ep.data(), addrlen, ec);
    if (!ec) {
        ep.resize(std::min<std::size_t>(addrlen, ep.capacity()));
    }
    return ret;
}
 
template <typename EndpointT>
inline std::size_t recvfrom(int sockfd, void* buf, std::size_t len, int flags, EndpointT& ep)
{
    socklen_t addrlen = ep.capacity();
    const auto ret = recvfrom(sockfd, buf, len, flags, *ep.data(), addrlen);
    ep.resize(std::min<std::size_t>(addrlen, ep.capacity()));
    return ret;
}
 
template <typename EndpointT>
inline ssize_t recvfrom(int sockfd, MutableBuffer buf, int flags, EndpointT& ep,
                        std::error_code& ec) noexcept
{
    return recvfrom(sockfd, buffer_cast<void*>(buf), buffer_size(buf), flags, ep, ec);
}
 
template <typename EndpointT>
inline std::size_t recvfrom(int sockfd, MutableBuffer buf, int flags, EndpointT& ep)
{
    return recvfrom(sockfd, buffer_cast<void*>(buf), buffer_size(buf), flags, ep);
}
 
inline ssize_t send(int sockfd, const void* buf, std::size_t len, int flags,
                    std::error_code& ec) noexcept
{
    const auto ret = ::send(sockfd, buf, len, flags);
    if (ret < 0) {
        ec = make_error(errno);
    }
    return ret;
}
 
inline std::size_t send(int sockfd, const void* buf, std::size_t len, int flags)
{
    const auto ret = ::send(sockfd, buf, len, flags);
    if (ret < 0) {
        throw std::system_error{make_error(errno), "send"};
    }
    return ret;
}
 
inline ssize_t send(int sockfd, ConstBuffer buf, int flags, std::error_code& ec) noexcept
{
    return send(sockfd, buffer_cast<const void*>(buf), buffer_size(buf), flags, ec);
}
 
inline std::size_t send(int sockfd, ConstBuffer buf, int flags)
{
    return send(sockfd, buffer_cast<const void*>(buf), buffer_size(buf), flags);
}
 
inline ssize_t sendto(int sockfd, const void* buf, std::size_t len, int flags, const sockaddr& addr,
                      socklen_t addrlen, std::error_code& ec) noexcept
{
    const auto ret = ::sendto(sockfd, buf, len, flags, &addr, addrlen);
    if (ret < 0) {
        ec = make_error(errno);
    }
    return ret;
}
 
inline std::size_t sendto(int sockfd, const void* buf, std::size_t len, int flags,
                          const sockaddr& addr, socklen_t addrlen)
{
    const auto ret = ::sendto(sockfd, buf, len, flags, &addr, addrlen);
    if (ret < 0) {
        throw std::system_error{make_error(errno), "sendto"};
    }
    return ret;
}
 
template <typename EndpointT>
inline ssize_t sendto(int sockfd, const void* buf, std::size_t len, int flags, const EndpointT& ep,
                      std::error_code& /*ec*/) noexcept
{
    return sendto(sockfd, buf, len, flags, *ep.data(), ep.size());
}
 
template <typename EndpointT>
inline std::size_t sendto(int sockfd, const void* buf, std::size_t len, int flags,
                          const EndpointT& ep)
{
    return sendto(sockfd, buf, len, flags, *ep.data(), ep.size());
}
 
template <typename EndpointT>
inline ssize_t sendto(int sockfd, ConstBuffer buf, int flags, const EndpointT& ep,
                      std::error_code& ec) noexcept
{
    return sendto(sockfd, buffer_cast<const void*>(buf), buffer_size(buf), flags, *ep.data(),
                  ep.size(), ec);
}
 
template <typename EndpointT>
inline std::size_t sendto(int sockfd, ConstBuffer buf, int flags, const EndpointT& ep)
{
    return sendto(sockfd, buffer_cast<const void*>(buf), buffer_size(buf), flags, *ep.data(),
                  ep.size());
}
 
inline void getsockname(int sockfd, sockaddr& addr, socklen_t& addrlen,
                        std::error_code& ec) noexcept
{
    // The addrlen argument is updated to contain the actual size of the source address.
    // The returned address is truncated if the buffer provided is too small.
    if (::getsockname(sockfd, &addr, &addrlen) < 0) {
        ec = make_error(errno);
    }
}
 
inline void getsockname(int sockfd, sockaddr& addr, socklen_t& addrlen)
{
    // The addrlen argument is updated to contain the actual size of the source address.
    // The returned address is truncated if the buffer provided is too small.
    if (::getsockname(sockfd, &addr, &addrlen) < 0) {
        throw std::system_error{make_error(errno), "getsockname"};
    }
}
 
template <typename EndpointT>
inline void getsockname(int sockfd, EndpointT& ep, std::error_code& ec) noexcept
{
    socklen_t addrlen = ep.capacity();
    getsockname(sockfd, *ep.data(), addrlen, ec);
    if (!ec) {
        ep.resize(std::min<std::size_t>(addrlen, ep.capacity()));
    }
}
 
template <typename EndpointT>
inline void getsockname(int sockfd, EndpointT& ep)
{
    socklen_t addrlen = ep.capacity();
    getsockname(sockfd, *ep.data(), addrlen);
    ep.resize(std::min<std::size_t>(addrlen, ep.capacity()));
}
 
inline void getsockopt(int sockfd, int level, int optname, void* optval, socklen_t& optlen,
                       std::error_code& ec) noexcept
{
    if (::getsockopt(sockfd, level, optname, optval, &optlen) < 0) {
        ec = make_error(errno);
    }
}
 
inline void getsockopt(int sockfd, int level, int optname, void* optval, socklen_t& optlen)
{
    if (::getsockopt(sockfd, level, optname, optval, &optlen) < 0) {
        throw std::system_error{make_error(errno), "getsockopt"};
    }
}
 
inline void setsockopt(int sockfd, int level, int optname, const void* optval, socklen_t optlen,
                       std::error_code& ec) noexcept
{
    if (::setsockopt(sockfd, level, optname, optval, optlen) < 0) {
        ec = make_error(errno);
    }
}
 
inline void setsockopt(int sockfd, int level, int optname, const void* optval, socklen_t optlen)
{
    if (::setsockopt(sockfd, level, optname, optval, optlen) < 0) {
        throw std::system_error{make_error(errno), "setsockopt"};
    }
}
 
} // namespace os
inline namespace net {
 
TOOLBOX_API AddrInfoPtr get_unix_addrinfo(std::string_view path, int type);
 
template <typename EndpointT>
inline void get_sock_name(int sockfd, EndpointT& ep, std::error_code& ec) noexcept
{
    os::getsockname(sockfd, ep, ec);
}
 
template <typename EndpointT>
inline void get_sock_name(int sockfd, EndpointT& ep)
{
    os::getsockname(sockfd, ep);
}
 
inline std::error_code get_so_error(int sockfd, std::error_code& ec) noexcept
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &optval, optlen, ec);
    return make_error(optval);
}
 
inline std::error_code get_so_error(int sockfd)
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &optval, optlen);
    return make_error(optval);
}
 
inline int get_so_rcv_buf(int sockfd, std::error_code& ec) noexcept
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, &optval, optlen, ec);
    return optval;
}
 
inline int get_so_rcv_buf(int sockfd)
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, &optval, optlen);
    return optval;
}
 
inline int get_so_snd_buf(int sockfd, std::error_code& ec) noexcept
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, SOL_SOCKET, SO_SNDBUF, &optval, optlen, ec);
    return optval;
}
 
inline int get_so_snd_buf(int sockfd)
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, SOL_SOCKET, SO_SNDBUF, &optval, optlen);
    return optval;
}
 
inline bool is_tcp_no_delay(int sockfd, std::error_code& ec) noexcept
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, &optval, optlen, ec);
    return optval != 0;
}
 
inline bool is_tcp_no_delay(int sockfd)
{
    int optval{};
    socklen_t optlen{sizeof(optval)};
    os::getsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, &optval, optlen);
    return optval != 0;
}
 
inline void set_so_rcv_buf(int sockfd, int size, std::error_code& ec) noexcept
{
    os::setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, &size, sizeof(size), ec);
}
 
inline void set_so_rcv_buf(int sockfd, int size)
{
    os::setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, &size, sizeof(size));
}
 
inline void set_so_reuse_addr(int sockfd, bool enabled, std::error_code& ec) noexcept
{
    int optval{enabled ? 1 : 0};
    os::setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval), ec);
}
 
inline void set_so_reuse_addr(int sockfd, bool enabled)
{
    int optval{enabled ? 1 : 0};
    os::setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval));
}
 
inline void set_so_snd_buf(int sockfd, int size, std::error_code& ec) noexcept
{
    os::setsockopt(sockfd, SOL_SOCKET, SO_SNDBUF, &size, sizeof(size), ec);
}
 
inline void set_so_snd_buf(int sockfd, int size)
{
    os::setsockopt(sockfd, SOL_SOCKET, SO_SNDBUF, &size, sizeof(size));
}
 
inline void set_tcp_no_delay(int sockfd, bool enabled, std::error_code& ec) noexcept
{
    int optval{enabled ? 1 : 0};
    os::setsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, &optval, sizeof(optval), ec);
}
 
inline void set_tcp_no_delay(int sockfd, bool enabled)
{
    int optval{enabled ? 1 : 0};
    os::setsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, &optval, sizeof(optval));
}
 
inline void set_tcp_syn_nt(int sockfd, int retrans, std::error_code& ec) noexcept
{
    os::setsockopt(sockfd, IPPROTO_TCP, TCP_SYNCNT, &retrans, sizeof(retrans), ec);
}
 
inline void set_tcp_syn_nt(int sockfd, int retrans)
{
    os::setsockopt(sockfd, IPPROTO_TCP, TCP_SYNCNT, &retrans, sizeof(retrans));
}
 
struct Sock : FileHandle {
    Sock(FileHandle&& sock, int family)
    : FileHandle{std::move(sock)}
    , family_{family}
    {
    }
    Sock() noexcept = default;
 
    int family() const noexcept { return family_; }
    bool is_ip_family() const noexcept { return family_ == AF_INET || family_ == AF_INET6; }
 
    // Logically const.
    std::error_code get_error(std::error_code& ec) const noexcept
    {
        return toolbox::get_so_error(get(), ec);
    }
    std::error_code get_error() const { return toolbox::get_so_error(get()); }
 
    int get_rcv_buf(std::error_code& ec) const noexcept
    {
        return toolbox::get_so_rcv_buf(get(), ec);
    }
    int get_rcv_buf() const { return toolbox::get_so_rcv_buf(get()); }
 
    int get_snd_buf(std::error_code& ec) const noexcept
    {
        return toolbox::get_so_snd_buf(get(), ec);
    }
    int get_snd_buf() const { return toolbox::get_so_snd_buf(get()); }
 
    bool is_tcp_no_delay(std::error_code& ec) const noexcept
    {
        return toolbox::is_tcp_no_delay(get(), ec);
    }
    bool is_tcp_no_delay() const { return toolbox::is_tcp_no_delay(get()); }
    void close() { reset(); }
 
    void set_non_block(std::error_code& ec) noexcept { toolbox::set_non_block(get(), ec); }
    void set_non_block() { toolbox::set_non_block(get()); }
 
    void set_rcv_buf(int size, std::error_code& ec) noexcept
    {
        toolbox::set_so_rcv_buf(get(), size, ec);
    }
    void set_rcv_buf(int size) { toolbox::set_so_rcv_buf(get(), size); }
 
    void set_reuse_addr(bool enabled, std::error_code& ec) noexcept
    {
        toolbox::set_so_reuse_addr(get(), enabled, ec);
    }
    void set_reuse_addr(bool enabled) { toolbox::set_so_reuse_addr(get(), enabled); }
 
    void set_snd_buf(int size, std::error_code& ec) noexcept
    {
        toolbox::set_so_snd_buf(get(), size, ec);
    }
    void set_snd_buf(int size) { toolbox::set_so_snd_buf(get(), size); }
 
  private:
    int family_{};
};
 
} // namespace net
} // namespace toolbox
 
#endif // TOOLBOX_NET_SOCKET_HPP