accept.h

Go to the documentation of this file.

 
#ifndef QB_IO_TRANSPORT_ACCEPT_H_
#define QB_IO_TRANSPORT_ACCEPT_H_
#include "../tcp/listener.h"
 
namespace qb::io::transport {

class accept {
    io::tcp::listener _io;          
    io::tcp::socket   _accepted_io; 
 
public:
    constexpr bool is_secure() const noexcept { return false; }
    using transport_io_type = io::tcp::listener;

    using socket_type = io::tcp::socket;

    io::tcp::listener &
    transport() noexcept {
        return _io;
    }

    std::size_t
    read() noexcept {
        if (_io.accept(_accepted_io) == io::SocketStatus::Done)
            return static_cast<std::size_t>(_accepted_io.native_handle());
        return static_cast<std::size_t>(-1);
    }

    void
    flush(std::size_t) noexcept {
        _accepted_io.release_handle();
    }

    void
    eof() const noexcept {}

    void
    close() noexcept {
        _io.close();
    }

    io::tcp::socket &
    getAccepted() {
        return _accepted_io;
    }
};
 
} // namespace qb::io::transport
 
#endif // QB_IO_TRANSPORT_ACCEPT_H_