From 438fe834086a1fa5674c2d7f8e2f5d97d2f6ca53 Mon Sep 17 00:00:00 2001
From: Dmitry Ozerov <dmitry.ozerov@psi.ch>
Date: Tue, 19 May 2020 19:12:52 +0200
Subject: [PATCH] another step towards retrieval script for daq

---
 scripts/retrieve_detector_data.sh | 39 +++++++++++++++++--------------
 1 file changed, 21 insertions(+), 18 deletions(-)

diff --git a/scripts/retrieve_detector_data.sh b/scripts/retrieve_detector_data.sh
index 2e6f447..c655cf4 100755
--- a/scripts/retrieve_detector_data.sh
+++ b/scripts/retrieve_detector_data.sh
@@ -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}