sf-daq/dap
0
0
Fork 1
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

removed if True

Browse Source
This commit is contained in:
augustin_s
2024-03-22 22:45:02 +01:00
parent c94d6943d4
commit 69745e34bc
1 changed files with 325 additions and 326 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
dap/worker.py
View File

@ -74,10 +74,9 @@ def main():
poller = zmq.Poller() poller = zmq.Poller()
# all the normal workers # all the normal workers
if True:
worker = 1 worker = 1
# receive from backend: # receive from backend:
backend_socket = zmq_context.socket(zmq.PULL) backend_socket = zmq_context.socket(zmq.PULL)
backend_socket.connect(BACKEND_ADDRESS) backend_socket.connect(BACKEND_ADDRESS)
@ -89,7 +88,7 @@ def main():
visualisation_socket = zmq_context.socket(zmq.PUB) visualisation_socket = zmq_context.socket(zmq.PUB)
visualisation_socket.connect(f"tcp://{FA_HOST_VISUALISATION}:{FA_PORT_VISUALISATION}") visualisation_socket.connect(f"tcp://{FA_HOST_VISUALISATION}:{FA_PORT_VISUALISATION}")
# in case of problem with communication to visualisation, keep in 0mq buffer only few messages # in case of problem with communication to visualisation, keep in 0mq buffer only few messages
visualisation_socket.set_hwm(10) visualisation_socket.set_hwm(10)
keep_pixels = None keep_pixels = None
@ -151,7 +150,7 @@ def main():
event_darkshot = bool((daq_rec >> 17) & 1) event_darkshot = bool((daq_rec >> 17) & 1)
event_fel = bool((daq_rec >> 18) & 1) event_fel = bool((daq_rec >> 18) & 1)
event_ppicker = bool((daq_rec >> 19) & 1) event_ppicker = bool((daq_rec >> 19) & 1)
#
if not event_darkshot: if not event_darkshot:
results["laser_on"] = event_laser results["laser_on"] = event_laser
@ -197,7 +196,7 @@ def main():
else: else:
pixel_mask_pf = None pixel_mask_pf = None
#
disabled_modules = results.get("disabled_modules", []) disabled_modules = results.get("disabled_modules", [])
# add additional mask at the edge of modules for JF06T08 # add additional mask at the edge of modules for JF06T08
@ -392,7 +391,7 @@ def main():
# usually don't need to change this value, rather robust # usually don't need to change this value, rather robust
hitfinder_local_bg_radius= 20. hitfinder_local_bg_radius= 20.
#in case of further modification with the mask, make a new one, independent from real mask # in case of further modification with the mask, make a new one, independent from real mask
maskPr = np.copy(pixel_mask_pf) maskPr = np.copy(pixel_mask_pf)
y, x = np.indices(d.shape) y, x = np.indices(d.shape)
@ -467,7 +466,7 @@ def main():
results["shape"] = data.shape results["shape"] = data.shape
frame_number = metadata["frame"] frame_number = metadata["frame"]
#
accumulator_socket.send_json(results, FLAGS) accumulator_socket.send_json(results, FLAGS)
if (apply_aggregation != 0 ) and "aggregation_max" in results: if (apply_aggregation != 0 ) and "aggregation_max" in results: