From 35776b5da7335feafbfa72cf7c66f7e5098e5a5a Mon Sep 17 00:00:00 2001 From: Hocuri Date: Fri, 18 Sep 2026 12:17:07 +0200 Subject: [PATCH] small fixes --- src/autorelay.rs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/autorelay.rs b/src/autorelay.rs index 83262da9c..9d5a2de01 100644 --- a/src/autorelay.rs +++ b/src/autorelay.rs @@ -95,11 +95,11 @@ pub(crate) async fn init_transports_inner( let relays_receiver = relays_receiver.clone(); let last_error = last_error.clone(); join_set.spawn(async move { - loop { - // Take a lock in order to prevent other relay management code - // from running simultaneously - let _lock = context.background_task_lock.read().await; + // Take a lock in order to prevent other relay management code + // from running simultaneously + let _lock = context.background_task_lock.read().await; + loop { let Ok(host) = relays_receiver.try_recv() else { return false; // No more relays to try }; @@ -118,6 +118,7 @@ pub(crate) async fn init_transports_inner( .log_err(&context) .ok(); info!(context, "Target number of transports reached."); + context.restart_io_if_running().await; } return true; // Success }