# HG changeset patch
# User kazz <kazz@cr.ie.u-ryukyu.ac.jp>
# Date 1328730262 -32400
# Node ID a76e603c43a010d16eee01262cf7a0301ab23759
# Parent  eb1714f41caf47f8ff52d66c0a27ea8ae1da88e0
add ring relay size

diff -r eb1714f41caf -r a76e603c43a0 src/alice/codesegment/CodeSegmentManager.java
--- a/src/alice/codesegment/CodeSegmentManager.java	Wed Feb 08 17:35:40 2012 +0900
+++ b/src/alice/codesegment/CodeSegmentManager.java	Thu Feb 09 04:44:22 2012 +0900
@@ -10,7 +10,7 @@
 
 	private static CodeSegmentManager instance = new CodeSegmentManager();
 	public LinkedBlockingQueue<CodeSegment> readyQueue = new LinkedBlockingQueue<CodeSegment>();
-	ThreadPoolExecutor codeSegmentExecutor = new ThreadPoolExecutor(1, // initial number of threads
+	private ThreadPoolExecutor codeSegmentExecutor = new ThreadPoolExecutor(1, // initial number of threads
 												Runtime.getRuntime().availableProcessors(),
 												Integer.MAX_VALUE, // keepAliveTime
 												TimeUnit.SECONDS,
diff -r eb1714f41caf -r a76e603c43a0 src/alice/codesegment/OutputDataSegment.java
--- a/src/alice/codesegment/OutputDataSegment.java	Wed Feb 08 17:35:40 2012 +0900
+++ b/src/alice/codesegment/OutputDataSegment.java	Thu Feb 09 04:44:22 2012 +0900
@@ -32,6 +32,14 @@
 		DataSegment.get(managerKey).update(key, ValueFactory.createRawValue(val), cs);
 	}
 
+	public void put(String managerKey, String key, byte[] val) {
+		DataSegment.get(managerKey).put(key, ValueFactory.createRawValue(val), cs);
+	}
+	
+	public void update(String managerKey, String key, byte[] val) {
+		DataSegment.get(managerKey).update(key, ValueFactory.createRawValue(val), cs);
+	}
+	
 	public void put(String managerKey, String key, int val) {
 		DataSegment.get(managerKey).put(key, ValueFactory.createIntegerValue(val), cs);
 	}
diff -r eb1714f41caf -r a76e603c43a0 src/alice/test/topology/ring/CheckMyName.java
--- a/src/alice/test/topology/ring/CheckMyName.java	Wed Feb 08 17:35:40 2012 +0900
+++ b/src/alice/test/topology/ring/CheckMyName.java	Thu Feb 09 04:44:22 2012 +0900
@@ -20,7 +20,7 @@
 		String host = this.host.asString();
 		logger.debug(host);
 		if (host.equals("node0")) {
-			ods.put("local", "counter", 0);
+			ods.put("local", "counter", new byte[conf.size]);
 			FirstRingMessagePassing cs1 = new FirstRingMessagePassing(System.nanoTime(), conf.count);
 			cs1.counter.setKey("local", "counter");
 			RingFinish cs2 = new RingFinish("manager");
diff -r eb1714f41caf -r a76e603c43a0 src/alice/test/topology/ring/FirstRingMessagePassing.java
--- a/src/alice/test/topology/ring/FirstRingMessagePassing.java	Wed Feb 08 17:35:40 2012 +0900
+++ b/src/alice/test/topology/ring/FirstRingMessagePassing.java	Thu Feb 09 04:44:22 2012 +0900
@@ -19,10 +19,8 @@
 	
 	@Override
 	public void run() {
-		int counter = this.counter.asInteger();
-		++counter;
-		ods.put("right", "counter", counter);
-		if (counter >= count) {
+		ods.put("right", "counter", counter.val);
+		if (counter.index >= count) {
 			ods.put("right", "finish", ValueFactory.createNilValue());
 			long endTime = System.nanoTime();
 			long time = endTime - startTime;
diff -r eb1714f41caf -r a76e603c43a0 src/alice/test/topology/ring/RingMessagePassing.java
--- a/src/alice/test/topology/ring/RingMessagePassing.java	Wed Feb 08 17:35:40 2012 +0900
+++ b/src/alice/test/topology/ring/RingMessagePassing.java	Thu Feb 09 04:44:22 2012 +0900
@@ -10,10 +10,7 @@
 
 	@Override
 	public void run() {
-		int counter = this.counter.asInteger();
-				
-		ods.put("right", "counter", counter);
-		
+		ods.put("right", "counter", this.counter.val);
 		RingMessagePassing cs = new RingMessagePassing();
 		cs.counter.setKey("local", "counter");
 	}
diff -r eb1714f41caf -r a76e603c43a0 src/alice/test/topology/ring/RingTopologyConfig.java
--- a/src/alice/test/topology/ring/RingTopologyConfig.java	Wed Feb 08 17:35:40 2012 +0900
+++ b/src/alice/test/topology/ring/RingTopologyConfig.java	Thu Feb 09 04:44:22 2012 +0900
@@ -3,12 +3,17 @@
 import alice.topology.node.TopologyNodeConfig;
 
 public class RingTopologyConfig extends TopologyNodeConfig {
+	
 	public int count = 10;
+	public int size = 10;
+	
 	public RingTopologyConfig(String[] args) {
 		super(args);
 		for (int i = 0; i < args.length; i++) {
 			if ("-count".equals(args[i])) {
 				this.count = new Integer(args[++i]);
+			} else if ("-size".equals(args[i])) {
+				this.size = new Integer(args[++i]);
 			}
 		}
 	}