view src/main/java/christie/topology/manager/TopologyManager.java @ 74:e2ce8038815a

fix FileParser
author akahori
date Wed, 05 Sep 2018 09:43:22 +0900
parents f1f34c3e33d4
children 2314c55534ef
line wrap: on
line source

package christie.topology.manager;

import christie.annotation.Peek;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;

import java.util.HashMap;
import java.util.LinkedList;

import christie.topology.HostMessage;

public class TopologyManager extends CodeGear {

    @Peek
    TopologyManagerConfig topologyManagerConfig;

    public TopologyManager() {
    }

    @Override
    protected void run(CodeGearManager cgm) {
        cgm.setup(new CheckComingHost());
        getLocalDGM().put("absCookieTable", new HashMap<String, String>());

        if(!topologyManagerConfig.dynamic) {
            cgm.setup(new FileParser());
            cgm.setup(new IncomingHosts());
            cgm.setup(new ConfigWaiter());
            getLocalDGM().put("running", false);
        }

        cgm.setup(new CreateHash());
        cgm.setup(new TopologyFinish());

        getLocalDGM().put("topology", new HashMap<String, HashMap<String, HostMessage>>());
        getLocalDGM().put("createdList", new LinkedList<String>());

    }


}