software/JDataWriter/JDataWriter.sh

Go to the documentation of this file.

#!/bin/zsh
#
# \author mdejong
#
script=${0##*/}

# ------------------------------------------------------------------------------------------
#
#                            Utility script to run JDataWriter and JEventGenerator.
#
# ------------------------------------------------------------------------------------------


if [ -z $JPP_DIR ]; then
    echo "Variable JPP_DIR undefined."
    exit
fi

source $JPP_DIR/setenv.sh $JPP_DIR

set_variable   DEBUG          3                                
set_variable   WORKDIR        /tmp/                            
set_variable   DETECTOR       $JPP_DATA/km3net_reference.detx  
set_variable   LOGGER_OUTPUT  logger.txt                       
set_variable   HOST           `get_ip_address`                 

if do_usage $*; then
    usage "$script [detector file [logger file [working directory]]]"
fi

case $# in
    3) set_variable WORKDIR       $3;&
    2) set_variable LOGGER_OUTPUT $2;&
    1) set_variable DETECTOR      $1;;
esac

set_variable INPUT_FILE      $WORKDIR/trigger_processor.root
set_variable MESSAGE_SERVER  localhost
set_variable MESSAGE_LOGGER  localhost
set_variable DEBUG           3
set_variable RUN_1           1001
set_variable RUN_2           1002
set_variable TIMEOUT_S       10
set_variable RUNTIME_S       20
set_variable DETECTOR_ID     1000
set_variable DWRITER_HOST    $HOST


if [[ ! -f $DETECTOR ]]; then
    JDetector.sh $DETECTOR
fi

if ( ! reuse_file $INPUT_FILE ); then

    set_variable singlesRate     0e3
    set_variable doublesRate     2e3
    set_variable numberOfSlices  10

    echo "Generating random background."
    echo "Singles rate:  $singlesRate [Hz]."
    echo "Doubles rate:  $doublesRate [Hz]."

    PIPE=/tmp/pipe.dat

    rm -f  $PIPE
    mkfifo $PIPE

    nohup JRandomTimesliceWriter \
        -a $DETECTOR                   \
        -o $PIPE                       \
        -B "$singlesRate $doublesRate" \
        -n $numberOfSlices             \
        -d1 > timeslice.log 2>&1 &

    echo Processing random data.

    JTriggerProcessor \
        -a $DETECTOR                   \
        -f $PIPE                       \
        -@trigger3DShower.enabled=1    \
        -@trigger3DMuon.enabled=1      \
        -o $INPUT_FILE                 \
        -d1 > trigger.log 2>&1

    rm -f $PIPE

    JPrintTree \
        -f $INPUT_FILE

fi


let RUN=RUN_1

while (( $RUN <= $RUN_2 )); do

    OUTPUT_FILE=`printf %s/KM3NeT_%08d_%08d.root $WORKDIR $DETECTOR_ID $RUN`

    if [[ -f $OUTPUT_FILE ]]; then
        rm -i $OUTPUT_FILE
    fi

    let RUN=$RUN+1
done 


# Event generation configure data.

if [[ ! -f ev_configure.txt ]]; then

cat>ev_configure.txt<<EOF
datawriter     = $DWRITER_HOST;
inputFile      = $INPUT_FILE;
eventRate_Hz   = 100.0;
EOF

fi

# Driver input.

if [[ ! -f driver.txt ]]; then

cat>driver.txt<<EOF

# To avoid unnecessary shell processes, the process I/O is redirected to /dev/null and the ssh command is quoted.

process  JEventGenerator  $HOST  ssh  \$HOST\$  "$JPP_BIN/JEventGenerator  -u \$NAME\$  -H \$SERVER\$  -M \$LOGGER\$  -d $DEBUG  </dev/null >&/dev/null &";
process  JDataWriter      $HOST  ssh  \$HOST\$  "$JPP_BIN/JDataWriter      -u \$NAME\$  -H \$SERVER\$  -M \$LOGGER\$  -d $DEBUG  </dev/null >&/dev/null &";

enter

event ev_init      { RC_CMD }
EOF

let RUN=RUN_1

while (( $RUN <= $RUN_2 )); do

cat>>driver.txt<<EOF

event ev_configure { 
    RC_EVT %<ev_configure.txt>%
    RC_DWRT path=$WORKDIR; update_s=10; logger_s=5;
}

event ev_start     { RC_CMD $RUN $DETECTOR_ID }

sleep $RUNTIME_S

event ev_pause     { RC_CMD }
event ev_stop      { RC_CMD }
EOF

let RUN=$RUN+1
done

cat>>driver.txt<<EOF

event ev_reset     { RC_CMD }
event ev_off       { RC_CMD }
EOF

fi


if (( 1 )); then

    JLigier.sh $MESSAGE_SERVER continue

fi


if (( 1 )); then

    JLogger.sh $MESSAGE_LOGGER $LOGGER_OUTPUT

fi


if (( 1 )); then

  JDAQDriver \
      -H $MESSAGE_SERVER \
      -M $MESSAGE_LOGGER \
      -t $TIMEOUT_S \
      -f driver.txt \
      -d $DEBUG     \
      -c

fi


if (( 1 )); then

    JStopDAQ.sh $MESSAGE_SERVER $MESSAGE_LOGGER

fi