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

dht_crawler: cleanup, try not to reset key

Browse source
This commit is contained in:
Victor Shyba 2022-06-11 20:53:25 -03:00 committed by Victor Shyba
parent baf422fc03
commit 174439f517
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
scripts/dht_crawler.py
View file

@ -179,10 +179,10 @@ class Crawler:
latency = None latency = None
for _ in range(3): for _ in range(3):
try: try:
async with self.semaphore:
ping_start = time.perf_counter_ns() ping_start = time.perf_counter_ns()
async with self.semaphore:
await self.node.protocol.get_rpc_peer(make_kademlia_peer(None, address, port)).ping() await self.node.protocol.get_rpc_peer(make_kademlia_peer(None, address, port)).ping()
key = self.node.protocol.peer_manager.get_node_id_for_endpoint(address, port) key = key or self.node.protocol.peer_manager.get_node_id_for_endpoint(address, port)
latency = time.perf_counter_ns() - ping_start latency = time.perf_counter_ns() - ping_start
except asyncio.TimeoutError: except asyncio.TimeoutError:
pass pass
@ -200,7 +200,6 @@ class Crawler:
peers = set() peers = set()
factor = 2048 factor = 2048
for i in range(200): for i in range(200):
#print(i, len(peers), key.hex(), host)
new_peers = await self.request_peers(address, port, key) new_peers = await self.request_peers(address, port, key)
if not new_peers: if not new_peers:
break break