summaryrefslogtreecommitdiffstats
path: root/vespaclient-core
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-01-08 23:04:28 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-01-08 23:04:28 +0100
commit46afc8534594be2e16efd5befa089fa3c3191cee (patch)
tree03088fbdfefb373ca5335d28e061911e4efe3de9 /vespaclient-core
parent98ab0aaa219617a595754e6343356c98cc7d1a9d (diff)
Use a constant with a descriptive name.
Diffstat (limited to 'vespaclient-core')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedapi/SharedSender.java3
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) {