From d924c59c6c1f91c8fdda389ba350c96bba042fac Mon Sep 17 00:00:00 2001 From: archipelago Date: Fri, 24 Jul 2026 04:29:15 -0400 Subject: [PATCH] style: cargo fmt on mesh_ports Co-Authored-By: Claude Fable 5 --- core/archipelago/src/mesh_ports.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/core/archipelago/src/mesh_ports.rs b/core/archipelago/src/mesh_ports.rs index a22f6236..6b211b1c 100644 --- a/core/archipelago/src/mesh_ports.rs +++ b/core/archipelago/src/mesh_ports.rs @@ -110,8 +110,8 @@ async fn listening_ports(path: &str, addr_hex_len: usize) -> Result /// A v6-only listener on [::]:port forwarding each connection to 127.0.0.1:port. fn spawn_forwarder(port: u16) -> Result> { use socket2::{Domain, Protocol, Socket, Type}; - let socket = Socket::new(Domain::IPV6, Type::STREAM, Some(Protocol::TCP)) - .context("create v6 socket")?; + let socket = + Socket::new(Domain::IPV6, Type::STREAM, Some(Protocol::TCP)).context("create v6 socket")?; // v6only so we coexist with the app's own 0.0.0.0: bind. socket.set_only_v6(true).context("set v6only")?; socket.set_reuse_address(true).ok(); @@ -119,8 +119,8 @@ fn spawn_forwarder(port: u16) -> Result> { let addr = SocketAddrV6::new(Ipv6Addr::UNSPECIFIED, port, 0, 0); socket.bind(&addr.into()).context("bind [::]")?; socket.listen(128).context("listen")?; - let listener = tokio::net::TcpListener::from_std(socket.into()) - .context("register with tokio")?; + let listener = + tokio::net::TcpListener::from_std(socket.into()).context("register with tokio")?; Ok(tokio::spawn(async move { loop {