Mercurial > hg > Database > Christie
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>()); } }