diff options
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/cluster/TrafficNodeMonitor.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/cluster/TrafficNodeMonitor.java | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/cluster/TrafficNodeMonitor.java b/container-search/src/main/java/com/yahoo/search/cluster/TrafficNodeMonitor.java index 830014bca46..ea881ad8b48 100644 --- a/container-search/src/main/java/com/yahoo/search/cluster/TrafficNodeMonitor.java +++ b/container-search/src/main/java/com/yahoo/search/cluster/TrafficNodeMonitor.java @@ -36,7 +36,6 @@ public class TrafficNodeMonitor<T> extends BaseNodeMonitor<T> { @Override public void failed(ErrorMessage error) { respondedAt = now(); - atStartUp = false; if (error.getCode() == Error.BACKEND_COMMUNICATION_ERROR.code) { setWorking(false, "Connection failure: " + error.toString()); @@ -61,14 +60,9 @@ public class TrafficNodeMonitor<T> extends BaseNodeMonitor<T> { setWorking(true,"Responds correctly"); } - /** - * Returns whether this node is currently is a state suitable for receiving traffic, or null if not known - */ - public Boolean isKnownWorking() { return atStartUp ? null : isWorking; } - /** Thread-safely changes the state of this node if required */ - protected synchronized void setWorking(boolean working, String explanation) { - if (this.isWorking == working) return; // Old news + protected synchronized void setWorking(boolean working,String explanation) { + if (this.isWorking==working) return; // Old news if (explanation==null) { explanation=""; |