package alice.topology.manager;

import org.msgpack.type.ValueFactory;

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

public class ConfigWaiter extends CodeSegment {
	
	public Receiver done = ids.create(CommandType.TAKE);
	public int count;
	
	public ConfigWaiter(int nodeNum) {
		this.count = nodeNum;
	}

	@Override
	public void run() {
		count--;
		if (count == 0) {
			ods.put("local", "start", ValueFactory.createNilValue());
			return;
		}
		ConfigWaiter cs3 = new ConfigWaiter(count);
		cs3.done.setKey("local", "done");
	}

}