Mercurial > hg > Database > Christie

comparison src/main/java/christie/topology/manager/CheckComingHost.java @ 44:6664efac18ee

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix CheckCommingHost ConfigWaiter IncommingHosts
author akahori
date Thu, 02 Aug 2018 11:44:47 +0900
parents cf5a75bc3e55
children 8dfd93810041
comparison
equal deleted inserted replaced
43:ea9657dc8311 44:6664efac18ee
20 } 20 }
21 21
22 @Override 22 @Override
23 public void run(CodeGearManager cgm) { 23 public void run(CodeGearManager cgm) {
24 24
25 boolean match = false;
26 // check cookie 25 // check cookie
27 if (hostMessage.cookie != null) { 26 if (hostMessage.cookie != null) {
28 if (absCookieTable.containsKey(hostMessage.cookie)){ 27 if (absCookieTable.containsKey(hostMessage.cookie)){
29 match = true;
30 hostMessage.absName = absCookieTable.get(hostMessage.cookie); 28 hostMessage.absName = absCookieTable.get(hostMessage.cookie);
31 System.out.println("match"); 29 System.out.println("match");
30 // coming host has ever joined this App
31 getLocalDGM().put("reconnectHost", hostMessage);
32 cgm.setup(new SearchHostName());
33 }else {
34 getLocalDGM().put("orderHash", "order");
35 getLocalDGM().put("newHost", hostMessage);
32 } 36 }
33 }
34
35 if (match){
36 // coming host has ever joined this App
37 getLocalDGM().put("reconnectHost", hostMessage);
38
39 // TODO: これから実装する
40 //new SearchHostName();
41 } else {
42 getLocalDGM().put("orderHash", "order");
43 getLocalDGM().put("newHost", hostMessage);
44 } 37 }
45 38
46 cgm.setup(new CheckComingHost()); 39 cgm.setup(new CheckComingHost());
47 } 40 }
48 41
49
50
51
52 } 42 }