Mercurial > hg > Database > Christie
diff src/main/java/christie/topology/node/IncomingConnectionInfo.java @ 65:5deea416f980
fix variable name
author | akahori |
---|---|
date | Thu, 30 Aug 2018 10:56:37 +0900 |
parents | 20d4c0cce914 |
children | 4e2453333508 |
line wrap: on
line diff
--- a/src/main/java/christie/topology/node/IncomingConnectionInfo.java Thu Aug 30 10:55:37 2018 +0900 +++ b/src/main/java/christie/topology/node/IncomingConnectionInfo.java Thu Aug 30 10:56:37 2018 +0900 @@ -1,7 +1,7 @@ package christie.topology.node; -import christie.annotation.TakeFrom; +import christie.annotation.Take; import christie.codegear.CodeGear; import christie.codegear.CodeGearManager; import christie.topology.HostMessage; @@ -9,8 +9,8 @@ public class IncomingConnectionInfo extends CodeGear { - @TakeFrom("manager") - HostMessage hostInfo; + @Take + HostMessage remoteNodeInfo; private String absName; private int count; @@ -21,7 +21,7 @@ this.absName = absName; this.count = count; this.managerKey = managerKey; - //hostInfo.setKey(managerKey,absName); + //remoteNodeInfo.setKey(managerKey,absName); } @@ -29,26 +29,26 @@ @Override protected void run(CodeGearManager cgm) { - log.info(hostInfo.toString()); - if ( hostInfo.hostName.equals("")) { // end case + log.info(remoteNodeInfo.toString()); + if ( remoteNodeInfo.hostName.equals("")) { // end case log.info(" topology node finished " + absName); getLocalDGM().put("configNodeNum", 0); return ; } - log.info("topology node " + absName + " will connect to " + hostInfo.hostName ); - if (cgm.getDgmList().contains(hostInfo.connectionName)) { + log.info("topology node " + absName + " will connect to " + remoteNodeInfo.hostName ); + if (cgm.getDgmList().contains(remoteNodeInfo.connectionName)) { // need to wait remove by DeleteConnection - getDGM("manager").put(absName, hostInfo); + getDGM("manager").put(absName, remoteNodeInfo); } else { - cgm.createRemoteDGM(hostInfo.connectionName, hostInfo.hostName, hostInfo.port); + cgm.createRemoteDGM(remoteNodeInfo.connectionName, remoteNodeInfo.hostName, remoteNodeInfo.port); - getDGM(hostInfo.connectionName).put("reverseKey", hostInfo.reverseName); - getDGM(hostInfo.connectionName).put("reverseHostName", hostInfo.hostName); - getDGM(hostInfo.connectionName).put("reverseKeyPort", hostInfo.port); + getDGM(remoteNodeInfo.connectionName).put("reverseKey", remoteNodeInfo.reverseName); + getDGM(remoteNodeInfo.connectionName).put("reverseHostName", remoteNodeInfo.hostName); + getDGM(remoteNodeInfo.connectionName).put("reverseKeyPort", remoteNodeInfo.port); count++; - getLocalDGM().put("cMember", hostInfo.connectionName); + getLocalDGM().put("cMember", remoteNodeInfo.connectionName); cgm.setup(new CreateConnectionList()); }