From 2723baa75c5362917ba78910b36aa0ff1c6e0421 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Tue, 11 Feb 2020 05:50:52 +0000 Subject: Ping timeout must be shorter than ping period, and add deprecation. --- .../com/yahoo/search/cluster/BaseNodeMonitor.java | 2 + .../yahoo/search/cluster/MonitorConfiguration.java | 59 +++++++--------------- 2 files changed, 19 insertions(+), 42 deletions(-) (limited to 'container-search/src/main') diff --git a/container-search/src/main/java/com/yahoo/search/cluster/BaseNodeMonitor.java b/container-search/src/main/java/com/yahoo/search/cluster/BaseNodeMonitor.java index dd01d895963..0d491d2f0c1 100644 --- a/container-search/src/main/java/com/yahoo/search/cluster/BaseNodeMonitor.java +++ b/container-search/src/main/java/com/yahoo/search/cluster/BaseNodeMonitor.java @@ -79,6 +79,8 @@ public abstract class BaseNodeMonitor { */ public abstract void responded(); + /** @deprecated Not used */ + @Deprecated // TODO: Remove on Vespa 8 public boolean isIdle() { return (now()-respondedAt) >= configuration.getIdleLimit(); } diff --git a/container-search/src/main/java/com/yahoo/search/cluster/MonitorConfiguration.java b/container-search/src/main/java/com/yahoo/search/cluster/MonitorConfiguration.java index 7b10992dff8..21e5fe3bc7f 100644 --- a/container-search/src/main/java/com/yahoo/search/cluster/MonitorConfiguration.java +++ b/container-search/src/main/java/com/yahoo/search/cluster/MonitorConfiguration.java @@ -14,23 +14,11 @@ public class MonitorConfiguration { */ private long checkInterval=1000; - /** - * The number of times a failed node must respond before getting - * traffic again - */ - private int responseAfterFailLimit=3; - - /** - * The number of ms a node is allowed to stay idle before it is - * pinged - */ - private long idleLimit=3000; - /** * The number of milliseconds to attempt to complete a request * before giving up */ - private final long requestTimeout = 5000; + private final long requestTimeout = 980; /** * The number of milliseconds a node is allowed to fail before we @@ -38,17 +26,6 @@ public class MonitorConfiguration { */ private long failLimit=5000; - /** - * The number of times a node is allowed to fail in one hour - * before it is quarantined for an hour - */ - private int failQuarantineLimit=3; - - /** - * The number of ms to quarantine an unstable node - */ - private long quarantineTime=1000*60*60; - /** * Sets the interval between each ping of idle or failing nodes * Default is 1000ms @@ -68,25 +45,27 @@ public class MonitorConfiguration { /** * Sets the number of times a failed node must respond before it is put * back in service. Default is 3. + * @deprecated Will go away in Vespa 8 */ - public void setResponseAfterFailLimit(int responseAfterFailLimit) { - this.responseAfterFailLimit=responseAfterFailLimit; - } + @Deprecated + public void setResponseAfterFailLimit(int responseAfterFailLimit) { } /** * Sets the number of ms a node (failing or working) is allowed to * stay idle before it is pinged. Default is 3000 + * @deprecated Will go away in Vespa 8 */ - public void setIdleLimit(int idleLimit) { - this.idleLimit=idleLimit; - } + @Deprecated + public void setIdleLimit(int idleLimit) { } /** * Gets the number of ms a node (failing or working) * is allowed to stay idle before it is pinged. Default is 3000 + * @deprecated Will go away in Vespa 8 */ + @Deprecated public long getIdleLimit() { - return idleLimit; + return 3000; } /** @@ -112,28 +91,24 @@ public class MonitorConfiguration { * in quarantine. Once in quarantine it won't be put back in * productuion before quarantineTime has expired even if it is * working. Default is 3 + * @deprecated Will go away in Vespa 8 */ - public void setFailQuarantineLimit(int failQuarantineLimit) { - this.failQuarantineLimit=failQuarantineLimit; - } + @Deprecated + public void setFailQuarantineLimit(int failQuarantineLimit) { } /** * The number of ms an unstable node is quarantined. Default is * 100*60*60 + * @deprecated Will go away in Vespa 8 */ - public void setQuarantineTime(long quarantineTime) { - this.quarantineTime=quarantineTime; - } + @Deprecated + public void setQuarantineTime(long quarantineTime) { } public String toString() { return "monitor configuration [" + "checkInterval: " + checkInterval + - " responseAfterFailLimit: " + responseAfterFailLimit + - " idleLimit: " + idleLimit + " requestTimeout " + requestTimeout + - " feilLimit " + failLimit + - " failQuerantineLimit " + failQuarantineLimit + - " quarantineTime " + quarantineTime + + " failLimit " + failLimit + "]"; } -- cgit v1.2.3