Mercurial > hg > Database > Christie
diff src/main/java/christie/topology/node/IncomingConnectionInfo.java @ 170:f9f83bb213e8
fix topology manager
author | akahori |
---|---|
date | Tue, 22 Jan 2019 18:32:39 +0900 |
parents | c7300be0fff6 |
children | 6eb548c188e5 |
line wrap: on
line diff
--- a/src/main/java/christie/topology/node/IncomingConnectionInfo.java Tue Jan 22 18:32:13 2019 +0900 +++ b/src/main/java/christie/topology/node/IncomingConnectionInfo.java Tue Jan 22 18:32:39 2019 +0900 @@ -14,11 +14,11 @@ @Take HostMessage remoteNodeInfo; + int count; + @Take TopologyDataGear topoDG; - int count; - public IncomingConnectionInfo() { this.count = 0; } @@ -32,22 +32,19 @@ protected void run(CodeGearManager cgm) { String connectionName = remoteNodeInfo.getConnectionName(); - if (remoteNodeInfo.getHostName().equals("")) { // end case - put("connectNodeNum", count); getLocalDGM().put("topoDG", topoDG); return; - }else{ + } cgm.createRemoteDGM(connectionName, remoteNodeInfo.getHostName(), remoteNodeInfo.getPort()); - getDGM(connectionName).put("reverseNodeName", topoDG.getNodeName()); topoDG.addConnection(connectionName); getLocalDGM().put("topoDG", topoDG); + getDGM(connectionName).put("reverseNodeName",connectionName); count++; - } cgm.setup(new IncomingConnectionInfo(count)); }