package alice.test.topology.ring;

import org.msgpack.type.ValueFactory;

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

public class FirstRingMessagePassing extends CodeSegment {
	
	public Receiver counter = ids.create(CommandType.TAKE);
	private long startTime;
	private int count; 
	
	public FirstRingMessagePassing(long startTime, int count) {
		this.startTime = startTime;
		this.count = count;
	}
	
	@Override
	public void run() {
		int counter = this.counter.asInteger();
		++counter;
		ods.put("right", "counter", counter);
		if (counter >= count) {
			ods.put("right", "finish", ValueFactory.createNilValue());
			long endTime = System.nanoTime();
			long time = endTime - startTime;
			System.out.println(count + ", " + time);
			return;	
		}
		
		FirstRingMessagePassing cs = new FirstRingMessagePassing(startTime, count);
		cs.counter.setKey("local", "counter");
	}

}