Mercurial > hg > Database > Alice
annotate src/alice/test/topology/ring/RingMessagePassing.java @ 32:2bfb796b0fa1
change method to create DataSegmentReceiver
| author | kazz <kazz@cr.ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 17 Jan 2012 20:49:26 +0900 |
| parents | 5c704b9a9a87 |
| children | 20c67f673224 |
| 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; | |
| 8 import alice.datasegment.DataSegmentReceiver; | |
| 9 | |
| 10 public class RingMessagePassing extends CodeSegment { | |
| 11 | |
|
32
2bfb796b0fa1
change method to create DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
31
diff
changeset
|
12 public DataSegmentReceiver counter = ids.createReceiver(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 } |