diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-08 23:04:28 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-08 23:04:28 +0100 |
commit | 46afc8534594be2e16efd5befa089fa3c3191cee (patch) | |
tree | 03088fbdfefb373ca5335d28e061911e4efe3de9 /vespaclient-core | |
parent | 98ab0aaa219617a595754e6343356c98cc7d1a9d (diff) |
Use a constant with a descriptive name.
Diffstat (limited to 'vespaclient-core')
-rwxr-xr-x | vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java b/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java index 3c19da5b4fd..b38f4b4e516 100755 --- a/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java +++ b/vespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java @@ -24,6 +24,7 @@ public class SharedSender implements ReplyHandler { private SendSession sender; private RouteMetricSet metrics; private static final int REACT_LATENCY_ON_RACE = 5; + private static final int REACT_LATENCY_ON_WATERMARK = 5; private ConcurrentHashMap<ResultCallback, OwnerState> activeOwners = new ConcurrentHashMap<>(); @@ -230,7 +231,7 @@ public class SharedSender implements ReplyHandler { try { synchronized (numPending) { while (numPending.get() > limit) { - numPending.wait(5); + numPending.wait(REACT_LATENCY_ON_WATERMARK); } } } catch (InterruptedException e) { |