aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@yahoo-inc.com>2016-08-16 14:31:20 +0200
committerJon Bratseth <bratseth@yahoo-inc.com>2016-08-16 14:31:20 +0200
commit9dab52cdfc1d679629046899c85a6b5139ab5945 (patch)
tree90e850697f00f5f902ff1a2b5c11d4492c531ceb /container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java
parente32d551e91700add8758cf57d9b91f7624c2bd3a (diff)
Only use direct dispatch when the local node is responding
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java11
1 files changed, 7 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java b/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java
index ce221fa1479..25582e43f5e 100644
--- a/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java
+++ b/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java
@@ -12,12 +12,15 @@ import java.util.concurrent.Executor;
public interface NodeManager<T> {
/** Called when a failed node is working (ready for production) again */
- public void working(T node);
+ void working(T node);
/** Called when a working node fails */
- public void failed(T node);
+ void failed(T node);
- /** Called when a node should be pinged */
- public void ping(T node, Executor executor);
+ /**
+ * Called when a node should be pinged.
+ * This *must* lead to either a call to NodeMonitor.failed or NodeMonitor.responded
+ */
+ void ping(T node, Executor executor);
}