diff options
Diffstat (limited to 'clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java')
-rw-r--r-- | clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java index 8393e776fc2..c88bf71af09 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java @@ -150,7 +150,7 @@ public class SlobrokClient implements NodeLookup { } cluster.setSlobrokGenerationCount(mirrorVersion); for (NodeInfo nodeInfo : cluster.getNodeInfos()) { - if (slobrokNodes.containsKey(nodeInfo.getNode()) && nodeInfo.isNotInSlobrok()) { + if (slobrokNodes.containsKey(nodeInfo.getNode()) && nodeInfo.isRpcAddressOutdated()) { context.log(log, Level.WARNING, "Node " + nodeInfo @@ -187,7 +187,7 @@ public class SlobrokClient implements NodeLookup { newNext = null; } else if (newNext == null || newNext.node.compareTo(oldNext.getNode()) > 0) { assert(slobrokNodes.get(oldNext.getNode()) == null); - if (oldNext.isInSlobrok() && oldNext.getRpcAddress() != null) { + if (!oldNext.isRpcAddressOutdated() && oldNext.getRpcAddress() != null) { missingNodeInfos.add(oldNext); } oldNext = null; @@ -195,7 +195,7 @@ public class SlobrokClient implements NodeLookup { assert(newNext.rpcAddress != null); if (oldNext.getRpcAddress() == null || !oldNext.getRpcAddress().equals(newNext.rpcAddress)) { alteredRpcAddress.add(newNext); - } else if (oldNext.isNotInSlobrok()) { + } else if (oldNext.isRpcAddressOutdated()) { returningRpcAddressNodeInfos.add(oldNext); } oldNext = null; |