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

Catch resolve timeouts

Browse source
This commit is contained in:
Miroslav Kovar 2019-11-11 17:01:41 +01:00 committed by Jack Robison
parent c321758afd
commit a80fbcc252
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 14 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
lbry/lbry/dht/node.py
View file

@ -141,7 +141,6 @@ class Node:
self.protocol.ping_queue.start() self.protocol.ping_queue.start()
self._refresh_task = self.loop.create_task(self.refresh_node()) self._refresh_task = self.loop.create_task(self.refresh_node())
seed_peers = peers_from_urls(await self._storage.get_persisted_kademlia_peers()) if self._storage else []
while True: while True:
if self.protocol.routing_table.get_peers(): if self.protocol.routing_table.get_peers():
if not self.joined.is_set(): if not self.joined.is_set():
@ -153,14 +152,22 @@ class Node:
else: else:
if self.joined.is_set(): if self.joined.is_set():
self.joined.clear() self.joined.clear()
self.protocol.peer_manager.reset() seed_peers = peers_from_urls(
self.protocol.ping_queue.enqueue_maybe_ping(*seed_peers, delay=0.0) await self._storage.get_persisted_kademlia_peers()
seed_peers.extend(await self.peer_search(self.protocol.node_id, shortlist=seed_peers, count=32)) ) if self._storage else []
if not seed_peers or not self.protocol.routing_table.get_peers(): if not seed_peers:
try:
seed_peers.extend(peers_from_urls([ seed_peers.extend(peers_from_urls([
(None, await resolve_host(address, udp_port, 'udp'), udp_port, None) (None, await resolve_host(address, udp_port, 'udp'), udp_port, None)
for address, udp_port in known_node_urls or [] for address, udp_port in known_node_urls or []
])) ]))
except asyncio.TimeoutError:
await asyncio.sleep(30)
continue
self.protocol.peer_manager.reset()
self.protocol.ping_queue.enqueue_maybe_ping(*seed_peers, delay=0.0)
await self.peer_search(self.protocol.node_id, shortlist=seed_peers, count=32)
await asyncio.sleep(1, loop=self.loop) await asyncio.sleep(1, loop=self.loop)