LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-08-28 07:51:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge branch 'network_walk'

Browse source
This commit is contained in:
ThomasV 2019-02-15 17:37:59 +01:00
commit 25a460f855
1 changed files with 11 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
electrum/network.py
View file

@ -1188,24 +1188,21 @@ class Network(PrintError):
return parse_servers(await session.send_request('server.peers.subscribe')) return parse_servers(await session.send_request('server.peers.subscribe'))
async def send_multiple_requests(self, servers: List[str], method: str, params: Sequence): async def send_multiple_requests(self, servers: List[str], method: str, params: Sequence):
num_connecting = len(self.connecting)
for server in servers:
self._start_interface(server)
# sleep a bit
for _ in range(10):
if len(self.connecting) < num_connecting:
break
await asyncio.sleep(1)
responses = dict() responses = dict()
async def get_response(iface: Interface): async def get_response(server):
interface = Interface(self, server, self.proxy)
timeout = self.get_network_timeout_seconds(NetworkTimeout.Urgent)
try: try:
res = await iface.session.send_request(method, params, timeout=10) await asyncio.wait_for(interface.ready, timeout)
except BaseException as e:
await interface.close()
return
try:
res = await interface.session.send_request(method, params, timeout=10)
except Exception as e: except Exception as e:
res = e res = e
responses[iface.server] = res responses[interface.server] = res
async with TaskGroup() as group: async with TaskGroup() as group:
for server in servers: for server in servers:
interface = self.interfaces.get(server) await group.spawn(get_response(server))
if interface:
await group.spawn(get_response(interface))
return responses return responses