jlpoole/LMXF-specification
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Automatically clean messages exceeding propagation transfer limit for peer from unhandled message queues

Browse source
This commit is contained in:
Mark Qvist 2025-01-30 11:30:45 +01:00
commit b94a712bb6
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
LXMF/LXMPeer.py
View file

@ -250,7 +250,7 @@ class LXMPeer:
lxm_size = unhandled_entry[2] lxm_size = unhandled_entry[2]
next_size = cumulative_size + (lxm_size+per_message_overhead) next_size = cumulative_size + (lxm_size+per_message_overhead)
if self.propagation_transfer_limit != None and next_size > (self.propagation_transfer_limit*1000): if self.propagation_transfer_limit != None and next_size > (self.propagation_transfer_limit*1000):
if lxm_size+per_message_overhead > self.propagation_transfer_limit: if lxm_size+per_message_overhead > (self.propagation_transfer_limit*1000):
RNS.log(f"Message {RNS.prettyhexrep(transient_id)} exceeds transfer limit for {self}, considering handled", RNS.LOG_DEBUG) RNS.log(f"Message {RNS.prettyhexrep(transient_id)} exceeds transfer limit for {self}, considering handled", RNS.LOG_DEBUG)
self.remove_unhandled_message(transient_id) self.remove_unhandled_message(transient_id)
self.add_handled_message(transient_id) self.add_handled_message(transient_id)