package christie.test.topology.treeTestTopology;

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

public class ParentCodeGear extends CodeGear{
    @Peek
    TopologyDataGear topoDG;

    @Peek
    int maxNodeNum;

    @Peek
    TopologyNodeConfig topologyNodeConfig;

    @Take
    int countNodeNum;

    @Take
    String childNodeName;

    @Override
    protected void run(CodeGearManager cgm) {
        System.out.println(topoDG.getNodeName() + " : " + childNodeName + " accept");
        if(countNodeNum == maxNodeNum){
            getDGM(topologyNodeConfig.getManagerKey()).put("FINISHMESSAGE", new Message());
        }else{
            getLocalDGM().put("countNodeNum", countNodeNum + 1);
            cgm.setup(new ParentCodeGear());
        }

    }
}