diff options
Diffstat (limited to 'tokio/tests/uds_datagram.rs')
-rw-r--r-- | tokio/tests/uds_datagram.rs | 34 |
1 files changed, 5 insertions, 29 deletions
diff --git a/tokio/tests/uds_datagram.rs b/tokio/tests/uds_datagram.rs index d3c3535e..bd47f19e 100644 --- a/tokio/tests/uds_datagram.rs +++ b/tokio/tests/uds_datagram.rs @@ -6,8 +6,9 @@ use tokio::net::UnixDatagram; use tokio::try_join; use std::io; +use std::sync::Arc; -async fn echo_server(mut socket: UnixDatagram) -> io::Result<()> { +async fn echo_server(socket: UnixDatagram) -> io::Result<()> { let mut recv_buf = vec![0u8; 1024]; loop { let (len, peer_addr) = socket.recv_from(&mut recv_buf[..]).await?; @@ -32,7 +33,7 @@ async fn echo() -> io::Result<()> { }); { - let mut socket = UnixDatagram::bind(&client_path).unwrap(); + let socket = UnixDatagram::bind(&client_path).unwrap(); socket.connect(server_path)?; socket.send(b"ECHO").await?; let mut recv_buf = [0u8; 16]; @@ -87,8 +88,8 @@ async fn try_send_recv_never_block() -> io::Result<()> { async fn split() -> std::io::Result<()> { let dir = tempfile::tempdir().unwrap(); let path = dir.path().join("split.sock"); - let socket = UnixDatagram::bind(path.clone())?; - let (mut r, mut s) = socket.into_split(); + let s = Arc::new(UnixDatagram::bind(path.clone())?); + let r = s.clone(); let msg = b"hello"; let ((), ()) = try_join! { @@ -106,28 +107,3 @@ async fn split() -> std::io::Result<()> { Ok(()) } - -#[tokio::test] -async fn reunite() -> std::io::Result<()> { - let dir = tempfile::tempdir().unwrap(); - let path = dir.path().join("reunite.sock"); - let socket = UnixDatagram::bind(path)?; - let (s, r) = socket.into_split(); - assert!(s.reunite(r).is_ok()); - Ok(()) -} - -#[tokio::test] -async fn reunite_error() -> std::io::Result<()> { - let dir = tempfile::tempdir().unwrap(); - let path = dir.path().join("reunit.sock"); - let dir = tempfile::tempdir().unwrap(); - let path1 = dir.path().join("reunit.sock"); - let socket = UnixDatagram::bind(path)?; - let socket1 = UnixDatagram::bind(path1)?; - - let (s, _) = socket.into_split(); - let (_, r1) = socket1.into_split(); - assert!(s.reunite(r1).is_err()); - Ok(()) -} |