Mercurial > hg > Applications > AliceVNC
annotate src/main/java/jp/ac/u_ryukyu/alicevnc/CheckCurrentInfo.java @ 54:4c0b06abd840
Fix spell miss
| author | Tatsuki IHA <e125716@ie.u-ryukyu.ac.jp> |
|---|---|
| date | Mon, 16 Nov 2015 15:41:01 +0900 |
| parents | 57ca704f86a3 |
| children | fe627049e289 4a8755a30aa8 |
| rev | line source |
|---|---|
| 27 | 1 package jp.ac.u_ryukyu.alicevnc; |
| 2 | |
| 29 | 3 import java.util.ArrayList; |
| 4 | |
| 32 | 5 import jp.ac.u_ryukyu.alicevnc.AliceVNCMessage.MessageType; |
| 27 | 6 import alice.codesegment.CodeSegment; |
| 7 import alice.datasegment.CommandType; | |
| 8 import alice.datasegment.Receiver; | |
| 9 | |
| 10 public class CheckCurrentInfo extends CodeSegment { | |
| 11 | |
| 12 private Receiver info = ids.create(CommandType.TAKE); // current Server Info | |
| 32 | 13 private AliceVNCMessage order; |
| 27 | 14 |
|
52
57ca704f86a3
back version Alice tag:work-compressedDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
47
diff
changeset
|
15 public CheckCurrentInfo(AliceVNCMessage order){ |
|
57ca704f86a3
back version Alice tag:work-compressedDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
47
diff
changeset
|
16 info.setKey("currentServer"); |
| 27 | 17 this.order = order; |
| 18 } | |
| 19 | |
| 20 @Override | |
| 21 public void run() { | |
| 32 | 22 AliceVNCMessage current = info.asClass(AliceVNCMessage.class); |
| 27 | 23 |
| 34 | 24 if (order.name.equals(current.name)) { |
| 25 // need check route and node name | |
| 26 ods.update("currentServer", current); | |
| 27 } else { | |
| 28 if (current.allowChange) { | |
| 29 // send Stop message to current | |
| 30 current.messageID = MessageType.StopProxy.getId(); | |
| 31 String address = current.getNextAddress(); | |
| 32 ods.put(address, "AliceVNCMessage", current); | |
| 29 | 33 |
| 34 | 34 AliceVNCMessage mes = new AliceVNCMessage(MessageType.StartNegotiate); |
| 35 mes.route = new ArrayList<String>(); | |
| 36 for (String s : order.route) { | |
| 37 mes.route.add(s); | |
| 38 } | |
| 39 mes.name = "node0"; | |
| 40 address = mes.getNextAddress(); | |
| 41 ods.put(address, "AliceVNCMessage", mes); | |
| 42 } else { | |
| 43 // not allow to change | |
| 44 order.messageID = MessageType.DeniedRequest.getId(); | |
| 45 order.name = "node0"; | |
| 46 String address = order.getNextAddress(); | |
| 47 ods.put(address, "AliceVNCMessage", order); | |
| 27 | 48 |
| 34 | 49 // update current server info |
| 50 ods.update("currentServer", current); | |
| 51 } | |
| 27 | 52 } |
|
52
57ca704f86a3
back version Alice tag:work-compressedDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
47
diff
changeset
|
53 new ReceiveAliceVNCMessage(); |
| 27 | 54 } |
| 55 } |