From 6e8c976421748584b10cf964bfede577370aebd7 Mon Sep 17 00:00:00 2001 From: Mark Qvist Date: Fri, 28 Aug 2026 12:44:59 +0200 Subject: [PATCH] Worker spawn prep --- RNS/Transport.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/RNS/Transport.py b/RNS/Transport.py index eb0e29b8..ca4fab8f 100755 --- a/RNS/Transport.py +++ b/RNS/Transport.py @@ -137,6 +137,7 @@ class Transport: PATH_REQUEST_RG = 1.5 # Extra grace time for roaming-mode interfaces to allow more suitable peers to respond first PATH_REQUEST_MI = 20 # Minimum interval in seconds for automated path requests + TRANSPORT_WORKERS = 1 USE_INBOUND_QUEUE = True USE_OUTBOUND_QUEUE = False INBOUND_DA_QUEUE_LENGTH = 1024 @@ -523,8 +524,10 @@ class Transport: Transport.prioritize_interfaces() # Spawn queue workers - if Transport.USE_INBOUND_QUEUE: threading.Thread(target=Transport.inbound_job, daemon=True).start() - if Transport.USE_OUTBOUND_QUEUE: threading.Thread(target=Transport.outbound_job, daemon=True).start() + for n in range(Transport.TRANSPORT_WORKERS): + if Transport.USE_INBOUND_QUEUE: threading.Thread(target=Transport.inbound_job, daemon=True).start() + if Transport.USE_OUTBOUND_QUEUE: threading.Thread(target=Transport.outbound_job, daemon=True).start() + Transport.ready = True # Synthesize tunnels for any interfaces wanting it