Mercurial > hg > FederatedLinda
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