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

same api across different estimation methods

Browse source
This commit is contained in:
Victor Shyba 2021-12-03 16:38:35 -03:00
parent b656759e0e
commit 2f84c38f6a
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
scripts/dht_node.py
View file

@ -63,15 +63,20 @@ class SimpleMetrics:
amount = 20_000
peers = await self.dht_node.peer_search(self.dht_node.protocol.node_id, count=amount, max_results=amount)
close_ids = [peer for peer in peers if peer.node_id[0] == self.dht_node.protocol.node_id[0]]
return web.json_response({"total": len(peers), "close": len(close_ids)})
return web.json_response(
{"total_peers_found_during_estimation": len(peers),
"peers_with_the_same_byte_prefix": len(close_ids),
'estimated_network_size': len(close_ids) * 256})
async def passive_estimation(self, _):
# same method as above but instead we use the routing table and assume our implementation was able to add
# all the reachable close peers, which should be usable for seed nodes since they are super popular
total_peers = self.dht_node.protocol.routing_table.get_peers()
close_ids = [peer for peer in total_peers if peer.node_id[0] == self.dht_node.protocol.node_id[0]]
peers = self.dht_node.protocol.routing_table.get_peers()
close_ids = [peer for peer in peers if peer.node_id[0] == self.dht_node.protocol.node_id[0]]
return web.json_response(
{"total": len(total_peers), "close": len(close_ids), 'estimated_network_size': len(close_ids) * 256})
{"total_peers_found_during_estimation": len(peers),
"peers_with_the_same_byte_prefix": len(close_ids),
'estimated_network_size': len(close_ids) * 256})
async def start(self):
prom_app = web.Application()