diff options
author | Jon Bratseth <bratseth@oath.com> | 2019-09-19 12:20:11 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-09-19 12:20:11 +0200 |
commit | 299e27c104957512493873eab85b5a6e6a4461cc (patch) | |
tree | 6fc8b38259ba1f0d65d39daa229a5cbdff72347b /container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java | |
parent | 2279ae48f3eebcdaac92b169e36225768b209cb9 (diff) | |
parent | 6d4addd1f27746ee530c56bfa513659a7576b08b (diff) |
Merge pull request #10717 from vespa-engine/bratseth/vip-logic
Bratseth/vip logic
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java b/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java index ac0c8375f04..b79f6f49c19 100644 --- a/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java +++ b/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java @@ -24,7 +24,7 @@ public class ClusterMonitor<T> { private MonitorConfiguration configuration = new MonitorConfiguration(); - private static Logger log=Logger.getLogger(ClusterMonitor.class.getName()); + private static Logger log = Logger.getLogger(ClusterMonitor.class.getName()); private NodeManager<T> nodeManager; @@ -69,6 +69,7 @@ public class ClusterMonitor<T> { /** Called from ClusterSearcher/NodeManager when a node failed */ public synchronized void failed(T node, ErrorMessage error) { + nodeManager.statusIsKnown(node); BaseNodeMonitor<T> monitor = nodeMonitors.get(node); boolean wasWorking = monitor.isWorking(); monitor.failed(error); @@ -79,6 +80,7 @@ public class ClusterMonitor<T> { /** Called when a node responded */ public synchronized void responded(T node) { + nodeManager.statusIsKnown(node); BaseNodeMonitor<T> monitor = nodeMonitors.get(node); boolean wasFailing =! monitor.isWorking(); monitor.responded(); |