view src/alice/test/topology/ring/RingMessagePassing.java @ 34:ca079a730d0b

added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Thu, 19 Jan 2012 16:01:50 +0900
parents 20c67f673224
children ae24d5d40c10
line wrap: on
line source

package alice.test.topology.ring;

import java.net.InetAddress;
import java.net.UnknownHostException;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.Receiver;

public class RingMessagePassing extends CodeSegment {

	public Receiver counter = ids.create(CommandType.TAKE);

	@Override
	public void run() {
		int counter = this.counter.asInteger();
		
		try {
			System.out.print("[" + InetAddress.getLocalHost().getHostName() + "] ");
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
		System.out.println(counter);
		
		ods.put("right", "counter", counter);
		
		RingMessagePassing cs = new RingMessagePassing();
		cs.counter.setKey("local", "counter");
	}

}