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) {
            getLocalDGM().put("start", ValueFactory.createNilValue());
            getLocalDGM().put("startTime", System.currentTimeMillis());
            getLocalDGM().put("running", true);

            return;
        }

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

}