Git-Mirrors/LXMF
1
0
Fork 0
mirror of https://github.com/markqvist/LXMF.git synced 2025-04-14 04:23:11 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

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:23:18 +01:00
parent 9eca747757
commit f42ccfc4e9
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
LXMF/LXMPeer.py
View File

@ -250,7 +250,10 @@ class LXMPeer:
lxm_size = unhandled_entry[2]
next_size = cumulative_size + (lxm_size+per_message_overhead)
if self.propagation_transfer_limit != None and next_size > (self.propagation_transfer_limit*1000):
pass
if lxm_size+per_message_overhead > self.propagation_transfer_limit:
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.add_handled_message(transient_id)
else:
cumulative_size += (lxm_size+per_message_overhead)
unhandled_ids.append(transient_id)