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 ds1 = ids.create(CommandType.TAKE);
	private long startTime;
	private int count;
	private int nodeNum;
	
	public FirstRingMessagePassing(long startTime, int count, int nodeNum) {
		this.startTime = startTime;
		this.count = count;
		this.nodeNum = nodeNum;
	}
	
	public FirstRingMessagePassing(int count, int nodeNum) { // at first
		this.startTime = System.nanoTime();
		this.count = count;
		this.nodeNum = nodeNum;
	}
	
	@Override
	public void run() {
		ods.put("right", "c", ds1.getVal()); // copy whole DataSegment to the right
		if (ds1.index > count) {        // after count time update of ds1
			ods.put("right", "finish", ValueFactory.createNilValue());
			long endTime = System.nanoTime();
			long time = endTime - startTime;
			System.out.println(nodeNum + " " + time / count / 1000000.0);
			return;
		}
		
		FirstRingMessagePassing cs = new FirstRingMessagePassing(startTime, count, nodeNum);
		cs.ds1.setKey("c");
	}

}