socket.h

Go to the documentation of this file.

 
#include "../system/sys__socket.h"
#include "../uri.h"
#include <optional>
#include <chrono>
#include <string>
 
#ifndef QB_IO_UDP_SOCKET_H_
#define QB_IO_UDP_SOCKET_H_
 
namespace qb::io::udp {

class QB_API socket : private qb::io::socket {
public:
    constexpr static const std::size_t DefaultDatagramSize = 512;
    
    constexpr static const std::size_t MaxDatagramSize = 65507;
 
    // Methods inherited from the base socket (made public via using-declarations)
    using qb::io::socket::close;
    using qb::io::socket::get_optval;
    using qb::io::socket::is_open;
    using qb::io::socket::local_endpoint;
    using qb::io::socket::native_handle;
    using qb::io::socket::peer_endpoint;
    using qb::io::socket::release_handle;
    using qb::io::socket::set_nonblocking;
    using qb::io::socket::set_optval;
    using qb::io::socket::test_nonblocking;

    socket() = default;

    socket(socket const &) = delete;

    socket(socket &&) = default;

    socket &operator=(socket &&) = default;

    socket(io::socket &&sock) noexcept;

    socket &operator=(io::socket &&sock) noexcept;

    bool init(int af = AF_INET) noexcept;

    int bind(qb::io::endpoint const &ep) noexcept;

    int bind(qb::io::uri const &u) noexcept;

    int bind_v4(uint16_t port, std::string const &host = "0.0.0.0") noexcept;

    int bind_v6(uint16_t port, std::string const &host = "::") noexcept;

    int bind_un(std::string const &path) noexcept;

    int read(void *dest, std::size_t len, qb::io::endpoint &peer) const noexcept;

    int read_timeout(void *dest, std::size_t len, qb::io::endpoint &peer, 
                     const std::chrono::microseconds &timeout) const noexcept;

    int try_read(void *dest, std::size_t len, qb::io::endpoint &peer) const noexcept;

    int write(const void *data, std::size_t len,
              qb::io::endpoint const &to) const noexcept;

    int set_buffer_size(std::size_t size) noexcept;

    int set_broadcast(bool enable) noexcept;

    int join_multicast_group(const std::string &group, 
                             const std::string &iface = "") noexcept;

    int leave_multicast_group(const std::string &group,
                              const std::string &iface = "") noexcept;

    int set_multicast_ttl(int ttl) noexcept;

    int set_multicast_loopback(bool enable) noexcept;

    int address_family() const noexcept;

    bool is_bound() const noexcept;

    int disconnect() const noexcept;
};
 
} // namespace qb::io::udp
 
#endif // QB_IO_UDP_SOCKET_H_