From 54def71ee15c38b390eb0fe4b6a9df3cf370cbc2 Mon Sep 17 00:00:00 2001
From: Henning Baldersheim <balder@yahoo-inc.com>
Date: Tue, 3 Jan 2017 23:53:47 +0100
Subject: Wake up more often to check if room. This allows us to let a few be a
 few and not many.

---
 messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'messagebus')

diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
index 6f8e0903e9b..12ec4186513 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
@@ -176,7 +176,7 @@ public final class SourceSession implements ReplyHandler {
                 try {
                     blockedCount++;
                     while (!closed && !throttlePolicy.canSend(msg, pendingCount)) {
-                        lock.wait(100);
+                        lock.wait(10);
                     }
                 } finally {
                     blockedCount--;
@@ -198,7 +198,7 @@ public final class SourceSession implements ReplyHandler {
                 throttlePolicy.processReply(reply);
             }
             done = (closed && pendingCount == 0);
-            if (blockedCount < 100) {
+            if (blockedCount < 10) {
                 lock.notifyAll();
             } else {
                 lock.notify();
-- 
cgit v1.2.3