Adding upstream version 1.0.12.upstream/1.0.12upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 120 insertions, 0 deletions

diff --git a/lib/clplumbing/transient-test.sh b/lib/clplumbing/transient-test.sh
new file mode 100755
index 0000000..7da88bf
--- /dev/null
+++ b/lib/clplumbing/transient-test.sh
@@ -0,0 +1,120 @@
+#!/bin/sh
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
+#
+#
+####FIXME
+# Known problems within this testing:
+# 1. Doesn't reflect "someone else's message" problems into error count.
+# 2. Path to "ipctransient{client,server}" not flexible enough.
+
+no_logs=0
+exit_on_error=1
+num_servers=10
+num_clients=10
+client_time=2
+commpath_args=""
+
+cmd=`basename $0`
+USAGE="Usage: $cmd [-c clients] [-s servers] [-t timetowait] [-C commpath]"
+
+while getopts c:s:C:t: c
+do
+	case $c in
+	c)
+		num_clients=$OPTARG
+		;;
+	s)
+		num_servers=$OPTARG
+		;;
+	t)
+		client_time=$OPTARG
+		;;
+	C)
+		commpath_args="-$c $OPTARG"
+		;;
+	\?)
+		echo $USAGE
+		exit 2
+		;;
+	esac
+done
+shift `expr $OPTIND - 1`
+
+total_failed=0
+
+server_failed=0
+server_loop_cnt=0
+while [ $server_loop_cnt != $num_servers ]; do
+	echo "############ DEBUG: Starting server iter $server_loop_cnt"
+	if [ $no_logs = 1 ]; then
+	    ./ipctransientserver $commpath_args > /dev/null 2>&1 &
+	else
+	    ./ipctransientserver $commpath_args &
+	fi
+	server_pid=$!
+
+	sleep 5    
+
+	client_failed=0
+	client_loop_cnt=0
+	while [ $client_loop_cnt != $num_clients ]; do
+	sleep 5    
+	    echo "############ DEBUG: Starting client iter $client_loop_cnt"
+	    if [ $no_logs = 1 ]; then
+		./ipctransientclient $commpath_args > /dev/null 2>&1 &
+	    else
+		./ipctransientclient $commpath_args &
+	    fi
+	    client_pid=$!
+	    sleep $client_time
+		if [ $exit_on_error = 1 ];then
+			kill -0 $client_pid > /dev/null 2>&1 
+		else
+			kill -9 $client_pid > /dev/null 2>&1
+		fi
+	    rc=$?
+	    if [ $rc = 0 ]; then
+			echo "############ ERROR: Iter $client_loop_cnt failed to receive all messages"
+			client_failed=`expr $client_failed + 1`
+			if [ $exit_on_error = 1 ];then
+				echo "terminating after first error..."
+				exit 0
+			fi
+	    else
+			echo "############ INFO: Iter $client_loop_cnt passed"
+	    fi
+	    
+	    client_loop_cnt=`expr $client_loop_cnt + 1`;
+	done
+	server_loop_cnt=`expr $server_loop_cnt + 1`;
+	total_failed=`expr $total_failed + $client_failed`
+	kill -9 $server_pid > /dev/null 2>&1 
+	rc=$?
+	if [ $rc = 0 ]; then
+		echo "############ ERROR: Server was already dead"
+		server_failed=`expr $server_failed + 1`
+	fi
+done
+
+total_failed=`expr $total_failed + $server_failed`
+
+if [ $total_failed = 0 ]; then
+    echo "INFO: All tests passed"
+else
+    echo "ERROR: $total_failed tests failed"
+fi
+
+exit $total_failed