Mercurial > hg > Database > Alice
annotate src/main/java/alice/topology/node/ReceiveCloseMessage.java @ 602:8a9fd716c335 dispose
change topology class extends CodeSegment from MetaCodeSegment, Chat minor fix
| author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Tue, 03 May 2016 20:09:45 +0900 |
| parents | 3284428f525e |
| children |
| rev | line source |
|---|---|
| 478 | 1 package alice.topology.node; |
| 2 | |
| 3 import alice.codesegment.CodeSegment; | |
|
599
3284428f525e
add MetaCodeSegment & MetaDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
492
diff
changeset
|
4 import alice.codesegment.MetaCodeSegment; |
| 478 | 5 import alice.datasegment.CommandType; |
| 6 import alice.datasegment.Receiver; | |
| 7 | |
|
602
8a9fd716c335
change topology class extends CodeSegment from MetaCodeSegment, Chat minor fix
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
599
diff
changeset
|
8 public class ReceiveCloseMessage extends CodeSegment { |
| 478 | 9 |
| 492 | 10 private Receiver info; |
| 478 | 11 |
| 492 | 12 public ReceiveCloseMessage(CommandType type) { |
| 13 info = ids.create(type); | |
| 478 | 14 info.setKey("_CLOSEMESSEAGE"); |
| 15 } | |
| 16 | |
| 17 @Override | |
| 18 public void run() { | |
| 492 | 19 if (info.type == CommandType.PEEK) { |
| 20 new PrepareToClose(); | |
| 21 } else if (info.type == CommandType.TAKE){ | |
| 22 new ReceiveCloseMessage(CommandType.PEEK); | |
| 483 | 23 } |
| 478 | 24 } |
| 25 | |
| 26 } |