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

Sync sequence set up

Browse Source
This commit is contained in:
Mark Qvist 2021-10-03 10:24:24 +02:00
parent 093d4f1317
commit 354e1932dc
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
LXMF/LXMF.py
View File

@ -547,6 +547,7 @@ class LXMPeer:
# TODO: Remove # TODO: Remove
RNS.log("Sending sync request to peer") RNS.log("Sending sync request to peer")
self.link.request(LXMPeer.OFFER_REQUEST_PATH, unhandled_ids, response_callback=self.offer_response, failed_callback=self.request_failed) self.link.request(LXMPeer.OFFER_REQUEST_PATH, unhandled_ids, response_callback=self.offer_response, failed_callback=self.request_failed)
self.state = LXMPeer.REQUEST_SENT
else: else:
# TODO: Remove # TODO: Remove
RNS.log("No unsynced messages") RNS.log("No unsynced messages")
@ -570,8 +571,10 @@ class LXMPeer:
if response == LXMPeer.ERROR_NO_IDENTITY: if response == LXMPeer.ERROR_NO_IDENTITY:
if self.link != None: if self.link != None:
RNS.log("Remote peer indicated that no identification was received, retrying...", RNS.LOG_DEBUG)
self.link.indentify() self.link.indentify()
self.state = LXMPeer.LINK_READY self.state = LXMPeer.LINK_READY
self.sync()
elif response == False: elif response == False:
# Peer already has all advertised messages # Peer already has all advertised messages
@ -631,6 +634,7 @@ class LXMPeer:
def link_established(self, link): def link_established(self, link):
self.link.identify(self.router.identity) self.link.identify(self.router.identity)
self.state = LXMPeer.LINK_READY self.state = LXMPeer.LINK_READY
self.sync()
def link_closed(self, link): def link_closed(self, link):
self.link = None self.link = None