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());
            ods.put("startTime",System.currentTimeMillis());
            ods.update("running", true);
            return;
        }
        ConfigWaiter cs3 = new ConfigWaiter(count);
        cs3.done.setKey("local", "done");
    }

}