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

fix peer_ping

Browse source
This commit is contained in:
Jack Robison 2019-02-02 02:02:19 -05:00
parent 91e581422c
commit 8f5a8ab8ba
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 6 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
lbrynet/extras/daemon/Daemon.py
View file

@ -2798,18 +2798,14 @@ class Daemon(metaclass=JSONRPCServerType):
"""
peer = None
if node_id and address and port:
peer = self.component_manager.peer_manager.get_peer(address, unhexlify(node_id), udp_port=int(port))
if not peer:
peer = self.component_manager.peer_manager.make_peer(
address, unhexlify(node_id), udp_port=int(port)
)
peer = self.component_manager.peer_manager.get_kademlia_peer(unhexlify(node_id), address,
udp_port=int(port))
try:
return await self.dht_node.protocol.get_rpc_peer(peer).ping()
except asyncio.TimeoutError:
return {'error': 'timeout'}
if not peer:
return {'error': 'peer not found'}
try:
result = await peer.ping()
return result.decode()
except asyncio.TimeoutError:
return {'error': 'ping timeout'}
@requires(DHT_COMPONENT)
def jsonrpc_routing_table_get(self):