diff --git a/rc/control/daqinterface.py b/rc/control/daqinterface.py index 33c83840..ec59de9e 100755 --- a/rc/control/daqinterface.py +++ b/rc/control/daqinterface.py @@ -636,12 +636,11 @@ def __init__( self.print_log( "i", - '%s: DAQInterface in partition %s launched and now in "%s" state, listening on port %d' + '%s: DAQInterface in partition %s launched and now in "%s" state' % ( date_and_time(), self.partition_number, self.state(self.name), - self.rpc_port, ), ) @@ -2483,6 +2482,7 @@ def process_command(self, procinfo_index, command): proc_starttimes = {} proc_endtimes = {} + for subsystem in subsystems_in_order: for proctype in proctypes_in_order: diff --git a/rc/io/rpc.py b/rc/io/rpc.py index 50d8292a..46eac2f4 100644 --- a/rc/io/rpc.py +++ b/rc/io/rpc.py @@ -45,6 +45,10 @@ def stop(self): @contextlib.contextmanager def rpc_server(host="", port=6000, funcs={}, timeout=0.01): server = StoppableRPCServer((host, port), timeout=timeout) + print( + "DAQInterface RPC server listening on %s:%d" % (host or "0.0.0.0", port), + flush=True, + ) with threaded(target=server.serve_forever, name="rpc-server-%s-%d" % (host, port)): for name, func in funcs.items(): server.register_function(func, name)