diff options
author | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-08-16 14:31:20 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-08-16 14:31:20 +0200 |
commit | 9dab52cdfc1d679629046899c85a6b5139ab5945 (patch) | |
tree | 90e850697f00f5f902ff1a2b5c11d4492c531ceb /container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java | |
parent | e32d551e91700add8758cf57d9b91f7624c2bd3a (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.java | 11 |
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); } |