EDG_JOBID=
LBPROXY=
LBPROXY_STORE_SOCK=
+LARGE_STRESS=
usage()
{
- echo "Usage : $0 [-x | -X store_socket_path] [-m bkserver_machine_name][-j job_id]"
+ echo "Usage : $0 [-x | -X store_socket_path] [-m bkserver_machine_name][-j job_id][-l size_of_random_data]"
exit 4
}
"-x") LBPROXY="-x -S $1" ;;
"-X") shift; LBPROXY="-x"; LBPROXY_STORE_SOCK="-S $1" ;;
"-j") shift; EDG_JOBID="$1" ;;
+ "-l") shift; LARGE_STRESS="-l $1" ;;
"*") usage ;;
esac
shift
send_log_ev()
{
echo $LOGEV $LBPROXY $LBPROXY_STORE_SOCK -j "$EDG_JOBID" -c "$EDG_WL_SEQUENCE" "$@" 1>&$LOGFD
- EDG_WL_SEQUENCE=`$LOGEV $LBPROXY $LBPROXY_STORE_SOCK -j $EDG_JOBID -c $EDG_WL_SEQUENCE "$@" 2>/dev/null`
+ EDG_WL_SEQUENCE=`$LOGEV $LARGE_STRESS $LBPROXY $LBPROXY_STORE_SOCK -j $EDG_JOBID -c $EDG_WL_SEQUENCE "$@" 2>/dev/null`
test $? -ne 0 -o -z "$EDG_WL_SEQUENCE" && exit 4
true
}
# some defaults
DEBUG=2
LOGFD=${LOGFD:-1}
+LARGE_STRESS=${LARGE_STRESS:-}
# timeouts for polling the bkserver
timeout=10
echo " -j | --jobs-count Count of test(ed) jobs."
echo " -s | --states List of states in which could tested jobs fall."
echo " -p | --proxy-purge-states List of states in which LBProxy purges the job."
+ echo " -l | --large-stress 'size' Do a large stress logging ('size' random data added to the messages."
+ echo " -g | --log 'logfile' Redirect all output to the 'logfile'."
echo ""
echo "For proper operation check your grid-proxy-info"
grid-proxy-info
{
# $LOGEV -j $EDG_JOBID -s NetworkServer -e UserTag --name color --value red
[ $DEBUG -gt 2 ] && echo "$LOGEV -j \"$EDG_JOBID\" -s UserInterface -c \"$EDG_WL_SEQUENCE\" $@"
- EDG_WL_SEQUENCE=`$LOGEV -j $EDG_JOBID -s UserInterface -c $EDG_WL_SEQUENCE "$@"`
+ EDG_WL_SEQUENCE=`$LOGEV $LARGE_STRESS -j $EDG_JOBID -s UserInterface -c $EDG_WL_SEQUENCE "$@"`
test $? -ne 0 -o -z "$EDG_WL_SEQUENCE" && echo "missing EDG_WL_SEQUENCE from $LOGEV"
}
# $LOGEV -x -j $EDG_JOBID -s NetworkServer -e UserTag --name color --value red
[ $DEBUG -gt 2 ] && echo "$LOGEV -x -j \"$EDG_JOBID\" -s UserInterface -c \"$EDG_WL_SEQUENCE\" $@"
- EDG_WL_SEQUENCE=`$LOGEV -x -j $EDG_JOBID -s UserInterface -c $EDG_WL_SEQUENCE "$@"`
+ EDG_WL_SEQUENCE=`$LOGEV -x $LARGE_STRESS -j $EDG_JOBID -s UserInterface -c $EDG_WL_SEQUENCE "$@"`
test $? -ne 0 -o -z "$EDG_WL_SEQUENCE" && echo "missing EDG_WL_SEQUENCE from $LOGEV"
}
[ $DEBUG -gt 0 ] && echo -n -e "Purging test jobs from db\t\t"
job=0
while [ $job -lt $JOBS_ARRAY_SIZE ] ; do
+ LARGE_STRESS=""
EDG_WL_SEQUENCE="UI=999999:NS=9999999999:WM=999999:BH=9999999999:JSS=999999:LM=999999:LRMS=999999:APP=999999"
# log_ev_proxy -e Clear --reason=PurgingDB
# purge_proxy
tmp=`echo $RANDOM % $st_count + 1 | bc`
state=`echo $STATES | cut -d " " -f $tmp | tr A-Z a-z`
- source glite-lb-$state.sh -X $TEST_LBPROXY_STORE_SOCK -m $BKSERVER_HOST -j ${SAMPLE_JOBS_ARRAY[$job]} 2>&1 1>/dev/null
+ source glite-lb-$state.sh $LARGE_STRESS -X $TEST_LBPROXY_STORE_SOCK -m $BKSERVER_HOST -j ${SAMPLE_JOBS_ARRAY[$job]} 2>&1 1>/dev/null
[ $? -ne 0 ] && echo -e "ERROR\n\tglite-lb-$state.sh ${SAMPLE_JOBS_ARRAY[$job]} error!"
proxy_state=`$JOBSTAT -x $TEST_LBPROXY_SERVE_SOCK ${SAMPLE_JOBS_ARRAY[$job]} 2>&1 | grep "state :" | cut -d " " -f 3 | tr A-Z a-z`
purged=`echo $LBPROXY_PURGE_STATES | grep $state`
"-j" | "--jobs-count") shift; JOBS_ARRAY_SIZE=$1 ;;
"-s" | "--states") shift; STATES="$1" ;;
"-p" | "--proxy-purge-states") shift; LBPROXY_PURGE_STATES="$1" ;;
- "-l" | "--log") shift ; logfile=$1 ;;
+ "-l" | "--large-stress") shift ; LARGE_STRESS="-l $1" ;;
+ "-g" | "--log") shift ; logfile=$1 ;;
*) echo "Unrecognized option $1" ;;