From: Zdeněk Šustr <sustr4@cesnet.cz>
Date: Tue, 27 Mar 2012 07:55:13 +0000 (+0000)
Subject: Script for generating test events -- initial (working) upload
X-Git-Tag: glite-jobid-api-c_R_2_1_2_1~9
X-Git-Url: http://scientific.zcu.cz/git/?a=commitdiff_plain;h=a012558e4f44480aed6973cf02d486b296dfeb48;p=jra1mw.git

Script for generating test events -- initial (working) upload
---

diff --git a/org.glite.testsuites.ctb/LB/tests/lb-generate-events.sh b/org.glite.testsuites.ctb/LB/tests/lb-generate-events.sh
new file mode 100755
index 0000000..f57e246
--- /dev/null
+++ b/org.glite.testsuites.ctb/LB/tests/lb-generate-events.sh
@@ -0,0 +1,192 @@
+#!/bin/bash
+#
+# Copyright (c) Members of the EGEE Collaboration. 2004-2010.
+# See http://www.eu-egee.org/partners for details on the copyright holders.
+# 
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# 
+#     http://www.apache.org/licenses/LICENSE-2.0
+# 
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+# show help and usage
+progname=`basename $0`
+showHelp()
+{
+cat << EndHelpHeader
+Script for generating test events at a pre-determined rate.
+
+Prerequisities:
+   - LB local logger, interlogger, and server running
+   - environment variables set:
+
+     GLITE_LB_SERVER_PORT - if nondefault port (9000) is used
+     GLITE_LB_LOGGER_PORT - if nondefault port (9002) is used 	
+     GLITE_WMS_QUERY_SERVER
+     GLITE_WMS_LOG_DESTINATION
+
+Ops called:
+
+    job registration
+    event logging
+
+EndHelpHeader
+
+	echo "Usage: $progname [OPTIONS] [event file prefix]"
+	echo "Options:"
+	echo " -h | --help            Show this help message."
+	echo " -n | --n-per-sec       Number of events to send between each 1-s pause."
+	echo " -N | --no-of-jobs      Number of jobs to keep unfinished simultaneously."
+	echo ""
+}
+
+
+send_next_event ()
+{
+	NO=$1
+	EDG_WL_SEQUENCE=${seq[$NO]}
+	currjobid=${jobid[$NO]}
+
+	case "${state[${NO}]}" in
+
+	0)
+		printf "%-25s" "Registering testing job "
+		currjobid=`${LBJOBREG} -m ${GLITE_WMS_QUERY_SERVER} -s application 2>&1 | $SYS_GREP "new jobid" | ${SYS_AWK} '{ print $3 }'`
+		jobid[${NO}]=$currjobid
+		EDG_WL_SEQUENCE="UI=000000:NS=0000000000:WM=000000:BH=0000000000:JSS=000000:LM=000000:LRMS=000000:APP=000002:LBS=000000"
+		let "JOBS++"
+		;;
+	1)
+		printf "%-25s" "logging Accepted"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s NetworkServer -e Accepted --from="UserInterface" --from_host="sending component hostname" --from_instance="sending component instance" --local_jobid="new jobId (Condor Globus ...)"`
+		;;
+	2)
+		printf "%-25s" "logging EnQueued"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s NetworkServer -e EnQueued --queue="destination queue" --job="job description in receiver language" --result=OK --reason="detailed description of transfer"`
+		;;
+	3)
+		printf "%-25s" "logging DeQueued"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s WorkloadManager -e DeQueued --queue="queue name" --local_jobid="new jobId assigned by the receiving component"`
+		;;
+	4)
+		printf "%-25s" "logging HelperCall"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s WorkloadManager -e HelperCall --helper_name="name of the called component" --helper_params="parameters of the call" --src_role=CALLING`
+		;;
+	5)
+		printf "%-25s" "logging Match"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s WorkloadManager -e Match --dest_id="${DESTINATION:-destination CE/queue}"`
+		;;
+	6)
+		printf "%-25s" "logging HelperReturn"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s WorkloadManager -e HelperReturn --helper_name="name of the called component" --retval="returned data" --src_role=CALLING`
+		;;
+	7)
+		printf "%-25s" "logging EnQueued"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s WorkloadManager -e EnQueued --queue="destination queue" --job="job description in receiver language" --result=OK --reason="detailed description of transfer"`
+		;;
+	8)
+		printf "%-25s" "logging DeQueued"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s JobController -e DeQueued --queue="queue name" --local_jobid="new jobId assigned by the receiving component"`
+		;;
+	9)
+		printf "%-25s" "logging Transfer"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s JobController -e Transfer --destination="LRMS" --dest_host="destination hostname" --dest_instance="destination instance" --job="job description in receiver language" --result=OK --reason="detailed description of transfer" --dest_jobid="destination internal jobid"`
+		;;
+	10)
+		printf "%-25s" "logging Accepted"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s LogMonitor -e Accepted --from="JobController" --from_host="sending component hostname" --from_instance="sending component instance" --local_jobid="new jobId (Condor Globus ...)"`
+		;;
+	11)
+		printf "%-25s" "logging Transfer"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s LogMonitor -e Transfer --destination="LRMS" --dest_host="destination hostname" --dest_instance="destination instance" --job="job description in receiver language" --result=OK --reason="detailed description of transfer" --dest_jobid="destination internal jobid"`
+		;;
+	12)
+		printf "%-25s" "logging Running"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s LogMonitor -e Running --node="${CE_NODE:-worker node}"`
+		;;
+	13)
+		printf "%-25s" "logging Done"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s LogMonitor -e Done --status_code=OK --reason="reason for the change" --exit_code=0`
+		;;
+	14)
+		printf "%-25s" "logging Clear"
+		EDG_WL_SEQUENCE=`${LBLOGEVENT} -j $currjobid -c $EDG_WL_SEQUENCE -s LogMonitor -e Clear --reason=USER`
+		;;
+	esac
+	seq[$NO]="$EDG_WL_SEQUENCE"
+}
+
+MAXnoJOBS=20
+PerSec=5
+JOBS=0
+
+COMMON=lb-common.sh
+if [ ! -r ${COMMON} ]; then
+        printf "Common definitions '${COMMON}' missing! Some checks will be skipped."
+	unset COMMON
+fi
+source ${COMMON}
+
+
+while test -n "$1"
+do
+	case "$1" in
+		"-h" | "--help") showHelp && exit 2 ;;
+		"-n" | "--n-per-sec") shift && PerSec=$1 ;;
+		"-N" | "--no-of-jobs") shift && MAXnoJOBS=$1 ;;
+	esac
+	shift
+done
+
+	if [ ! -z "$COMMON" ]; then
+	        printf "Testing if all binaries are available"
+	        check_binaries $GRIDPROXYINFO $SYS_GREP $SYS_SED $SYS_AWK $SYS_CAT
+	        if [ $? -gt 0 ]; then
+			echo "Required binary not present"
+			exit 1
+	        fi
+
+		# check credentials
+		printf "Testing credentials"
+		check_credentials_and_generate_proxy
+		if [ $? != 0 ]; then
+			echo "No proxy available"
+			exit 1
+		fi
+	fi
+
+	for (( i=0; i<$MAXnoJOBS; i++ ))
+	do
+		state[$i]=0
+	done
+
+	CONT="yes"
+	while [ "$CONT" = "yes" ]; do
+
+		for (( j=0; j<$PerSec; j++ ))
+		do
+			let "curr = ($RANDOM + $RANDOM) % $MAXnoJOBS"
+
+			printf "%4d " "$curr"
+			send_next_event $curr
+			printf "${jobid[$curr]}\n"
+
+			let "state[${curr}] = ${state[${curr}]} + 1"
+			if [ ${state[${curr}]} -gt 14 ]; then
+				state[${curr}]=0
+			fi
+		done
+		printf "$JOBS jobs so far...\n"
+		sleep 1
+	done
+
+test_end
+
+