Git-Mirrors/LXMF
1
0
Fork 0
mirror of https://github.com/markqvist/LXMF.git synced 2024-12-17 19:54:19 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fixed sync limit on path response re-trigger

Browse Source
This commit is contained in:
Mark Qvist 2021-10-08 13:55:16 +02:00
parent b2596bd561
commit 71a9f16bde
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
LXMF/LXMF.py
View File

@ -949,7 +949,7 @@ class LXMRouter:
propagation_node_identity = RNS.Identity.recall(self.outbound_propagation_node) propagation_node_identity = RNS.Identity.recall(self.outbound_propagation_node)
propagation_node_destination = RNS.Destination(propagation_node_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, APP_NAME, "propagation") propagation_node_destination = RNS.Destination(propagation_node_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, APP_NAME, "propagation")
def msg_request_established_callback(link): def msg_request_established_callback(link):
self.request_messages_from_propagation_node(identity) self.request_messages_from_propagation_node(identity, self.propagation_transfer_max_messages)
self.outbound_propagation_link = RNS.Link(propagation_node_destination, established_callback=msg_request_established_callback) self.outbound_propagation_link = RNS.Link(propagation_node_destination, established_callback=msg_request_established_callback)
else: else:
@ -977,7 +977,7 @@ class LXMRouter:
time.sleep(0.1) time.sleep(0.1)
if RNS.Transport.has_path(self.wants_download_on_path_available_from): if RNS.Transport.has_path(self.wants_download_on_path_available_from):
self.request_messages_from_propagation_node(self.wants_download_on_path_available_to) self.request_messages_from_propagation_node(self.wants_download_on_path_available_to, self.propagation_transfer_max_messages)
else: else:
RNS.log("Propagation node path request timed out", RNS.LOG_DEBUG) RNS.log("Propagation node path request timed out", RNS.LOG_DEBUG)
self.acknowledge_sync_completion() self.acknowledge_sync_completion()