package christie.topology.manager;


import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import org.msgpack.type.ValueFactory;

public class ConfigWaiter extends CodeGear {


    // Question; done 変数がわからない...何やっているんだろう.
    // public Receiver done = ids.create(CommandType.TAKE);
    @Take
    boolean done;

    @Take
    int nodeNum;



    public ConfigWaiter() { }

    @Override
    public void run(CodeGearManager cgm) {
        nodeNum--;
        if (nodeNum == 0) {
            put("local", "start", ValueFactory.createNilValue());
            put("startTime", System.currentTimeMillis());
            put("done", true);
            //update("running", true);

            return;
        }
        //ConfigWaiter cs3 = new ConfigWaiter(count);
        //cs3.done.setKey("local", "done");

        cgm.setup(new ConfigWaiter());
        getLocalDGM().put("nodeNum", nodeNum);
        getLocalDGM().put("done", false);
    }

}