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

fix rare edge cases on network

Browse source
This commit is contained in:
Victor Shyba 2019-09-09 00:56:58 -03:00 committed by Lex Berezhny
parent 5dbc749000
commit 375c2a3363
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -177,8 +177,8 @@ class BaseNetwork:
try: try:
self._update_remote_height((await self.subscribe_headers(),)) self._update_remote_height((await self.subscribe_headers(),))
log.info("Subscribed to headers: %s:%d", *self.client.server) log.info("Subscribed to headers: %s:%d", *self.client.server)
except asyncio.TimeoutError: except (asyncio.TimeoutError, ConnectionError):
log.info("Switching to %s:%d timed out, closing and retrying.") log.info("Switching to %s:%d timed out, closing and retrying.", *self.client.server)
self.client.synchronous_close() self.client.synchronous_close()
self.client = None self.client = None
@ -254,7 +254,8 @@ class BaseNetwork:
return await self.rpc('blockchain.address.subscribe', [address], True) return await self.rpc('blockchain.address.subscribe', [address], True)
except asyncio.TimeoutError: except asyncio.TimeoutError:
# abort and cancel, we cant lose a subscription, it will happen again on reconnect # abort and cancel, we cant lose a subscription, it will happen again on reconnect
self.client.abort() if self.client:
self.client.abort()
raise asyncio.CancelledError() raise asyncio.CancelledError()