package christie.topology.manager;


import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.topology.Message;


import java.util.LinkedList;

public class ConfigWaiter extends CodeGear {

    @Peek
    LinkedList<String> waiterNodeNames;

    @Take
    Message _DONEMESSAGE;

    @Take
    int nodeNum;

    public ConfigWaiter() { }

    @Override
    protected void run(CodeGearManager cgm) {
        nodeNum--;
        if (nodeNum == 0) {
            getLocalDGM().put("_STARTMESSAGE", new Message());
            for (String nodeName: waiterNodeNames) getDGM(nodeName).put("_STARTMESSAGE", new Message());
            getLocalDGM().put("startTime", System.currentTimeMillis());
            getLocalDGM().put("running", true);

            return;
        }

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

}