Unsignedio
/
Reticulum
mirror of https://github.com/markqvist/Reticulum.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Tuned QUEUED_ANNOUNCES. Logging.

master
Mark Qvist 2026-08-25 12:08:43 +02:00
parent 47add6381d
commit 0536b972d7
No known key found for this signature in database
2 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
RNS/Reticulum.py
View File

@ -108,8 +108,8 @@ class Reticulum:
discovery significantly increases throughput over fast links.
"""
MAX_QUEUED_ANNOUNCES = 16384
QUEUED_ANNOUNCE_LIFE = 60*60*24
MAX_QUEUED_ANNOUNCES = 4096
QUEUED_ANNOUNCE_LIFE = 60*60*3
ANNOUNCE_CAP = 2
"""

23
RNS/Transport.py
View File

@ -1563,20 +1563,19 @@ class Transport:
timer = threading.Timer(wait_time, interface.process_announce_queue)
timer.start()
if wait_time < 1: wait_time_str = str(round(wait_time*1000,2))+"ms"
else: wait_time_str = str(round(wait_time*1,2))+"s"
ql_str = str(len(interface.announce_queue))
RNS.log("Added announce to queue (height "+ql_str+") on "+str(interface)+" for processing in "+wait_time_str, RNS.LOG_EXTREME) if RNS.sl(RNS.LOG_EXTREME) else None
if RNS.sl(RNS.LOG_EXTREME):
if wait_time < 1: wait_time_str = str(round(wait_time*1000,2))+"ms"
else: wait_time_str = str(round(wait_time*1,2))+"s"
ql_str = str(len(interface.announce_queue))
RNS.log("Added announce to queue (height "+ql_str+") on "+str(interface)+" for processing in "+wait_time_str, RNS.LOG_EXTREME)
else:
wait_time = max(interface.announce_allowed_at - time.time(), 0)
if wait_time < 1: wait_time_str = str(round(wait_time*1000,2))+"ms"
else: wait_time_str = str(round(wait_time*1,2))+"s"
ql_str = str(len(interface.announce_queue))
RNS.log("Added announce to queue (height "+ql_str+") on "+str(interface)+" for processing in "+wait_time_str, RNS.LOG_EXTREME) if RNS.sl(RNS.LOG_EXTREME) else None
if RNS.sl(RNS.LOG_EXTREME):
wait_time = max(interface.announce_allowed_at - time.time(), 0)
if wait_time < 1: wait_time_str = str(round(wait_time*1000,2))+"ms"
else: wait_time_str = str(round(wait_time*1,2))+"s"
ql_str = str(len(interface.announce_queue))
RNS.log("Added announce to queue (height "+ql_str+") on "+str(interface)+" for processing in "+wait_time_str, RNS.LOG_EXTREME)
else: pass