From be8d4cbb8bc42da16f1aeaf97a7fe5516ae9c675 Mon Sep 17 00:00:00 2001 From: lbl8603 <49143209+lbl8603@users.noreply.github.com> Date: Wed, 31 Jul 2024 10:00:28 +0800 Subject: [PATCH] fmt --- vnt/src/channel/punch.rs | 23 +++++++++++------------ 1 file changed, 11 insertions(+), 12 deletions(-) diff --git a/vnt/src/channel/punch.rs b/vnt/src/channel/punch.rs index 7772657..76e476c 100644 --- a/vnt/src/channel/punch.rs +++ b/vnt/src/channel/punch.rs @@ -268,16 +268,15 @@ impl Punch { } let device_info = self.current_device.load(); - nat_info.public_ips.retain(|ip| { - is_ipv4_global(ip) - && device_info.not_in_network(*ip) - }); + nat_info + .public_ips + .retain(|ip| is_ipv4_global(ip) && device_info.not_in_network(*ip)); nat_info.public_ports.retain(|port| *port != 0); nat_info.udp_ports.retain(|port| *port != 0); - nat_info.local_ipv4 = nat_info.local_ipv4.filter(|ip| { - device_info.not_in_network(*ip) - }); + nat_info.local_ipv4 = nat_info + .local_ipv4 + .filter(|ip| device_info.not_in_network(*ip)); if punch_tcp && self.punch_model.use_tcp() && nat_info.tcp_port != 0 { //向tcp发起连接 @@ -383,11 +382,11 @@ impl Punch { } let mut index = start + self.punch_symmetric( - &self.port_vec[start..end], - buf, - &nat_info.public_ips, - max_k2, - )?; + &self.port_vec[start..end], + buf, + &nat_info.public_ips, + max_k2, + )?; if index >= self.port_vec.len() { index = 0 }