dht_crawler: dont gather empty, fix crash
This commit is contained in:
parent
adc79ec404
commit
90c2a58470
1 changed files with 2 additions and 1 deletions
|
@ -248,6 +248,7 @@ class Crawler:
|
||||||
log.info("%d known, %d contacted recently, %d unreachable, %d error, %d processing, %d on queue",
|
log.info("%d known, %d contacted recently, %d unreachable, %d error, %d processing, %d on queue",
|
||||||
self.recent_peers_query.count(), self.checked_peers_count, self.unreachable_peers_count,
|
self.recent_peers_query.count(), self.checked_peers_count, self.unreachable_peers_count,
|
||||||
self.peers_with_errors_count, len(to_process), len(to_check))
|
self.peers_with_errors_count, len(to_process), len(to_check))
|
||||||
|
if to_process:
|
||||||
await asyncio.wait(to_process.values(), return_when=asyncio.FIRST_COMPLETED)
|
await asyncio.wait(to_process.values(), return_when=asyncio.FIRST_COMPLETED)
|
||||||
to_check = self.get_peers_needing_check()
|
to_check = self.get_peers_needing_check()
|
||||||
while not to_check and not to_process:
|
while not to_check and not to_process:
|
||||||
|
|
Loading…
Reference in a new issue