Commit 3fa76455 authored by Olivier Kaufmann's avatar Olivier Kaufmann
Browse files

Fixes bug related to the mux_barrier in hardware system

No related merge requests found
Showing with 2 additions and 1 deletion
+2 -1
...@@ -281,13 +281,14 @@ class OhmPiHardware: ...@@ -281,13 +281,14 @@ class OhmPiHardware:
elec_dict = {i: [] for i in roles} elec_dict = {i: [] for i in roles}
for i in range(len(electrodes)): for i in range(len(electrodes)):
elec_dict[roles[i]].append(electrodes[i]) elec_dict[roles[i]].append(electrodes[i])
print(f'parties: {self.mux_barrier.parties}')
mux_workers = [] mux_workers = []
for _, mux in self.mux_boards.items(): for _, mux in self.mux_boards.items():
# start a new thread to perform some work # start a new thread to perform some work
mux_workers.append(Thread(target=mux.switch, kwargs={'elec_dict': elec_dict})) mux_workers.append(Thread(target=mux.switch, kwargs={'elec_dict': elec_dict}))
for mux_worker in mux_workers: for mux_worker in mux_workers:
mux_worker.start() 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() self.mux_barrier.wait()
for mux_worker in mux_workers: for mux_worker in mux_workers:
mux_worker.join() mux_worker.join()
......
Supports Markdown
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