artiq_dashboard: major refactor to proxy connectors

This commit is contained in:
Simon Renblad 2024-01-16 16:19:35 +08:00
parent 70542b0a5b
commit b78a72ac9b

View File

@ -216,8 +216,12 @@ def main():
broadcast_clients["ccb"].notify_cbs.append(d_applets.ccb_notify)
d_waveform = waveform.WaveformDock()
loop.run_until_complete(d_waveform.proxy_client.start(args.server, args.port_notify))
atexit_register_coroutine(d_waveform.proxy_client.stop, loop=loop)
loop.run_until_complete(d_waveform.devices_sub.connect(args.server, args.port_notify))
atexit_register_coroutine(d_waveform.devices_sub.close, loop=loop)
for name in ["rpc_client", "receiver_client"]:
client = getattr(d_waveform, name)
loop.run_until_complete(client.start())
atexit_register_coroutine(client.close, loop=loop)
d_ttl_dds = moninj.MonInj(rpc_clients["schedule"])
loop.run_until_complete(d_ttl_dds.start(args.server, args.port_notify))