Commit 50ed11f7 authored by Antoine Kaufmann's avatar Antoine Kaufmann
Browse files

experiments: wait till proxy sockets exist

(implement wait_proxy_sockets properly)
parent 816b1893
...@@ -378,8 +378,20 @@ class ExperimentDistributedRunner(ExperimentBaseRunner): ...@@ -378,8 +378,20 @@ class ExperimentDistributedRunner(ExperimentBaseRunner):
await asyncio.sleep(10) await asyncio.sleep(10)
async def wait_proxy_sockets(self): async def wait_proxy_sockets(self):
# TODO """ Make sure all sockets exist. """
pass paths = {}
for proxy in itertools.chain(
self.exp.proxies_connect, self.exp.proxies_listen):
for (nic, local) in proxy.nics:
if local:
continue
exec = self.sim_executor(proxy)
if exec not in paths:
paths[exec] = []
paths[exec].append(self.env.nic_eth_path(nic))
for (exec, paths) in paths.items():
await exec.await_files(paths, verbose=self.verbose)
async def before_nets(self): async def before_nets(self):
await self.run_proxies_listeners() await self.run_proxies_listeners()
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment