From 6aa337c618221acb1af700b8a6972914f8fa5949 Mon Sep 17 00:00:00 2001 From: ThomasV Date: Wed, 27 May 2020 18:13:30 +0200 Subject: [PATCH] fix #6176 --- electrum/lnpeer.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/electrum/lnpeer.py b/electrum/lnpeer.py index fc634e7a9..cac370fa9 100644 --- a/electrum/lnpeer.py +++ b/electrum/lnpeer.py @@ -810,7 +810,13 @@ class Peer(Logger): self.logger.info(f'channel_reestablish ({chan.get_id_for_log()}): sent channel_reestablish with ' f'(next_local_ctn={next_local_ctn}, ' f'oldest_unrevoked_remote_ctn={oldest_unrevoked_remote_ctn})') - msg = await self.wait_for_message('channel_reestablish', chan_id) + while True: + try: + msg = await self.wait_for_message('channel_reestablish', chan_id) + break + except asyncio.TimeoutError: + self.logger.info('waiting to receive channel_reestablish...') + continue their_next_local_ctn = msg["next_commitment_number"] their_oldest_unrevoked_remote_ctn = msg["next_revocation_number"] their_local_pcp = msg.get("my_current_per_commitment_point")