Mercurial > crates > systemd-socket
diff tests/comm.rs @ 28:cfef4593e207
Run `cargo fmt`.
author | Paul Fisher <paul@pfish.zone> |
---|---|
date | Sat, 19 Apr 2025 01:33:50 -0400 |
parents | 1941e9d9819c |
children |
line wrap: on
line diff
--- a/tests/comm.rs Fri Feb 28 23:15:59 2025 +0100 +++ b/tests/comm.rs Sat Apr 19 01:33:50 2025 -0400 @@ -1,6 +1,6 @@ -use std::process::Child; use std::ffi::OsStr; use std::io::{self, Read, Write}; +use std::process::Child; pub trait Test { const SOCKET_ADDR: &'static str; @@ -17,14 +17,22 @@ // give slave some time to bind the socket just to be sure std::thread::sleep(std::time::Duration::from_secs(5)); - if let Some(exited) = slave.try_wait().expect("failed to check if the child exited") { + if let Some(exited) = slave + .try_wait() + .expect("failed to check if the child exited") + { panic!("child exited unexpectedly: {}", exited); } - let mut client_socket = std::net::TcpStream::connect("localhost:4242").expect("Failed to connect to 127.0.0.1:4242"); - client_socket.write_all(REQUEST).expect("failed to send data"); + let mut client_socket = std::net::TcpStream::connect("localhost:4242") + .expect("Failed to connect to 127.0.0.1:4242"); + client_socket + .write_all(REQUEST) + .expect("failed to send data"); let mut buf = [0u8; RESPONSE.len()]; - client_socket.read_exact(&mut buf).expect("failed to read response"); + client_socket + .read_exact(&mut buf) + .expect("failed to read response"); assert_eq!(buf, RESPONSE); let status = slave.wait().expect("faild to wait for slave"); @@ -49,9 +57,13 @@ let (mut client_socket, _) = socket.accept().expect("failed to accept"); let mut buf = [0u8; REQUEST.len()]; - client_socket.read_exact(&mut buf).expect("failed to read response"); + client_socket + .read_exact(&mut buf) + .expect("failed to read response"); assert_eq!(buf, REQUEST); - client_socket.write_all(RESPONSE).expect("failed to send data"); + client_socket + .write_all(RESPONSE) + .expect("failed to send data"); } pub fn main<T: Test>() {