sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-08 16:02:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'eiger' of https://github.com/paulscherrerinstitute/sf_daq_buffer into eiger

Browse Source
This commit is contained in:
babic_a
2022-02-17 12:33:58 +01:00
parent 39024f4953 4bfca9ab55
commit 206945a8ff
2 changed files with 32 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
eiger/xbl-daq-24/check_services.sh
+18 -2
View File
@@ -1,10 +1,26 @@
#!/bin/bash
GREP="std|streamvis"
while getopts g: flag
GREP="std|streamvis|rabbit"
RESTART="OFF"
STATUS_VERBOSE="OFF"
while getopts g:s: flag
do
case "${flag}" in
g) GREP=${OPTARG};;
# r) RESTART='ON';;
s) STATUS_VERBOSE=${OPTARG};;
esac
done
if [ ${STATUS_VERBOSE} = "ON" ]; then
systemctl list-units --type service --all | grep -E ${GREP} | awk '{print $1}' | xargs -I{} systemctl status {}
fi
#if [ RESTART = "ON" ]; then
# systemctl list-units --type service --all | grep -E ${GREP} | awk '{print $1}' | xargs -I{} systemctl restart {}
#fi
systemctl list-units --type service --all | grep -E ${GREP} | awk 'BEGIN{print "Unit State Status"};$4 ~ /^running$/{print $1,$2,$4}' | column -t
eiger/xbl-daq-24/start_request.py
+14 -20
View File
@@ -5,13 +5,22 @@ import json
# writer agent endpoint
URL = "http://127.0.0.1:5000"
# type of write request
SYNC = "/write_sync"
# details of request
n_images = 3
n_acquisitions = 1000
n_images = 10
n_acquisitions = 5
headers = {'Content-type': 'application/json'}
print("Configuring the detector...")
data_config = {"det_name":"eiger","config":{"frames":100,"dr":16, "triggers":1, "exptime":0.000005, "timing":"auto", "tengiga":1}}
r = requests.post(url="http://127.0.0.1:5000/detector", headers=headers, json=data_config)
time.sleep(0.5)
print("Starting the detector...")
start_data = {'cmd':"START"}
r = requests.post(url = "http://127.0.0.1:5000/detector/eiger", headers=headers, json=start_data)
time.sleep(0.5)
print("Performing sync aquisitions...")
for i in range(0,n_acquisitions):
output_file ='/home/dbe/git/sf_daq_buffer/eiger/xbl-daq-24/output_folder/eiger_sync_%s_%s.h5' % (datetime.now().strftime("%H%M%S"), i)
@@ -20,22 +29,7 @@ for i in range(0,n_acquisitions):
print("REQUEST: ", i)
print("DATA: ", data)
r = requests.post(url = "http://127.0.0.1:5000/write_sync", json=data, headers=headers)
r = requests.post(url = "http://127.0.0.1:5000/write_async", json=data, headers=headers)
print("RESPONSE FROM REQUEST: ", r.text)
data = None
time.sleep(0.2)
# time.sleep(3)
# print("Performing async aquisitions...")
# for i in range(0,n_acquisitions):
# output_file ='/home/hax_l/tests/eiger_async_%s_%s.h5' % (datetime.now().strftime("%H%M%S"), i)
# data = {'sources':'eiger', 'n_images':n_images, 'output_file':output_file}
# print("REQUEST: ", i)
# print("DATA: ", data)
# r = requests.post(url = "http://127.0.0.1:5000/write_async", json=data, headers=headers)
# data = None
# time.sleep(1)
# #//TODO print("Testing kill aquisitions...")