changeset 118:2a64c13e743a

merge
author kazz
date Wed, 08 Feb 2012 18:02:40 +0900
parents fce61ee25d20 (diff) 4150c16e93fd (current diff)
children 49e7f02f0063 0706e989bc47
files StartFDLindaServ2.py StopProcess.py pexpect.py src/fdl/test/metaTransfer/FDLServWithSend.java src/fdl/test/metaTransfer/MetaProtocolEngine.java src/fdl/test/metaTransfer/MetaProtocolEngine_not.java src/fdl/test/metaTransfer/Ring/FDLServWithSend.java src/fdl/test/metaTransfer/Ring/MetaProtocolEngine.java src/fdl/test/metaTransfer/Ring/Server.java src/fdl/test/metaTransfer/Ring/TestSend.java src/fdl/test/metaTransfer/Ring/TestTransfer.java src/fdl/test/metaTransfer/Ring/TestTransferRing.java src/fdl/test/metaTransfer/Ring/TestTransferThree.java src/fdl/test/metaTransfer/Server.java src/fdl/test/metaTransfer/TestSend.java src/fdl/test/metaTransfer/TestTransfer.java src/fdl/test/transfer/ProtocolEngine.java src/fdl/test/transfer/Server.java src/fdl/test/transfer/TestSend.java src/fdl/test/transfer/TestTransfer.java src/fdl/test/transfer/cluster/FDLServWithSendMeta.java src/fdl/test/transfer/cluster/HostCheck.java src/fdl/test/transfer/cluster/MetaProtocolEngine.java src/fdl/test/transfer/cluster/ProtocolEngine.java src/fdl/test/transfer/cluster/ProtocolEngineMain.java src/fdl/test/transfer/cluster/Server.java src/fdl/test/transfer/cluster/ServerMain.java src/fdl/test/transfer/cluster/TestGet.java src/fdl/test/transfer/cluster/TestSend.java src/fdl/test/transfer/three/ProtocolEngine.java src/fdl/test/transfer/three/Server.java src/fdl/test/transfer/three/TestGet.java src/fdl/test/transfer/three/TestSend.java src/fdl/test/transfer/three/TestTransfer.java src/fdl/test/transfer/two/ProtocolEngine.java src/fdl/test/transfer/two/Server.java src/fdl/test/transfer/two/TestGet.java src/fdl/test/transfer/two/TestSend.java src/fdl/test/transfer/two/TestTransfer.java src/fdl/test2/CountTest.java src/fdl/test2/Server.java src/fdl/test2/TestRead.java src/fdl/test2/TestRing.java src/fdl/test2/client.java src/fdl/test2/nodelist
diffstat 12 files changed, 172 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/README	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,6 @@
+require
+$fdlhome/FedLinda.jar
+
+How to run
+./ring-run.sh
+
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/clean.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,5 @@
+#!/bin/sh
+rm -rf RingRelay.{o,e}*
+rm -rf *~
+rm nodes
+rm nodes-tcp-no-delay
\ No newline at end of file
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/cover.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,10 @@
+#!/bin/sh
+nodenum=3
+maxcount=30
+
+count=1
+while [ $count -le $maxcount ];
+do
+  qsub -l nodes=$nodenum:ppn=2 ring.sh
+  count=`expr $count + 1`
+done
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/debug.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,29 @@
+#!/bin/sh
+#
+#Federated Linda Ring Relay Test
+#
+#PBS -N RingRelay
+#PBS -l walltime=00:05:00
+
+fdlpath=/net/home/other/maui/student/e065701/fdl
+
+#cat $PBS_NODEFILE
+nodenum=`wc -l < $PBS_NODEFILE`
+nodenum=`expr $nodenum / 2 - 1`
+
+function run() {
+    read serv
+    read serv
+    ssh $serv pkill java < /dev/null
+    ssh $serv java -cp $fdlpath/FedLinda.jar fdl.test.debug2.ConfigurationManager -nodes $nodenum -relay 3 -size 4096 < /dev/null &
+    sleep 3
+    while read node; do
+	read node
+	ssh $node pkill java < /dev/null
+	ssh $node java -cp $fdlpath/FedLinda.jar fdl.test.debug2.FDLindaNode -manager $serv < /dev/null &
+    done
+    wait
+}
+
+cat $PBS_NODEFILE | uniq >> $fdlpath/nodes
+run < $PBS_NODEFILE
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/pkill.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,13 @@
+#!/bin/sh
+#
+#Federated Linda Ring Relay Test
+#
+#PBS -N pkill
+#PBS -l walltime=00:01:00
+
+for serv in `cat $PBS_NODEFILE`
+do
+  echo $serv
+  ssh $serv pkill java &
+done
+wait
\ No newline at end of file
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/ring-tcp-no-delay.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,27 @@
+#!/bin/sh
+#
+#Federated Linda Ring Relay Test
+#
+#PBS -N RingRelay
+#PBS -l walltime=00:05:00
+
+fdlpath=/net/home/other/maui/student/e065701/fdl
+
+nodenum=`wc -l < $PBS_NODEFILE`
+nodenum=`expr $nodenum / 2 - 1`
+
+function run() {
+    read serv
+    read serv
+    ssh $serv pkill java < /dev/null
+    ssh $serv java -cp $fdlpath/FedLindaTcpNoDelay.jar fdl.test.debug.ConfigurationManager -nodes $nodenum -relay 100 -size 4096 < /dev/null &
+    sleep 3
+    while read node; do
+	read node
+	ssh $node pkill java < /dev/null
+	ssh $node java -cp $fdlpath/FedLindaTcpNoDelay.jar fdl.test.debug.FDLindaNode -manager $serv < /dev/null &
+    done
+    wait
+}
+cat $PBS_NODEFILE | uniq >> $fdlpath/nodes-tcp-no-delay
+run < $PBS_NODEFILE
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/ring.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,34 @@
+#!/bin/sh
+#
+#Federated Linda Ring Relay Test
+#
+#PBS -q dque
+#PBS -N RingRelay
+#PBS -l walltime=00:05:00
+
+fdlpath=/home/mass/share/student/k108572
+#fdlpath=/net/home/other/maui/student/e065701/fdl
+#cat $PBS_NODEFILE
+nodenum=`wc -l < $PBS_NODEFILE`
+nodenum=`expr $nodenum / 4 - 1`
+
+function run() {
+    read serv
+    read serv
+    read serv
+    read serv
+    ssh $serv pkill java < /dev/null
+    ssh $serv java -cp $fdlpath/FedLinda.jar fdl.test.debug.ConfigurationManager -nodes $nodenum -relay 100 -size 4096 < /dev/null &
+    sleep 3
+    while read node; do
+	read node
+	read node
+	read node
+	ssh $node pkill java < /dev/null
+	ssh $node java -cp $fdlpath/FedLinda.jar fdl.test.debug.FDLindaNode -manager $serv < /dev/null &
+    done
+    wait
+}
+
+#cat $PBS_NODEFILE | uniq >> /tmp/nodes
+run < $PBS_NODEFILE
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/run-debug.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,2 @@
+#!/bin/sh
+qsub -l nodes=30:ppn=2 debug.sh
\ No newline at end of file
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/run-ring.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,10 @@
+#!/bin/sh
+count=6
+while [ $count -le 40 ];
+do
+  qsub -l nodes=$count:ppn=4 ring.sh
+  count=`expr $count + 5`
+done
+
+
+
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/run-tcp-no-delay.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,7 @@
+#!/bin/sh
+count=6
+while [ $count -le 86 ];
+do
+  qsub -l nodes=$count:ppn=2 ring-tcp-no-delay.sh
+  count=`expr $count + 5`
+done
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/test-tcp-no-delay.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,17 @@
+#!/bin/sh
+nodenum=30
+maxcount=1
+
+count=1
+while [ $count -le $maxcount ];
+do
+  qsub -l nodes=$nodenum:ppn=2 ring.sh
+  count=`expr $count + 1`
+done
+
+count=1
+while [ $count -le $maxcount ];
+do
+  qsub -l nodes=$nodenum:ppn=2 ring-tcp-no-delay.sh
+  count=`expr $count + 1`
+done
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tools/torque/test.sh	Wed Feb 08 18:02:40 2012 +0900
@@ -0,0 +1,12 @@
+#PBS -l nodes=10,walltime=00:10:00
+function run() {
+    read firstserv
+    while read serv; do
+	#ssh $serv env
+	(sleep 10; echo end)&
+    done
+    wait
+}
+echo start
+run < $PBS_NODEFILE
+echo run_end