stream

Author: kouhe3

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

@@ -3,7 +3,7 @@ use core::mem;
 use super::sockaddr_un;
 use crate::io;
 use crate::os::raw::c_int;
-use crate::os::windows::net::{SocketAddr, from_sockaddr_un};
+use crate::os::windows::net::{SocketAddr, UnixStream, from_sockaddr_un};
 use crate::path::Path;
 use crate::sys::c::{self, bind, getsockname, listen};
 use crate::sys::cvt;
@@ -13,7 +13,6 @@ use crate::sys::net::Socket;
 pub struct UnixListener(Socket);
 #[stable(feature = "rust1", since = "1.0.0")]
 
-pub struct UnixStream(Socket);
 impl UnixListener {
     #[stable(feature = "rust1", since = "1.0.0")]
     pub fn bind<P: AsRef<Path>>(path: &Path) -> io::Result<UnixListener> {

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

@@ -2,7 +2,10 @@
 
 mod addr;
 mod listener;
+mod stream;
 #[stable(feature = "rust1", since = "1.0.0")]
 pub use addr::*;
 #[stable(feature = "rust1", since = "1.0.0")]
 pub use listener::*;
+#[stable(feature = "rust1", since = "1.0.0")]
+pub use stream::*;

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

@@ -0,0 +1,70 @@
+#![stable(feature = "rust1", since = "1.0.0")]
+
+use core::time::Duration;
+
+use crate::io;
+use crate::net::Shutdown;
+use crate::os::windows::net::{SocketAddr, sockaddr_un};
+use crate::path::Path;
+use crate::sys::c::{SO_RCVTIMEO, SO_SNDTIMEO, connect, getpeername, getsockname};
+use crate::sys::cvt;
+use crate::sys::net::Socket;
+
+#[stable(feature = "rust1", since = "1.0.0")]
+pub struct UnixStream(pub Socket);
+impl UnixStream {
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn connect<P: AsRef<Path>>(path: P) -> io::Result<UnixStream> {
+        unsafe {
+            let inner = Socket::new_unix()?;
+            let (addr, len) = sockaddr_un(path.as_ref())?;
+            cvt(connect(inner.as_raw() as _, &addr as *const _ as *const _, len))?;
+            Ok(UnixStream(inner))
+        }
+    }
+    #[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 pair() -> io::Result<(Self, Self)> {
+        unimplemented!()
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn peer_addr(&self) -> io::Result<SocketAddr> {
+        SocketAddr::new(|addr, len| unsafe { getpeername(self.0.as_raw() as _, addr, len) })
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn read_timeout(&self) -> io::Result<Option<Duration>> {
+        self.0.timeout(SO_RCVTIMEO)
+    }
+    #[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 set_read_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
+        self.0.set_timeout(dur, SO_RCVTIMEO)
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn set_write_timeout(&self, dur: Option<Duration>) -> io::Result<()> {
+        self.0.set_timeout(dur, SO_SNDTIMEO)
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn shutdown(&self, how: Shutdown) -> io::Result<()> {
+        self.0.shutdown(how)
+    }
+    #[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 try_clone(&self) -> io::Result<UnixStream> {
+        self.0.duplicate().map(UnixStream)
+    }
+    #[stable(feature = "rust1", since = "1.0.0")]
+    pub fn write_timeout(&self) -> io::Result<Option<Duration>> {
+        self.0.timeout(SO_SNDTIMEO)
+    }
+}