software/JDataFilter/JDataFilter.sh

Go to the documentation of this file.

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

# ------------------------------------------------------------------------------------------
#
#         Example script to run JDataFilter and JDataWriter using JDQSimulator(s)
#
# ------------------------------------------------------------------------------------------


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

source $JPP_DIR/setenv.sh $JPP_DIR

set_variable:  DEBUG             TEST_DEBUG        3
set_variable:  WORKDIR           TEST_WORKDIR      ${TMPDIR:-/tmp}/
set_variable   IP_ADDRESS        `get_ip_address`  

set_variable   MESSAGE_SERVER    localhost         
set_variable   MESSAGE_LOGGER    localhost         

set_variable   TIMEOUT_S         30                
set_variable   RUNTIME_S         60                
set_variable   PORT              5551              
set_array      SOURCE_HOST       $IP_ADDRESS       $IP_ADDRESS  $IP_ADDRESS
set_variable   FILTER_HOST       $IP_ADDRESS       
set_variable   WRITER_HOST       $IP_ADDRESS       
set_variable   DATAFILTER        F001/F001         
set_variable   DATAWRITER        W000/W000         
set_variable   SINGLESRATE_HZ    10e3               
set_variable   DOUBLESRATE_HZ    0e3               
set_variable   NUMBER_OF_SLICES  10                


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

case $# in
    1) set_variable WORKDIR       $1;;
    0) ;;
    *) fatal "Wrong number of arguments."
esac


set_variable  DETECTOR             $WORKDIR/detector.detx
set_variable  ID                   1000
set_variable  RUN                  1001

typeset -Z 8  ID
typeset -Z 8  RUN

set_variable  INPUT_FILE           $WORKDIR/timeslice.root
set_variable  OUTPUT_FILE          $WORKDIR/KM3NeT_${ID}_${RUN}.root


function clean()
{
    rm -f $DETECTOR
    rm -f $INPUT_FILE
    rm -f $OUTPUT_FILE

    rm -f $WORKDIR/ev_configure_datafilter.txt
    rm -f $WORKDIR/ev_configure_dqsimulator.txt
    rm -f $WORKDIR/driver.txt

    killall JDQSimulator   >& /dev/null
    killall JDataFilter    >& /dev/null
    killall JDataWriter    >& /dev/null

    return 0;
}


debug "IP address $IP_ADDRESS"

JDataFilter    -h!
JDQSimulator   -h!
JDataWriter    -h!


# Clean

clean


# Continue server

JLigier-local.sh continue


# Create detector

set_variable numberOfLines          1
set_variable numberOfFloors         4
set_variable floorDistance_m       36
set_variable lineDistance_m        90
set_variable heightOfFirstFloor_m  72
set_variable detectorType           1

if [[ -f $DETECTOR ]]; then
    echo "Detector $DETECTOR aleady exists; remove to overwrite."
    exit
fi

JDetector \
    -D $ID                                   \
    -@ "detectorType    = $detectorType"     \
    -@ "numberOfLines   = $numberOfLines"    \
    -@ "numberOfFloors  = $numberOfFloors"   \
    -@ "floorDistance_m = $floorDistance_m"  \
    -@ "lineDistance_m  = $lineDistance_m"   \
    -z $heightOfFirstFloor_m                 \
    -f footprint.txt                         \
    -o $DETECTOR -d 1 --!


# Create input data

JRandomTimesliceWriter \
    -a $DETECTOR                           \
    -o $INPUT_FILE                         \
    -B "$SINGLESRATE_HZ $DOUBLESRATE_HZ"   \
    -n $NUMBER_OF_SLICES                   \
    -d1 --!


