diff --git a/src/ip_sink.rs b/src/ip_sink.rs index a209da9..b9226f7 100644 --- a/src/ip_sink.rs +++ b/src/ip_sink.rs @@ -13,7 +13,9 @@ pub async fn run_ip_sink_interface(wg: Arc) -> ! { // No sockets on sink interface let mut sockets: [_; 0] = Default::default(); - let mut virtual_interface = InterfaceBuilder::new(device, &mut sockets[..]).ip_addrs([]).finalize(); + let mut virtual_interface = InterfaceBuilder::new(device, &mut sockets[..]) + .ip_addrs([]) + .finalize(); loop { let loop_start = smoltcp::time::Instant::now(); diff --git a/src/virtual_iface/tcp.rs b/src/virtual_iface/tcp.rs index d34357a..340242a 100644 --- a/src/virtual_iface/tcp.rs +++ b/src/virtual_iface/tcp.rs @@ -77,7 +77,7 @@ impl VirtualInterfacePoll for TcpVirtualInterface { let device = VirtualIpDevice::new_direct(VirtualPort(self.virtual_port, PortProtocol::Tcp), self.wg) .with_context(|| "Failed to initialize TCP VirtualIpDevice")?; - + // there are always 2 sockets: 1 virtual client and 1 virtual server. let mut sockets: [_; 2] = Default::default(); let mut virtual_interface = InterfaceBuilder::new(device, &mut sockets[..]) @@ -158,7 +158,8 @@ impl VirtualInterfacePoll for TcpVirtualInterface { } { - let (client_socket, context) = virtual_interface.get_socket_and_context::(client_handle); + let (client_socket, context) = + virtual_interface.get_socket_and_context::(client_handle); if !shutdown && client_socket.state() == TcpState::Closed && !has_connected { // Not shutting down, but the client socket is closed, and the client never successfully connected.