tfix regression in shutdown (from 1c5dc7929838fbb7307faeac6506c95821002049) - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 0bf09d14a05caf920cf89a277e656a4a9e37a088
DIR parent 34400c0710b2cb2b167e20a49643826565ef36b6
HTML Author: ThomasV <thomasv@electrum.org>
Date: Thu, 27 Feb 2020 19:01:06 +0100
fix regression in shutdown (from 1c5dc7929838fbb7307faeac6506c95821002049)
Diffstat:
M electrum/lnpeer.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
---
DIR diff --git a/electrum/lnpeer.py b/electrum/lnpeer.py
t@@ -88,7 +88,7 @@ class Peer(Logger):
self.ordered_messages = ['accept_channel', 'funding_signed', 'funding_created', 'accept_channel', 'channel_reestablish', 'closing_signed']
self.ordered_message_queues = defaultdict(asyncio.Queue) # for messsage that are ordered
self.temp_id_to_id = {} # to forward error messages
- self.shutdown_received = defaultdict(asyncio.Future)
+ self.shutdown_received = {}
self.announcement_signatures = defaultdict(asyncio.Queue)
self.orphan_channel_updates = OrderedDict()
self._local_changed_events = defaultdict(asyncio.Event)
t@@ -1362,6 +1362,7 @@ class Peer(Logger):
@log_exceptions
async def close_channel(self, chan_id: bytes):
chan = self.channels[chan_id]
+ self.shutdown_received[chan_id] = asyncio.Future()
await self.send_shutdown(chan)
payload = await self.shutdown_received[chan_id]
txid = await self._shutdown(chan, payload, True)