1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161
use crate::net::{Incoming, SocketAddr, TcpStream}; #[cfg(unix)] use std::os::unix::io::{AsRawFd, FromRawFd, IntoRawFd, RawFd}; #[cfg(windows)] use std::os::windows::io::{AsRawSocket, FromRawSocket, IntoRawSocket, RawSocket}; use std::{io, net}; /// A TCP socket server, listening for connections. /// /// This corresponds to [`std::net::TcpListener`]. /// /// Note that this `TcpListener` has no `bind` method. To bind it to a socket /// address, you must first obtain a [`Catalog`] permitting the address, and /// then call [`Catalog::bind_tcp_listener`]. /// /// [`std::net::TcpListener`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html /// [`Catalog`]: struct.Catalog.html /// [`Catalog::bind_tcp_listener`]: struct.Catalog.html#method.bind_tcp_listener pub struct TcpListener { std: net::TcpListener, } impl TcpListener { /// Constructs a new instance of `Self` from the given `std::net::TcpListener`. #[inline] pub fn from_std(std: net::TcpListener) -> Self { Self { std } } /// Returns the local socket address of this listener. /// /// This corresponds to [`std::net::TcpListener::local_addr`]. /// /// [`std::net::TcpListener::local_addr`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.local_addr #[inline] pub fn local_addr(&self) -> io::Result<SocketAddr> { self.std.local_addr() } /// Creates a new independently owned handle to the underlying socket. /// /// This corresponds to [`std::net::TcpListener::try_clone`]. /// /// [`std::net::TcpListener::try_clone`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.try_clone #[inline] pub fn try_clone(&self) -> io::Result<Self> { Ok(Self::from_std(self.std.try_clone()?)) } /// Accept a new incoming connection from this listener. /// /// This corresponds to [`std::net::TcpListener::accept`]. /// /// [`std::net::TcpListener::accept`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.accept #[inline] pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { self.std .accept() .map(|(tcp_stream, addr)| (TcpStream::from_std(tcp_stream), addr)) } /// Returns an iterator over the connections being received on this listener. /// /// This corresponds to [`std::net::TcpListener::incoming`]. /// /// [`std::net::TcpListener::incoming`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.incoming #[inline] pub fn incoming(&self) -> Incoming { Incoming::from_std(self.std.incoming()) } /// Sets the value for the `IP_TTL` option on this socket. /// /// This corresponds to [`std::net::TcpListener::set_ttl`]. /// /// [`std::net::TcpListener::set_ttl`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.set_ttl #[inline] pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { self.std.set_ttl(ttl) } /// Gets the value of the `IP_TTL` option for this socket. /// /// This corresponds to [`std::net::TcpListener::ttl`]. /// /// [`std::net::TcpListener::ttl`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.ttl #[inline] pub fn ttl(&self) -> io::Result<u32> { self.std.ttl() } /// Gets the value of the `SO_ERROR` option on this socket. /// /// This corresponds to [`std::net::TcpListener::take_error`]. /// /// [`std::net::TcpListener::take_error`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.take_error #[inline] pub fn take_error(&self) -> io::Result<Option<io::Error>> { self.std.take_error() } /// Moves this TCP stream into or out of nonblocking mode. /// /// This corresponds to [`std::net::TcpListener::set_nonblocking`]. /// /// [`std::net::TcpListener::set_nonblocking`]: https://doc.rust-lang.org/std/net/struct.TcpListener.html#method.set_nonblocking #[inline] pub fn set_nonblocking(&self, nonblocking: bool) -> io::Result<()> { self.std.set_nonblocking(nonblocking) } } #[cfg(unix)] impl FromRawFd for TcpListener { #[inline] unsafe fn from_raw_fd(fd: RawFd) -> Self { Self::from_std(net::TcpListener::from_raw_fd(fd)) } } #[cfg(windows)] impl FromRawSocket for TcpListener { #[inline] unsafe fn from_raw_socket(socket: RawSocket) -> Self { Self::from_std(net::TcpListener::from_raw_socket(socket)) } } #[cfg(unix)] impl AsRawFd for TcpListener { #[inline] fn as_raw_fd(&self) -> RawFd { self.std.as_raw_fd() } } #[cfg(windows)] impl AsRawSocket for TcpListener { #[inline] fn as_raw_socket(&self) -> RawSocket { self.std.as_raw_socket() } } #[cfg(unix)] impl IntoRawFd for TcpListener { #[inline] fn into_raw_fd(self) -> RawFd { self.std.into_raw_fd() } } #[cfg(windows)] impl IntoRawSocket for TcpListener { #[inline] fn into_raw_socket(self) -> RawSocket { self.std.into_raw_socket() } } // TODO: impl Debug for TcpListener