examples/JDataWriter/JDataWriter.sh

Go to the documentation of this file.

#!/bin/zsh
#
# \author mdejong
#
version=1.0
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        $JPP_DATA                        
set_variable   DETECTOR       $JPP_DATA/km3net_reference.detx  
set_variable   LOGGER_OUTPUT  logger.txt                       


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

case $# in 
    3) WORKDIR=$3;&
    2) LOGGER_OUTPUT=$2;&
    1) 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  DWRITER_HOST $HOSTNAME

print_variable MESSAGE_SERVER MESSAGE_SERVER TIMEOUT_S RUNTIME_S


if [[ ! -f $DETECTOR ]]; then

    detectorType=5
    numberOfLines=115
    numberOfFloors=18
    floorDistance_m=36
    lineDistance_m=90
    heightOfFirstFloor=100

    echo "Creating detector $DETECTOR, with parameters:"

    JDetector       \
        -D 1000                            \
        -@detectorType=$detectorType       \
        -@numberOfLines=$numberOfLines     \
        -@numberOfFloors=$numberOfFloors   \
        -@floorDistance_m=$floorDistance_m \
        -@lineDistance_m=$lineDistance_m   \
        -z $heightOfFirstFloor             \
        -f footprint_extended.txt          \
        -V V2                              \
        -o $DETECTOR -d 1 --!
fi


if [[ ! -f $INPUT_FILE ]]; then

    singlesRate=0e3
    doublesRate=2e3
    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.root $WORKDIR $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  $HOSTNAME  ssh  \$HOST\$  "JEventGenerator  -u \$NAME\$  -H \$SERVER\$  -M \$LOGGER\$  -d $DEBUG  </dev/null >&/dev/null &";
process  JDataWriter      $HOSTNAME  ssh  \$HOST\$  "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 }

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