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

lnbase: do not revoke more than once if we have missed reading commitments

Browse source
This commit is contained in:
Janus 2018-07-09 13:25:09 +02:00 • committed by SomberNight
parent 014d25ff28
commit be068de6a0
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/lnbase.py
View file

@ -862,8 +862,9 @@ class Peer(PrintError):
if failure_coro.done(): if failure_coro.done():
sig_64, htlc_sigs = chan.sign_next_commitment() sig_64, htlc_sigs = chan.sign_next_commitment()
self.send_message(gen_msg("commitment_signed", channel_id=chan.channel_id, signature=sig_64, num_htlcs=1, htlc_signature=htlc_sigs[0])) self.send_message(gen_msg("commitment_signed", channel_id=chan.channel_id, signature=sig_64, num_htlcs=1, htlc_signature=htlc_sigs[0]))
while (await self.commitment_signed[chan.channel_id].get())["htlc_signature"] != b"":
self.revoke(chan) self.revoke(chan)
while (await self.commitment_signed[chan.channel_id].get())["htlc_signature"] != b"":
pass
# TODO process above commitment transactions # TODO process above commitment transactions
await self.receive_revoke(chan) await self.receive_revoke(chan)
chan.fail_htlc(htlc) chan.fail_htlc(htlc)
@ -880,11 +881,11 @@ class Peer(PrintError):
preimage = update_fulfill_htlc_msg["payment_preimage"] preimage = update_fulfill_htlc_msg["payment_preimage"]
chan.receive_htlc_settle(preimage, int.from_bytes(update_fulfill_htlc_msg["id"], "big")) chan.receive_htlc_settle(preimage, int.from_bytes(update_fulfill_htlc_msg["id"], "big"))
while (await self.commitment_signed[chan.channel_id].get())["htlc_signature"] != b"":
self.revoke(chan) self.revoke(chan)
# TODO process above commitment transactions
self.revoke(chan) while (await self.commitment_signed[chan.channel_id].get())["htlc_signature"] != b"":
pass
# TODO process above commitment transactions
bare_ctx = chan.make_commitment(chan.remote_state.ctn + 1, False, chan.remote_state.next_per_commitment_point, bare_ctx = chan.make_commitment(chan.remote_state.ctn + 1, False, chan.remote_state.next_per_commitment_point,
msat_remote, msat_local) msat_remote, msat_local)