tlnpeer: move ping_if_required away from message_loop - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 821431a23913349ae1c698b7653f42fc91ccb241
DIR parent bddb0bfcdd1c89528d1e3938414ea0cde9e7bea7
HTML Author: ThomasV <thomasv@electrum.org>
Date: Mon, 13 Apr 2020 11:34:58 +0200
lnpeer: move ping_if_required away from message_loop
If our connection dies because we went to sleep, message_loop
will stall and ping_if_required will never be called.
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@@ -463,7 +463,6 @@ class Peer(Logger):
async for msg in self.transport.read_messages():
self.process_message(msg)
await asyncio.sleep(.01)
- self.ping_if_required()
def on_reply_short_channel_ids_end(self, payload):
self.querying.set()
t@@ -1452,8 +1451,10 @@ class Peer(Logger):
return closing_tx.txid()
async def htlc_switch(self):
+ await self.initialized
while True:
await asyncio.sleep(0.1)
+ self.ping_if_required()
for chan_id, chan in self.channels.items():
if not chan.can_send_ctx_updates():
continue