Mercurial > hg > Database > Alice

comparison src/alice/test/topology/ring/CheckMyName.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 ae24d5d40c10
children 0c2ad7c70f4e
comparison
equal deleted inserted replaced
45:ae24d5d40c10 46:1a498f436332
8 import alice.datasegment.CommandType; 8 import alice.datasegment.CommandType;
9 import alice.datasegment.Receiver; 9 import alice.datasegment.Receiver;
10 10
11 public class CheckMyName extends CodeSegment { 11 public class CheckMyName extends CodeSegment {
12 12
13 Receiver host = ids.create(CommandType.PEEK); 13 public Receiver host = ids.create(CommandType.PEEK);
14 Logger logger = Logger.getLogger(CheckMyName.class); 14
15 private Logger logger = Logger.getLogger(CheckMyName.class);
16 private RingTopologyConfig conf;
17 public CheckMyName(RingTopologyConfig conf) {
18 this.conf = conf;
19 }
15 @Override 20 @Override
16 public void run() { 21 public void run() {
17 String host = this.host.asString(); 22 String host = this.host.asString();
18 logger.debug(host); 23 logger.debug(host);
19 if (host.equals("node0")) { 24 if (host.equals("node0")) {
20 ods.put("local", "counter", 0); 25 ods.put("local", "counter", 0);
21 FirstRingMessagePassing cs1 = new FirstRingMessagePassing(new Date()); 26 FirstRingMessagePassing cs1 = new FirstRingMessagePassing(new Date(), conf.count);
22 cs1.counter.setKey("local", "counter"); 27 cs1.counter.setKey("local", "counter");
23 RingFinish cs2 = new RingFinish("manager"); 28 RingFinish cs2 = new RingFinish("manager");
24 cs2.finish.setKey("local", "finish"); 29 cs2.finish.setKey("local", "finish");
25 } else { 30 } else {
26 ods.close("manager"); 31 ods.close("manager");