package christie.topology.node;

import christie.annotation.Peek;
import christie.annotation.Take;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.daemon.Config;
import christie.topology.manager.keepalive.KeepAlive;
import org.msgpack.type.ValueFactory;

public class ConfigurationFinish extends CodeGear {

    @Peek
    int reverseCount;

    @Peek
    int connectNodeNum;

    @Peek
    TopologyNodeConfig topologyNodeConfig;

    private CodeGear startCG;

    public ConfigurationFinish() {
        // System.err.println("config finish ...") ;
    }

    public ConfigurationFinish(CodeGear startCG) {
        this.startCG = startCG;
    }

    @Override
    protected void run(CodeGearManager cgm) {
        // System.err.println(" rcount = " + Integer.toString(rcount) + " " + Integer.toString(ncount));
        if (reverseCount == connectNodeNum) {
            getDGM(topologyNodeConfig.getManagerKey()).put("nodePrepareDone", "done");
            cgm.setup(new Start(startCG));


            /*if (topologyNodeConfig.useKeepAlive)
                cgm.setup(new KeepAlive());
            cgm.setup(new PrepareToClose());
            ClosedEventManager.getInstance().register(DeleteConnection.class);
            ClosedEventManager.getInstance().setKey();*/
            return;
        }

        cgm.setup(new ConfigurationFinish(this.startCG));
    }
}