comparison src/main/java/jp/ac/u_ryukyu/alicevnc/CheckCurrentInfo.java @ 28:71dd46e2d706

send ServerInIt message
author sugi
date Sat, 08 Nov 2014 16:48:36 +0900
parents 14c7bd581cc2
children 0f964a1ec846
comparison
equal deleted inserted replaced
27:14c7bd581cc2 28:71dd46e2d706
1 package jp.ac.u_ryukyu.alicevnc; 1 package jp.ac.u_ryukyu.alicevnc;
2 2
3 import jp.ac.u_ryukyu.alicevnc.ChangeRequestMessage.MessageType;
3 import alice.codesegment.CodeSegment; 4 import alice.codesegment.CodeSegment;
4 import alice.datasegment.CommandType; 5 import alice.datasegment.CommandType;
5 import alice.datasegment.Receiver; 6 import alice.datasegment.Receiver;
6 7
7 public class CheckCurrentInfo extends CodeSegment { 8 public class CheckCurrentInfo extends CodeSegment {
14 this.order = order; 15 this.order = order;
15 } 16 }
16 17
17 @Override 18 @Override
18 public void run() { 19 public void run() {
20 System.out.println("check");
19 ChangeRequestMessage current = info.asClass(ChangeRequestMessage.class); 21 ChangeRequestMessage current = info.asClass(ChangeRequestMessage.class);
20 22
21 if (current.allowChange) { 23 if (current.allowChange) {
22 // send Stop message to current 24 // send Stop message to current
25 current.messageID = MessageType.StopProxy.getId();
23 int last = current.route.size() - 1; 26 int last = current.route.size() - 1;
24 String address = current.route.get(last); 27 String address = current.route.get(last);
25 current.route.remove(last); 28 current.route.remove(last);
26 ods.put(address, "changeRequest", current); 29 ods.put(address, "changeRequest", current);
27 30