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

log bottom out of peer search in debug, show short key id for find value

Browse source
This commit is contained in:
Victor Shyba 2022-02-08 17:10:33 -03:00 committed by Victor Shyba
parent 0b2b10f759
commit 3876e0317d
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lbry/dht/protocol/iterative_find.py
View file

@ -351,9 +351,10 @@ class IterativeNodeFinder(IterativeFinder):
if self.are_k_closest_peers_ready: if self.are_k_closest_peers_ready:
self.put_result(self.active, True) self.put_result(self.active, True)
elif self.bottom_out_count >= self.bottom_out_limit or self.iteration_count >= self.bottom_out_limit: elif self.bottom_out_count >= self.bottom_out_limit or self.iteration_count >= self.bottom_out_limit:
log.info("peer search bottomed out.") log.debug("peer search bottomed out.")
self.put_result(self.active, True) self.put_result(self.active, True)
class IterativeValueFinder(IterativeFinder): class IterativeValueFinder(IterativeFinder):
def __init__(self, loop: asyncio.AbstractEventLoop, peer_manager: 'PeerManager', def __init__(self, loop: asyncio.AbstractEventLoop, peer_manager: 'PeerManager',
routing_table: 'TreeRoutingTable', protocol: 'KademliaProtocol', key: bytes, routing_table: 'TreeRoutingTable', protocol: 'KademliaProtocol', key: bytes,
@ -420,10 +421,10 @@ class IterativeValueFinder(IterativeFinder):
elif self.is_closest_peer_ready: elif self.is_closest_peer_ready:
self.bottom_out_count += 1 self.bottom_out_count += 1
if self.are_k_closest_peers_ready: if self.are_k_closest_peers_ready:
log.info("blob peer search finished.") log.info("blob peer search finished for %s", self.key.hex()[:8])
self.iteration_queue.put_nowait(None) self.iteration_queue.put_nowait(None)
elif self.bottom_out_count >= self.bottom_out_limit: elif self.bottom_out_count >= self.bottom_out_limit:
log.info("blob peer search bottomed out") log.info("blob peer search bottomed out for %s", self.key.hex()[:8])
self.iteration_queue.put_nowait(None) self.iteration_queue.put_nowait(None)
def get_initial_result(self) -> typing.List['KademliaPeer']: def get_initial_result(self) -> typing.List['KademliaPeer']: