listener

Author: kouhe3

library/std/src/os/windows/net/addr.rs

@@ -2,7 +2,8 @@
 
 use crate::os::raw::{c_char, c_int};
 use crate::path::Path;
-use crate::sys::c;
+use crate::sys::c::{self, SOCKADDR};
+use crate::sys::cvt;
 use crate::{io, mem};
 #[stable(feature = "rust1", since = "1.0.0")]
 pub fn sockaddr_un(path: &Path) -> io::Result<(c::sockaddr_un, c_int)> {
@@ -52,6 +53,18 @@ pub struct SocketAddr {
     len: c_int,
 }
 impl SocketAddr {
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn new<F>(f: F) -> io::Result<SocketAddr>
+    where
+        F: FnOnce(*mut SOCKADDR, *mut c_int) -> c_int,
+    {
+        unsafe {
+            let mut addr: c::sockaddr_un = mem::zeroed();
+            let mut len = mem::size_of::<c::sockaddr_un>() as c_int;
+            cvt(f(&mut addr as *mut _ as *mut _, &mut len))?;
+            SocketAddr::from_parts(addr, len)
+        }
+    }
     fn from_parts(addr: c::sockaddr_un, mut len: c_int) -> io::Result<SocketAddr> {
         if len == 0 {
             // When there is a datagram from unnamed unix socket

library/std/src/os/windows/net/listener.rs

@@ -5,7 +5,7 @@ use crate::io;
 use crate::os::raw::c_int;
 use crate::os::windows::net::{SocketAddr, from_sockaddr_un};
 use crate::path::Path;
-use crate::sys::c::{self, bind, listen};
+use crate::sys::c::{self, bind, getsockname, listen};
 use crate::sys::cvt;
 use crate::sys::net::Socket;
 #[stable(feature = "rust1", since = "1.0.0")]
@@ -33,4 +33,28 @@ impl UnixListener {
         let addr = from_sockaddr_un(storage, len)?;
         Ok((UnixStream(sock), addr))
     }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn incoming(&self) -> Incoming<'_> {
+        Incoming { listener: self }
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn take_error(&self) -> io::Result<Option<io::Error>> {
+        self.0.take_error()
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn set_nonblocking(&self, nonblocking: bool) -> io::Result<()> {
+        self.0.set_nonblocking(nonblocking)
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn local_addr(&self) -> io::Result<SocketAddr> {
+        SocketAddr::new(|addr, len| unsafe { getsockname(self.0.as_raw() as _, addr, len) })
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn try_clone(&self) -> io::Result<UnixListener> {
+        self.0.duplicate().map(UnixListener)
+    }
+}
+#[stable(feature = "rust1", since = "1.0.0")]
+pub struct Incoming<'a> {
+    listener: &'a UnixListener,
 }