From f049e4a99887d55df1de555cb03ee21c2d942520 Mon Sep 17 00:00:00 2001 From: suchao Date: Tue, 22 Oct 2024 00:08:55 +0800 Subject: [PATCH] minor change --- src/bin/udpgw_server.rs | 2 +- src/lib.rs | 2 +- src/udpgw.rs | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/bin/udpgw_server.rs b/src/bin/udpgw_server.rs index 7090bc4..dc2da57 100644 --- a/src/bin/udpgw_server.rs +++ b/src/bin/udpgw_server.rs @@ -259,7 +259,7 @@ async fn process_client_udp_req(args: &UdpGwArgs, tx: Sender>, client: C log::error!("client {} received packet too long", client.addr); break; } - log::debug!("client {} recvied packet len {}", client.addr, packet_len); + log::trace!("client {} recvied packet len {}", client.addr, packet_len); client.buf.clear(); let mut left_len: usize = packet_len as usize; while left_len > 0 { diff --git a/src/lib.rs b/src/lib.rs index 5db9fdf..ff04568 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -497,7 +497,7 @@ async fn handle_udp_gateway_session( let mut server_stream = match udpgw_client.get_server_connection().await { Some(server) => server, None => { - if udpgw_client.is_full().await { + if udpgw_client.is_full() { return Err("max udpgw connection limit reached".into()); } let mut tcp_server_stream = create_tcp_stream(&socket_queue, server_addr).await?; diff --git a/src/udpgw.rs b/src/udpgw.rs index 45a980d..9118af8 100644 --- a/src/udpgw.rs +++ b/src/udpgw.rs @@ -278,7 +278,7 @@ impl UdpGwClient { self.udp_timeout } - pub(crate) async fn is_full(&self) -> bool { + pub(crate) fn is_full(&self) -> bool { TCP_COUNTER.load(Relaxed) >= self.max_connections as u32 }