format node path
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/0068ed34 Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/0068ed34 Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/0068ed34 Branch: refs/heads/master Commit: 0068ed3494b29106800f4b32e162156cd4a660ef Parents: f68df24 Author: Kevin Xu <[email protected]> Authored: Thu Dec 3 15:57:20 2015 +0800 Committer: Kevin Xu <[email protected]> Committed: Thu Dec 3 15:57:20 2015 +0800 ---------------------------------------------------------------------- .../org/trafodion/dcs/master/listener/ConnectReply.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/0068ed34/dcs/src/main/java/org/trafodion/dcs/master/listener/ConnectReply.java ---------------------------------------------------------------------- diff --git a/dcs/src/main/java/org/trafodion/dcs/master/listener/ConnectReply.java b/dcs/src/main/java/org/trafodion/dcs/master/listener/ConnectReply.java index 704c9a7..6012b74 100644 --- a/dcs/src/main/java/org/trafodion/dcs/master/listener/ConnectReply.java +++ b/dcs/src/main/java/org/trafodion/dcs/master/listener/ConnectReply.java @@ -170,9 +170,10 @@ class ConnectReply { indexArr[index] = index; maxIndex = Math.max(maxIndex, index); server = servers.get(index); + nodeRegisteredPath = registeredPath + "/" + server; if(LOG.isDebugEnabled()) LOG.debug(clientSocketAddress + ": " + "server selected in search 1 " + server ); - data = isServerAvalible(registeredPath + "/" + server); + data = isServerAvalible(nodeRegisteredPath); if(data != null){ found = true; break; @@ -185,10 +186,11 @@ class ConnectReply { for(index=maxIndex+1; index<length; index++){ if (indexArr[index] != index){ server = servers.get(index); + nodeRegisteredPath = registeredPath + "/" + server; if(LOG.isDebugEnabled()) LOG.debug(clientSocketAddress + ": " + "server selected in search 1 " + server ); - data = isServerAvalible(registeredPath + "/" + server); + data = isServerAvalible(nodeRegisteredPath); if(data != null){ found = true; break; @@ -203,10 +205,11 @@ class ConnectReply { for(index=0; index<maxIndex; index++){ if (indexArr[index] != index){ server = servers.get(index); + nodeRegisteredPath = registeredPath + "/" + server; if(LOG.isDebugEnabled()) LOG.debug(clientSocketAddress + ": " + "server selected in search 2 " + server ); - data = isServerAvalible(registeredPath + "/" + server); + data = isServerAvalible(nodeRegisteredPath); if(data != null){ found = true; break;
