LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

use node_id parameter instead of your own

Browse source
This commit is contained in:
Victor Shyba 2019-01-31 01:11:09 -03:00
parent 21f2b2dcd7
commit 3e1c3d1e4b
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lbrynet/dht/node.py
View file

@ -82,7 +82,7 @@ class Node:
log.info("Store to %i peers", len(peers)) log.info("Store to %i peers", len(peers))
log.info(peers) log.info(peers)
for peer in peers: for peer in peers:
log.info("store to %s %s %s", peer.address, peer.udp_port, peer.tcp_port) log.debug("store to %s %s %s", peer.address, peer.udp_port, peer.tcp_port)
stored_to_tup = await asyncio.gather( stored_to_tup = await asyncio.gather(
*(self.protocol.store_to_peer(hash_value, peer) for peer in peers), loop=self.loop *(self.protocol.store_to_peer(hash_value, peer) for peer in peers), loop=self.loop
) )
@ -229,7 +229,7 @@ class Node:
async def peer_search(self, node_id: bytes, count=constants.k, max_results=constants.k*2, async def peer_search(self, node_id: bytes, count=constants.k, max_results=constants.k*2,
bottom_out_limit=20) -> typing.List['KademliaPeer']: bottom_out_limit=20) -> typing.List['KademliaPeer']:
accumulated: typing.List['KademliaPeer'] = [] accumulated: typing.List['KademliaPeer'] = []
async with self.peer_search_junction(self.protocol.node_id, max_results=max_results, async with self.peer_search_junction(node_id, max_results=max_results,
bottom_out_limit=bottom_out_limit) as junction: bottom_out_limit=bottom_out_limit) as junction:
async for peers in junction: async for peers in junction:
accumulated.extend(peers) accumulated.extend(peers)