From 7e7593717cc9bdb3cce339b380365e80503fa5ce Mon Sep 17 00:00:00 2001 From: babic_a Date: Mon, 4 May 2020 09:05:13 +0200 Subject: [PATCH] move sf_replay to other numa nodes and make a quasi online stream (one hour replay) to test --- scripts/JF07-replay-worker.sh | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/scripts/JF07-replay-worker.sh b/scripts/JF07-replay-worker.sh index 6d77992..aacf7c0 100644 --- a/scripts/JF07-replay-worker.sh +++ b/scripts/JF07-replay-worker.sh @@ -8,20 +8,19 @@ fi M=$1 -#8 replay workers per core, last writer worker occupies 4 -coreAssociated=(17 17 17 17 17 17 17 17 18 18 18 18 18 18 18 18 19 19 19 19 19 19 19 19 20 20 20 20 20 20 20 20 21,22,23,24) +#8 replay workers per core, last (stream to visualisation) worker occupies 4 +coreAssociated=(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 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}-100000)) -first_pulse_id=$((${last_pulse_id}-100000)) +first_pulse_id=$((${last_pulse_id}-360000)) echo "First/last pulse_id : ${first_pulse_id} ${last_pulse_id}" if [ ${M} == 32 ] then # taskset -c ${coreAssociated[10#${M}]} /usr/bin/sf_writer /gpfs/photonics/swissfel/buffer/test.${first_pulse_id}-${last_pulse_id}.h5 ${first_pulse_id} ${last_pulse_id} - taskset -c ${coreAssociated[10#${M}]} /usr/bin/sf_stream tcp://129.129.241.42:9007 30 tcp://129.129.241.42:9107 30 + taskset -c ${coreAssociated[10#${M}]} /usr/bin/sf_stream tcp://129.129.241.42:9007 30 tcp://192.168.30.29:9107 30 else taskset -c ${coreAssociated[10#${M}]} /usr/bin/sf_replay /gpfs/photonics/swissfel/buffer/JF07T32V01 M${M} ${M} ${first_pulse_id} ${last_pulse_id} fi