diff options
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) { |