software/JDataFilter/JDataFilter.sh

Go to the documentation of this file.

#!/usr/bin/env 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