sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-25 07:20:44 +02:00
Code Issues Packages Projects Releases Wiki Activity

another step towards retrieval script for daq

Browse Source
This commit is contained in:
Dmitry Ozerov
2020-05-19 19:12:52 +02:00
committed by Data Backend account
parent c0bb9b870e
commit 438fe83408
1 changed files with 21 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/retrieve_detector_data.sh
+21 -18
View File
@@ -1,9 +1,10 @@
#!/bin/bash
if [ $# != 3 ]
if [ $# -lt 3 ]
then
echo "Usage : $0 detector_name start_pulse_id end_pulse_id"
echo "Example : $0 JF07T32V01 11709404000 11709405000"
echo "Optional parameters: output_file_name"
exit
fi
@@ -11,32 +12,34 @@ DETECTOR=$1
START_PULSE_ID=$2
STOP_PULSE_ID=$3
#8 replay workers per core, last (writer) worker occupies 4
if [ $# == 4 ]
then
OUTFILE=$4
else
OUTFILE=/gpfs/photonics/swissfel/buffer/test.${START_PULSE_ID}-${STOP_PULSE_ID}.h5
fi
#8 replay workers per core
#coreAssociated_replay=(20 20 20 20 20 20 20 20 21 21 21 21 21 21 21 21 22 22 22 22 22 22 22 22 23 23 23 23 23 23 23 23)
#4 replay workers per core, last (writer) worker occupies 4
#coreAssociated_replay=(20 20 20 20 21 21 21 21 22 22 22 22 23 23 23 23 24 24 24 24 25 25 25 25 26 26 26 26 27 27 27 27)
#2 replay workers per core, last (writer) worker occupies 4
#4 replay workers per core
coreAssociated_replay=(7 7 7 7 8 8 8 8 9 9 9 9 10 10 10 10 11 11 11 11 12 12 12 12 13 13 13 13 14 14 14 14)
#2 replay workers per core
#coreAssociated_replay=(20 20 21 21 22 22 23 23 24 24 25 25 26 26 27 27 28 28 29 29 30 30 31 31 32 32 33 33 34 34 35 35)
#1 replay workers per core, last (writer) worker occupies 4
coreAssociated_replay=(4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35)
#1 replay workers per core
#coreAssociated_replay=(4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35)
coreAssociated_writer="24,25,26,27"
#latest_file=`cat /gpfs/photonics/swissfel/buffer/JF07T32V01/M00/LATEST`
#last_pulse_id=`basename ${latest_file} | sed 's/.h5//'`
#first_pulse_id=$((${last_pulse_id}-360000))
#echo "First/last pulse_id : ${first_pulse_id} ${last_pulse_id}"
coreAssociated_writer="2,3,4,5,6"
touch /tmp/detector_retrieve.log
cd /gpfs/photonics/swissfel/buffer/
for M in {00..31}
do
taskset -c ${coreAssociated_replay[10#${M}]} /usr/bin/sf_replay ${DETECTOR} M${M} ${M} ${START_PULSE_ID} ${STOP_PULSE_ID} >> /tmp/detector_retrieve.log &
taskset -c ${coreAssociated_replay[10#${M}]} /usr/bin/sf_replay ${DETECTOR} M${M} ${M} ${START_PULSE_ID} ${STOP_PULSE_ID} >> /tmp/detector_retrieve_replay.log &
done
taskset -c ${coreAssociated_writer} /usr/bin/sf_writer /gpfs/photonics/swissfel/buffer/test.${START_PULSE_ID}-${STOP_PULSE_ID}.h5 ${START_PULSE_ID} ${STOP_PULSE_ID} >> /tmp/detector_retrieve.log &
taskset -c ${coreAssociated_writer} /usr/bin/sf_writer ${OUTFILE} ${START_PULSE_ID} ${STOP_PULSE_ID} >> /tmp/detector_retrieve.log &
wait
echo ${OUTFILE}