Mercurial > hg > Members > tatsuki > Alice

comparison src/alice/topology/node/StartTopologyNode.java @ 46:1a498f436332

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bug fix for time calculate
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Sat, 04 Feb 2012 16:03:05 +0900
parents ca079a730d0b
children 7982324d4329
comparison
equal deleted inserted replaced
45:ae24d5d40c10 46:1a498f436332
8 import alice.topology.HostMessage; 8 import alice.topology.HostMessage;
9 9
10 public class StartTopologyNode extends CodeSegment { 10 public class StartTopologyNode extends CodeSegment {
11 11
12 private TopologyNodeConfig conf; 12 private TopologyNodeConfig conf;
13 private Class<? extends CodeSegment> clazz; 13 private CodeSegment startCS;
14 14
15 public StartTopologyNode(TopologyNodeConfig conf, Class<? extends CodeSegment> clazz) { 15 public StartTopologyNode(TopologyNodeConfig conf, CodeSegment startCS) {
16 this.conf = conf; 16 this.conf = conf;
17 this.clazz = clazz; 17 this.startCS = startCS;
18 } 18 }
19 19
20 @Override 20 @Override
21 public void run() { 21 public void run() {
22 DataSegment.connect("manager", "", conf.managerHostName, conf.managerPort); 22 DataSegment.connect("manager", "", conf.managerHostName, conf.managerPort);
37 cs2.reverseKey.setKey("local", "reverseKey"); 37 cs2.reverseKey.setKey("local", "reverseKey");
38 cs2.reverseCount.setKey("local", "reverseCount"); 38 cs2.reverseCount.setKey("local", "reverseCount");
39 39
40 ods.put("local", "reverseCount", 0); 40 ods.put("local", "reverseCount", 0);
41 41
42 ConfigurationFinish cs3 = new ConfigurationFinish(clazz); 42 ConfigurationFinish cs3 = new ConfigurationFinish(startCS);
43 cs3.reverseCount.setKey("local", "reverseCount"); 43 cs3.reverseCount.setKey("local", "reverseCount");
44 cs3.configNodeNum.setKey("local", "configNodeNum"); 44 cs3.configNodeNum.setKey("local", "configNodeNum");
45 } 45 }
46 46
47 } 47 }