diff --git a/hardware_system.py b/hardware_system.py index 2630cc05a4651ff25c7f9aa22e2046bb4d0a65ea..0bffd6c7fa669cb81a4f21770755435fc9b39d20 100644 --- a/hardware_system.py +++ b/hardware_system.py @@ -281,13 +281,14 @@ class OhmPiHardware: elec_dict = {i: [] for i in roles} for i in range(len(electrodes)): elec_dict[roles[i]].append(electrodes[i]) + print(f'parties: {self.mux_barrier.parties}') mux_workers = [] for _, mux in self.mux_boards.items(): # start a new thread to perform some work mux_workers.append(Thread(target=mux.switch, kwargs={'elec_dict': elec_dict})) for mux_worker in mux_workers: mux_worker.start() - self.exec_logger.debug(f'Waiting: {self.mux_barrier.n_waiting}') + self.exec_logger.debug(f'Waiting: {self.mux_barrier.n_waiting}/{self.mux_barrier.parties}') self.mux_barrier.wait() for mux_worker in mux_workers: mux_worker.join()