rt/Reticulum
1
0
Fork 0
mirror of https://github.com/markqvist/Reticulum.git synced 2026-10-26 19:01:53 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Worker spawn prep

Browse source
This commit is contained in:
Mark Qvist 2026-08-28 12:44:59 +02:00
parent b28f5ebf7a
commit 6e8c976421
No known key found for this signature in database
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
RNS/Transport.py
View file

@ -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