From 0bf09d14a05caf920cf89a277e656a4a9e37a088 Mon Sep 17 00:00:00 2001 From: ThomasV Date: Thu, 27 Feb 2020 19:01:06 +0100 Subject: [PATCH] fix regression in shutdown (from 1c5dc7929838fbb7307faeac6506c95821002049) --- electrum/lnpeer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/electrum/lnpeer.py b/electrum/lnpeer.py index c571dc1e1..9b5295d5f 100644 --- a/electrum/lnpeer.py +++ b/electrum/lnpeer.py @@ -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) @@ -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)