set_variable  DQ_SIMULATOR               JDQSimulator
set_variable  NUMBER_OF_DQ_SIMULATORS    ${#SOURCE_HOST}
set_variable  NUMBER_OF_FRAMES           `JPrintDetector -a $DETECTOR -O modules | awk '/Module/ {if ($4 != 0) {print $0}}' | wc -l`


# JDataFilter configure data

cat>$WORKDIR/ev_configure_datafilter.txt<<EOF
logger_s               = 5;
update_s               = 10;
dataWriter             = ${WRITER_HOST};
numberOfFramesPerSlice = ${NUMBER_OF_FRAMES};
detector               = %<${DETECTOR}>%;
triggerParameters      = writeSummary            = 1;
triggerParameters      = writeL0                 = 1;
queueSize              = 100000000;
path                   = $WORKDIR;
JDataFilter            = ${DATAFILTER} ${FILTER_HOST}:${PORT};
JDataWriter            = ${DATAWRITER} ${WRITER_HOST};
EOF


# JDQSimulator configure data.

cat>$WORKDIR/ev_configure_dqsimulator.txt<<EOF
numberOfFrames         = ${NUMBER_OF_FRAMES};
numberOfEvents         = 1;
inputFile              = ${INPUT_FILE};
target                 = 0 ${FILTER_HOST}:${PORT};
EOF


# Driver input.

for (( i = 1; $i <= $NUMBER_OF_DQ_SIMULATORS ; ++i )); do

    let "index = ${#SOURCE_HOST}  -  $i % ${#SOURCE_HOST}"

    echo "source = 0 $DQ_SIMULATOR/$i;"                            >> $WORKDIR/ev_configure_dqsimulator.txt
    
    echo "process  $DQ_SIMULATOR/$i  $SOURCE_HOST[$index]         \
        csh -c '(setenv ROOTSYS $ROOTSYS && source $JPP_DIR/setenv.csh $JPP_DIR && ($DQ_SIMULATOR     \
        -u \$NAME\$     \
        -H \$SERVER\$   \
        -M \$LOGGER\$   \
        -d $DEBUG       \
        </dev/null >&/dev/null &))';"                              >> $WORKDIR/driver.txt
done

cat>>$WORKDIR/driver.txt<<EOF

process  ${DATAFILTER}  $FILTER_HOST  csh -c '(setenv ROOTSYS $ROOTSYS && source $JPP_DIR/setenv.csh $JPP_DIR && (JDataFilter  -H \$SERVER\$  -M \$LOGGER\$  -d $DEBUG  -u ${DATAFILTER}  -P $PORT  </dev/null >&/dev/null &))';
process  ${DATAWRITER}  $WRITER_HOST  csh -c '(setenv ROOTSYS $ROOTSYS && source $JPP_DIR/setenv.csh $JPP_DIR && (JDataWriter  -H \$SERVER\$  -M \$LOGGER\$  -d $DEBUG  -u ${DATAWRITER}            </dev/null >&/dev/null &))';

print 

enter

event ev_init      { RC_CMD }
event ev_reset     { RC_CMD }
event ev_init      { RC_CMD }

event ev_configure { 
    RC_DFLTR  %<$WORKDIR/ev_configure_datafilter.txt>%
    RC_DQSIM  %<$WORKDIR/ev_configure_dqsimulator.txt>% 
    RC_DWRT   path=$WORKDIR;  update_s=10;  logger_s=5;
}

event ev_start     { RC_CMD  $RUN  $ID }

sleep $RUNTIME_S

event ev_pause     { RC_CMD }
event ev_stop      { RC_CMD }
event ev_reset     { RC_CMD }
event ev_off       { RC_CMD }

EOF


# Go!

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


# Check processes

for PROCESS in JDQSimulator JDataFilter JDataWriter; do

    set_variable  PID  `ps h -o "%p" -C $PROCESS`

    debug "Check $PROCESS (${PID})."

    if [[ -n "$PID" ]] then
        error "$PROCESS still running (${PID})."
        kill -9 $PID
    fi
done


# Clean

echo -n "clean [Y/N]? "
read ANSWER

if [[ $ANSWER == "Y" || $ANSWER == "y" ]]; then
    clean
fi