diff options
author | Jon Bratseth <bratseth@verizonmedia.com> | 2019-09-19 19:15:19 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@verizonmedia.com> | 2019-09-19 19:15:19 +0200 |
commit | d9a0deeb28c911ccd90d2b618602cec96196d254 (patch) | |
tree | 2c35bbe569f09f8e77c91948ca62d77d7602b6fb /container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Node.java | |
parent | ca11e50b27b343ff8e48e402ec965bd168576834 (diff) |
Revert "Merge pull request #10737 from vespa-engine/revert-10717-bratseth/vip-logic"
This reverts commit ae30a47174b67ca78dc33d21770903b3ee626240, reversing
changes made to 992b73092f0d14beb3ae380904d27886fe4dbc89.
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Node.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Node.java | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Node.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Node.java index a71ce0354f9..0dd933fc24e 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Node.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Node.java @@ -19,6 +19,7 @@ public class Node { private final int fs4port; final int group; + private final AtomicBoolean statusIsKnown = new AtomicBoolean(false); private final AtomicBoolean working = new AtomicBoolean(true); private final AtomicLong activeDocuments = new AtomicLong(0); @@ -45,9 +46,13 @@ public class Node { /** Returns the id of this group this node belongs to */ public int group() { return group; } - public void setWorking(boolean working) { - this.working.lazySet(working); - } + /** Note that we know the status of this node */ + public void setStatusIsKnown() { statusIsKnown.lazySet(true); } + + /** Returns whether we know the status of this node */ + public boolean getStatusIsKnown() { return statusIsKnown.get(); } + + public void setWorking(boolean working) { this.working.lazySet(working); } /** Returns whether this node is currently responding to requests */ public boolean isWorking() { return working.get(); } @@ -77,4 +82,5 @@ public class Node { @Override public String toString() { return "search node " + hostname + ":" + fs4port + " in group " + group; } + } |