annotate src/alice/test/topology/ring/RingMessagePassing.java @ 33:20c67f673224

change name of DataSegmentReceiver
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Wed, 18 Jan 2012 01:34:23 +0900
parents 2bfb796b0fa1
children ca079a730d0b
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package alice.test.topology.ring;
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
2
31
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
3 import java.net.InetAddress;
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
4 import java.net.UnknownHostException;
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
5
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 import alice.codesegment.CodeSegment;
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 import alice.datasegment.CommandType;
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
8 import alice.datasegment.Receiver;
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
9
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 public class RingMessagePassing extends CodeSegment {
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
11
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 32
diff changeset
12 public Receiver counter = ids.create(CommandType.TAKE);
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
13
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 @Override
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
15 public void run() {
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 int counter = this.counter.asInteger();
31
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
17
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
18
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 try {
31
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
20 System.out.print("[" + InetAddress.getLocalHost().getHostName() + "] ");
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
21 } catch (UnknownHostException e) {
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 e.printStackTrace();
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 }
31
5c704b9a9a87 add ring script
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
24 System.out.println(counter);
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
25
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 ods.put("right", "counter", counter);
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
27
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 RingMessagePassing cs = new RingMessagePassing();
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
29 cs.counter.setKey("local", "counter");
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 }
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
31
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
32 }