package alice.test.topology.ring;

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

public class RingMessagePassing extends CodeSegment {

	public DataSegmentReceiver counter = new DataSegmentReceiver(ids, CommandType.TAKE);

	@Override
	public void run() {
		int counter = this.counter.asInteger();
		System.out.println(counter);

		try {
			Thread.sleep(200);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		
		ods.put("right", "counter", counter);
		
		RingMessagePassing cs = new RingMessagePassing();
		cs.counter.setKey("local", "counter");
	}

}