mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2025-06-18 11:06:39 +00:00
Handle TimeoutError on automatic reconnect
This commit is contained in:
parent
4a8a85d7a6
commit
10b9b4b969
@ -324,8 +324,15 @@ class MTProtoSender:
|
|||||||
for retry in range(1, retries + 1):
|
for retry in range(1, retries + 1):
|
||||||
try:
|
try:
|
||||||
await self._connect()
|
await self._connect()
|
||||||
except ConnectionError:
|
except (ConnectionError, asyncio.TimeoutError) as e:
|
||||||
__log__.info('Failed reconnection retry %d/%d', retry, retries)
|
__log__.info('Failed reconnection retry %d/%d with %s',
|
||||||
|
retry, retries, e.__class__.__name__)
|
||||||
|
|
||||||
|
await asyncio.sleep(self._delay)
|
||||||
|
except Exception:
|
||||||
|
__log__.exception('Unexpected exception reconnecting on '
|
||||||
|
'retry %d/%d', retry, retries)
|
||||||
|
|
||||||
await asyncio.sleep(self._delay)
|
await asyncio.sleep(self._delay)
|
||||||
else:
|
else:
|
||||||
self._send_queue.extend(self._pending_state.values())
|
self._send_queue.extend(self._pending_state.values())
|
||||||
|
Loading…
Reference in New Issue
Block a user