Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

fixes stalling client reconnect issue

Browse source
This commit is contained in:
Lex Berezhny 2021-03-03 12:06:38 -05:00
parent f6d0847453
commit 9815ddef1f
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lbry/wallet/network.py
View file

@ -296,10 +296,13 @@ class Network:
log.info("maintaining connection to spv server %s", server_str) log.info("maintaining connection to spv server %s", server_str)
self._keepalive_task = asyncio.create_task(self.client.keepalive_loop()) self._keepalive_task = asyncio.create_task(self.client.keepalive_loop())
try: try:
if not self._urgent_need_reconnect.is_set():
await asyncio.wait( await asyncio.wait(
[self._keepalive_task, self._urgent_need_reconnect.wait()], [self._keepalive_task, self._urgent_need_reconnect.wait()],
return_when=asyncio.FIRST_COMPLETED return_when=asyncio.FIRST_COMPLETED
) )
else:
await self._keepalive_task
if self._urgent_need_reconnect.is_set(): if self._urgent_need_reconnect.is_set():
log.warning("urgent reconnect needed") log.warning("urgent reconnect needed")
self._urgent_need_reconnect.clear() self._urgent_need_reconnect.clear()