Added rebalanced time to links

This commit is contained in:
Mark Qvist
2026-07-23 17:14:48 +02:00
parent c4297d318f
commit 6d4523c27e
2 changed files with 7 additions and 4 deletions
+1
View File
@@ -265,6 +265,7 @@ class Link:
self.owner = owner
self.destination = destination
self.expected_hops = None
self.rebalanced = None
self.attached_interface = None
self.__remote_identity = None
self.__track_phy_stats = False
+6 -4
View File
@@ -2297,10 +2297,12 @@ class Transport:
RNS.log(f"Re-balancing path to {RNS.prettyhexrep(link.destination.hash)} at link terminus ({link.expected_hops}->{packet.hops})", REBALANCE_LOGLEVEL) if RNS.sl(REBALANCE_LOGLEVEL) else None
link.expected_hops = packet.hops
with Transport.path_table_lock:
if link.destination.hash in Transport.path_table:
path_entry = Transport.path_table[link.destination.hash]
path_entry[IDX_PT_HOPS] = packet.hops
RNS.log(f"Path table re-balanced for {RNS.prettyhexrep(link.destination.hash)}", REBALANCE_LOGLEVEL) if RNS.sl(REBALANCE_LOGLEVEL) else None
if not link.rebalanced:
link.rebalanced = time.time()
if link.destination.hash in Transport.path_table:
path_entry = Transport.path_table[link.destination.hash]
path_entry[IDX_PT_HOPS] = packet.hops
RNS.log(f"Path table re-balanced for {RNS.prettyhexrep(link.destination.hash)}", REBALANCE_LOGLEVEL) if RNS.sl(REBALANCE_LOGLEVEL) else None
else: RNS.log(f"Aborting path re-balancing at link terminus for {RNS.prettyhexrep(link.destination.hash)} on link {link} due to invalid signature", REBALANCE_LOGLEVEL) if RNS.sl(REBALANCE_LOGLEVEL) else None
except Exception as e: RNS.log("Error while validating link request proof for path re-balancing at link terminus. The contained exception was: "+str(e), REBALANCE_LOGLEVEL) if RNS.sl(REBALANCE_LOGLEVEL) else None