From 30582fee76ccdf62a72d9f79dea0b8378b270322 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jon=20H=C3=A4ggblad?= Date: Mon, 16 Oct 2023 10:15:23 +0200 Subject: [PATCH] Add missing continue --- common/wireguard/src/setup.rs | 2 +- common/wireguard/src/udp_listener.rs | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/common/wireguard/src/setup.rs b/common/wireguard/src/setup.rs index 3fd948f487e..b01442258ad 100644 --- a/common/wireguard/src/setup.rs +++ b/common/wireguard/src/setup.rs @@ -50,7 +50,7 @@ pub fn peer_static_public_key() -> x25519::PublicKey { let peer_static_public_bytes: [u8; 32] = decode_base64_key(PEER); let peer_static_public = x25519::PublicKey::try_from(peer_static_public_bytes).unwrap(); info!( - "peer public key: {}", + "Adding wg peer public key: {}", general_purpose::STANDARD.encode(peer_static_public) ); peer_static_public diff --git a/common/wireguard/src/udp_listener.rs b/common/wireguard/src/udp_listener.rs index 5c943d25fd3..959258dcb0e 100644 --- a/common/wireguard/src/udp_listener.rs +++ b/common/wireguard/src/udp_listener.rs @@ -110,6 +110,7 @@ pub(crate) async fn start_udp_listener( .send(Event::Wg(buf[..len].to_vec().into())) .tap_err(|e| log::error!("{e}")) .ok(); + continue; } // Verify the incoming packet @@ -171,7 +172,7 @@ pub(crate) async fn start_udp_listener( log::info!("udp: received {len} bytes from {addr} from unknown peer, starting tunnel"); // NOTE: we are NOT passing in the existing rate_limiter. Re-visit this // choice later. - log::warn!("Creating new rate limiter, consider re-using"); + log::warn!("Creating new rate limiter, consider re-using?"); let (join_handle, peer_tx) = crate::wg_tunnel::start_wg_tunnel( addr, udp.clone(),