Mercurial > hg > Database > Alice
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 |
rev | line source |
---|---|
30 | 1 package alice.test.topology.ring; |
2 | |
31 | 3 import java.net.InetAddress; |
4 import java.net.UnknownHostException; | |
5 | |
30 | 6 import alice.codesegment.CodeSegment; |
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 | 9 |
10 public class RingMessagePassing extends CodeSegment { | |
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 | 13 |
14 @Override | |
15 public void run() { | |
16 int counter = this.counter.asInteger(); | |
31 | 17 |
18 | |
30 | 19 try { |
31 | 20 System.out.print("[" + InetAddress.getLocalHost().getHostName() + "] "); |
21 } catch (UnknownHostException e) { | |
30 | 22 e.printStackTrace(); |
23 } | |
31 | 24 System.out.println(counter); |
30 | 25 |
26 ods.put("right", "counter", counter); | |
27 | |
28 RingMessagePassing cs = new RingMessagePassing(); | |
29 cs.counter.setKey("local", "counter"); | |
30 } | |
31 | |
32 } |