aboutsummaryrefslogtreecommitdiffstats
path: root/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeInfo.java
diff options
context:
space:
mode:
Diffstat (limited to 'clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeInfo.java')
-rw-r--r--clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeInfo.java15
1 files changed, 7 insertions, 8 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeInfo.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeInfo.java
index 746432f1d38..2993784dba4 100644
--- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeInfo.java
+++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeInfo.java
@@ -3,6 +3,7 @@ package com.yahoo.vespa.clustercontroller.core;
import com.yahoo.collections.Pair;
import com.yahoo.jrt.Target;
+import java.util.logging.Level;
import com.yahoo.vdslib.distribution.Distribution;
import com.yahoo.vdslib.distribution.Group;
import com.yahoo.vdslib.state.ClusterState;
@@ -12,12 +13,12 @@ import com.yahoo.vdslib.state.NodeType;
import com.yahoo.vdslib.state.State;
import com.yahoo.vespa.clustercontroller.core.hostinfo.HostInfo;
import com.yahoo.vespa.clustercontroller.core.rpc.RPCCommunicator;
+
import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.LinkedList;
import java.util.List;
import java.util.TreeMap;
-import java.util.logging.Level;
import java.util.logging.Logger;
/**
@@ -243,13 +244,11 @@ abstract public class NodeInfo implements Comparable<NodeInfo> {
public ContentCluster getCluster() { return cluster; }
- /** Returns true if the node is registered in slobrok */
- public boolean isInSlobrok() { return lastSeenInSlobrok == null; }
-
- /** Returns true if the node is NOT registered in slobrok */
- public boolean isNotInSlobrok() { return ! isInSlobrok(); }
+ /** Returns true if the node is currently registered in slobrok */
+ // FIXME why is this called "isRpcAddressOutdated" then???
+ public boolean isRpcAddressOutdated() { return lastSeenInSlobrok != null; }
- public Long lastSeenInSlobrok() { return lastSeenInSlobrok; }
+ public Long getRpcAddressOutdatedTimestamp() { return lastSeenInSlobrok; }
public void abortCurrentNodeStateRequests() {
for(Pair<GetNodeStateRequest, Long> it : pendingNodeStateRequests) {
@@ -276,7 +275,7 @@ abstract public class NodeInfo implements Comparable<NodeInfo> {
return wantedState;
}
- /** Returns the wanted state set directly by a user (i.e. not configured) */
+ /** Returns the wanted state set directly by a user (i.e not configured) */
public NodeState getUserWantedState() { return wantedState; }
public long getTimeOfFirstFailingConnectionAttempt() {