LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-08-28 07:51:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

lnbase: resend revoke_and_ack if necessary

Browse source
This commit is contained in:
Janus 2018-10-12 18:42:57 +02:00 • committed by SomberNight
parent 0c52c1cc8d
commit 04741512ce
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
1 changed files with 18 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
electrum/lnbase.py
View file

@ -816,10 +816,24 @@ class Peer(PrintError):
# compare local ctns # compare local ctns
local_ctn = int.from_bytes(channel_reestablish_msg["next_remote_revocation_number"], 'big') local_ctn = int.from_bytes(channel_reestablish_msg["next_remote_revocation_number"], 'big')
if local_ctn != chan.config[LOCAL].ctn: if local_ctn != chan.config[LOCAL].ctn:
self.print_error("expected local ctn {}, got {}".format(chan.config[LOCAL].ctn, local_ctn)) if remote_ctn == chan.config[LOCAL].ctn + 1:
# TODO iff their ctn is lower than ours, we should force close instead # A node:
try_to_get_remote_to_force_close_with_their_latest() # if next_remote_revocation_number is equal to the
return # commitment number of the last revoke_and_ack
# the receiving node sent, AND the receiving node
# hasn't already received a closing_signed:
# MUST re-send the revoke_and_ack.
self.config[LOCAL]=self.config[LOCAL]._replace(
ctn=remote_ctn,
)
self.revoke(chan)
self.channel_reestablished[chan_id].set_result(True)
return
else:
self.print_error("expected local ctn {}, got {}".format(chan.config[LOCAL].ctn, local_ctn))
# TODO iff their ctn is lower than ours, we should force close instead
try_to_get_remote_to_force_close_with_their_latest()
return
# compare per commitment points (needs data_protect option) # compare per commitment points (needs data_protect option)
their_pcp = channel_reestablish_msg.get("my_current_per_commitment_point", None) their_pcp = channel_reestablish_msg.get("my_current_per_commitment_point", None)
if their_pcp is not None: if their_pcp is not None: