LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

on timeout, restore latency to max

Browse source
This commit is contained in:
Victor Shyba 2019-08-07 12:47:13 -03:00
parent cf924373f6
commit 4a749f6c38
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
torba/torba/client/basenetwork.py
View file

@ -40,6 +40,9 @@ class ClientSession(BaseClientSession):
except RPCError as e: except RPCError as e:
log.warning("Wallet server returned an error. Code: %s Message: %s", *e.args) log.warning("Wallet server returned an error. Code: %s Message: %s", *e.args)
raise e raise e
except TimeoutError:
self.latency = 1 << 32
raise
async def ensure_session(self): async def ensure_session(self):
# Handles reconnecting and maintaining a session alive # Handles reconnecting and maintaining a session alive
@ -50,7 +53,7 @@ class ClientSession(BaseClientSession):
if self.is_closing(): if self.is_closing():
await self.create_connection(self.timeout) await self.create_connection(self.timeout)
await self.ensure_server_version() await self.ensure_server_version()
if (time() - self.last_send) > self.max_seconds_idle: if (time() - self.last_send) > self.max_seconds_idle or self.latency == 1 << 32:
await self.send_request('server.banner') await self.send_request('server.banner')
retry_delay = default_delay retry_delay = default_delay
except (asyncio.TimeoutError, OSError): except (asyncio.TimeoutError, OSError):