Mercurial > hg > Database > Christie

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

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix FileParser
author akahori
date Wed, 05 Sep 2018 09:43:22 +0900
parents f1f34c3e33d4
children 2314c55534ef
comparison
equal deleted inserted replaced
73:f1f34c3e33d4 74:e2ce8038815a
2 2
3 import christie.annotation.Peek; 3 import christie.annotation.Peek;
4 import christie.codegear.CodeGear; 4 import christie.codegear.CodeGear;
5 import christie.codegear.CodeGearManager; 5 import christie.codegear.CodeGearManager;
6 6
7 import java.io.File;
8 import java.io.FileNotFoundException;
9 import java.io.FileReader;
10 import java.util.ArrayList;
11 import java.util.HashMap; 7 import java.util.HashMap;
12 import java.util.LinkedList; 8 import java.util.LinkedList;
13 9
14 import christie.topology.HostMessage; 10 import christie.topology.HostMessage;
15 11
16 public class TopologyManager extends CodeGear { 12 public class TopologyManager extends CodeGear {
13
14 @Peek
15 TopologyManagerConfig topologyManagerConfig;
17 16
18 public TopologyManager() { 17 public TopologyManager() {
19 } 18 }
20 19
21 @Override 20 @Override
22 protected void run(CodeGearManager cgm) { 21 protected void run(CodeGearManager cgm) {
23 cgm.setup(new CheckComingHost()); 22 cgm.setup(new CheckComingHost());
24 getLocalDGM().put("absCookieTable", new HashMap<String, String>()); 23 getLocalDGM().put("absCookieTable", new HashMap<String, String>());
25 24
26 cgm.setup(new FileParser()); 25 if(!topologyManagerConfig.dynamic) {
27 cgm.setup(new IncomingHosts()); 26 cgm.setup(new FileParser());
28 cgm.setup(new ConfigWaiter()); 27 cgm.setup(new IncomingHosts());
28 cgm.setup(new ConfigWaiter());
29 getLocalDGM().put("running", false);
30 }
31
29 cgm.setup(new CreateHash()); 32 cgm.setup(new CreateHash());
30 cgm.setup(new TopologyFinish()); 33 cgm.setup(new TopologyFinish());
31 34
32 getLocalDGM().put("running", false);
33 getLocalDGM().put("hostInfoMap", new HashMap<String, HostMessage>());
34 getLocalDGM().put("topology", new HashMap<String, HashMap<String, HostMessage>>()); 35 getLocalDGM().put("topology", new HashMap<String, HashMap<String, HostMessage>>());
35 getLocalDGM().put("createdList", new LinkedList<String>()); 36 getLocalDGM().put("createdList", new LinkedList<String>());
36 37
37 } 38 }
38 39