# HG changeset patch # User e095732 # Date 1360235259 -32400 # Node ID 481dab56c3dc72e1de2b2e4608a2f2f21b2cf0fa # Parent 8d3cb7e5fa5702fee68c7dfa9dd22dbcb2b65aa7 aquarium can execute on mountain lion (with java 1.6) diff -r 8d3cb7e5fa57 -r 481dab56c3dc build.xml --- a/build.xml Sun Feb 03 18:29:45 2013 +0900 +++ b/build.xml Thu Feb 07 20:07:39 2013 +0900 @@ -34,7 +34,7 @@ - + diff -r 8d3cb7e5fa57 -r 481dab56c3dc scripts/aquarium.sh --- a/scripts/aquarium.sh Sun Feb 03 18:29:45 2013 +0900 +++ b/scripts/aquarium.sh Thu Feb 07 20:07:39 2013 +0900 @@ -1,25 +1,17 @@ #!/bin/bash -# java="java -version:1.6" -java="java" -# export JAVA_HOME="/System/Library/Java/JavaVirtualMachines/1.6.jdk/Contents/Home" max=$1 child_num=$2 -echo 1 +java=/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/bin/java ruby ./topology/treen.rb $1 $2 > ./topology/tree.dot -echo 2 dot -Tpng ./topology/tree.dot > ./topology/tree.png #open ./topology/tree.png -echo 3 +$java -version $java -cp ../Alice.jar alice.topology.manager.TopologyManager -p 10000 -conf ./topology/tree.dot -log ./output/manager.log -level debug > ./output/std_manager.log & -sleep 3 cnt=0 -#max=`expr $max - 1` while [ $cnt -lt $max ] do - echo 4 $cnt - $java -cp ../Alice.jar alice.test.topology.aquarium.FishMovementTopology -host 192.168.128.41 -port 10000 -p `expr 20000 + $cnt` -log ./output/aquarium${cnt}.log -level debug > ./output/std_aquarium${cnt}.log & + $java -cp ../Alice.jar alice.test.topology.aquarium.FishMovementTopology -host `hostname` -port 10000 -p `expr 20000 + $cnt` -log ./output/aquarium${cnt}.log -level debug > ./output/std_aquarium${cnt}.log & cnt=`expr $cnt + 1` - sleep 3 done wait diff -r 8d3cb7e5fa57 -r 481dab56c3dc src/alice/codesegment/CodeSegmentManager.java --- a/src/alice/codesegment/CodeSegmentManager.java Sun Feb 03 18:29:45 2013 +0900 +++ b/src/alice/codesegment/CodeSegmentManager.java Thu Feb 07 20:07:39 2013 +0900 @@ -11,7 +11,7 @@ private static CodeSegmentManager instance = new CodeSegmentManager(); public LinkedBlockingQueue readyQueue = new LinkedBlockingQueue(); private ThreadPoolExecutor codeSegmentExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), // initial number of threads - Runtime.getRuntime().availableProcessors(), + Runtime.getRuntime().availableProcessors(), Integer.MAX_VALUE, // keepAliveTime TimeUnit.SECONDS, new LinkedBlockingQueue());