Clear retry_event once triggered.

Fixes #603
This commit is contained in:
Neil Booth 2018-09-24 11:07:19 +01:00
parent d6dc5e8d01
commit b7c1a693eb

View File

@ -197,6 +197,7 @@ class PeerManager(object):
pause = WAKEUP_SECS * 2 ** peer.try_count
async with ignore_after(pause):
await peer.retry_event.wait()
peer.retry_event.clear()
async def _should_drop_peer(self, peer):
peer.try_count += 1