Mercurial > hg > Database > Alice

comparison src/alice/topology/node/IncomingConnectionInfo.java @ 271:3667ab045530

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
refactor
author sugi
date Sat, 24 Aug 2013 18:17:42 +0900
parents 23e53aaa8720
children f866178f3018
comparison
equal deleted inserted replaced
270:23e53aaa8720 271:3667ab045530
30 30
31 @Override 31 @Override
32 public void run() { 32 public void run() {
33 if (this.hostInfo.getVal() == null) { 33 if (this.hostInfo.getVal() == null) {
34 ods.put("local", "configNodeNum", count); 34 ods.put("local", "configNodeNum", count);
35 System.out.println("bbb");
36 return; 35 return;
37 } 36 }
38 37
39 HostMessage hostInfo = this.hostInfo.asClass(HostMessage.class); 38 HostMessage hostInfo = this.hostInfo.asClass(HostMessage.class);
40 System.out.println(hostInfo.connectionName+" "+hostInfo.name+" "+hostInfo.port );
41 DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port); 39 DataSegment.connect(hostInfo.connectionName, hostInfo.reverseName, hostInfo.name, hostInfo.port);
42 ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName); 40 ods.put(hostInfo.connectionName, "reverseKey", hostInfo.reverseName);
43 connectionList.add(hostInfo.connectionName); 41 connectionList.add(hostInfo.connectionName);
44 ods.update("_CLIST", connectionList); 42 ods.update("_CLIST", connectionList);
45 IncomingConnectionInfo cs = new IncomingConnectionInfo(absName, ++count, connectionList); 43 IncomingConnectionInfo cs = new IncomingConnectionInfo(absName, ++count, connectionList);
46 cs.hostInfo.setKey("manager", absName); 44 cs.hostInfo.setKey("manager", absName);
47 System.out.println("aaa"); 45
48 } 46 }
49 47
50 } 48 }