Mirror/Reticulum
1
0
Fork 0
mirror of https://github.com/markqvist/Reticulum.git synced 2026-07-27 01:58:10 -07:00
Code Issues Packages Projects Releases Wiki Activity

Allow boundary -> boundary and boundary -> gateway path requests

Browse Source
This commit is contained in:
Mark Qvist
2026-07-22 17:53:04 +02:00
parent 4838875691
commit b051e76d00
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
RNS/Interfaces/Interface.py
+2 -1
View File
@@ -52,7 +52,8 @@ class Interface:
# Which interface modes a Transport Node should # Which interface modes a Transport Node should
# actively discover paths for. # actively discover paths for.
DISCOVER_PATHS_FOR = [MODE_ACCESS_POINT, MODE_GATEWAY, MODE_ROAMING, MODE_INTERNAL] DISCOVER_PATHS_FOR = [MODE_ACCESS_POINT, MODE_GATEWAY, MODE_ROAMING, MODE_INTERNAL]
BOUNDARY_SEARCH_MODES = [MODE_BOUNDARY, MODE_GATEWAY]
# How many samples to use for announce # How many samples to use for announce
# frequency calculations # frequency calculations
RNS/Transport.py
+6 -1
View File
@@ -2945,13 +2945,17 @@ class Transport:
@staticmethod @staticmethod
def path_request(destination_hash, is_from_local_client, attached_interface, requestor_transport_id=None, tag=None): def path_request(destination_hash, is_from_local_client, attached_interface, requestor_transport_id=None, tag=None):
should_search_for_unknown = False should_search_for_unknown = False
should_ingress_limit = False should_ingress_limit = False
search_mode_filter = None
if attached_interface != None: if attached_interface != None:
should_ingress_limit = attached_interface.should_ingress_limit_pr() should_ingress_limit = attached_interface.should_ingress_limit_pr()
if RNS.Reticulum.transport_enabled(): if RNS.Reticulum.transport_enabled():
if attached_interface.recursive_prs: should_search_for_unknown = True if attached_interface.recursive_prs: should_search_for_unknown = True
elif attached_interface.mode in RNS.Interfaces.Interface.Interface.DISCOVER_PATHS_FOR: should_search_for_unknown = True elif attached_interface.mode in RNS.Interfaces.Interface.Interface.DISCOVER_PATHS_FOR: should_search_for_unknown = True
elif attached_interface.mode == RNS.Interfaces.Interface.Interface.MODE_BOUNDARY:
should_search_for_unknown = True
search_mode_filter = RNS.Interfaces.Interface.Interface.BOUNDARY_SEARCH_MODES
if RNS.sl(RNS.LOG_PATHING): if RNS.sl(RNS.LOG_PATHING):
interface_str = f" on {attached_interface}" interface_str = f" on {attached_interface}"
@@ -3068,6 +3072,7 @@ class Transport:
with Transport.discovery_pr_lock: Transport.discovery_path_requests[destination_hash] = pr_entry with Transport.discovery_pr_lock: Transport.discovery_path_requests[destination_hash] = pr_entry
for interface in Transport.interfaces: for interface in Transport.interfaces:
if search_mode_filter and not interface.mode in search_mode_filter: continue
if not interface == attached_interface: if not interface == attached_interface:
if interface.should_egress_limit_pr(): if interface.should_egress_limit_pr():
RNS.log(f"Not sending recursive path request on {interface} due to active egress limiting", RNS.LOG_EXTREME) if RNS.sl(RNS.LOG_EXTREME) else None RNS.log(f"Not sending recursive path request on {interface} due to active egress limiting", RNS.LOG_EXTREME) if RNS.sl(RNS.LOG_EXTREME) else None