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

bug fix

Browse source
This commit is contained in:
Lex Berezhny 2021-06-18 10:19:41 -04:00
parent 227fb0ae9b
commit c39195488a
2 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
lbry/wallet/manager.py
View file

@ -182,6 +182,7 @@ class WalletManager:
ledger_config = { ledger_config = {
'auto_connect': True, 'auto_connect': True,
'explicit_servers': [],
'default_servers': config.lbryum_servers, 'default_servers': config.lbryum_servers,
'known_hubs': config.known_hubs, 'known_hubs': config.known_hubs,
'jurisdiction': config.jurisdiction, 'jurisdiction': config.jurisdiction,

2
lbry/wallet/network.py
View file

@ -250,6 +250,7 @@ class Network:
n = len(ip_to_hostnames) n = len(ip_to_hostnames)
log.info("%i possible spv servers to try (%i urls in config)", n, len(self.config['explicit_servers'])) log.info("%i possible spv servers to try (%i urls in config)", n, len(self.config['explicit_servers']))
pongs = {} pongs = {}
known_hubs = self.known_hubs
try: try:
await loop.create_datagram_endpoint(lambda: connection, ('0.0.0.0', 0)) await loop.create_datagram_endpoint(lambda: connection, ('0.0.0.0', 0))
# could raise OSError if it cant bind # could raise OSError if it cant bind
@ -257,7 +258,6 @@ class Network:
for server in ip_to_hostnames: for server in ip_to_hostnames:
connection.ping(server) connection.ping(server)
sent_ping_timestamps[server] = perf_counter() sent_ping_timestamps[server] = perf_counter()
known_hubs = self.known_hubs
while len(pongs) < n: while len(pongs) < n:
(remote, ts), pong = await asyncio.wait_for(pong_responses.get(), timeout - (perf_counter() - start)) (remote, ts), pong = await asyncio.wait_for(pong_responses.get(), timeout - (perf_counter() - start))
latency = ts - start latency = ts - start