diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-03 23:53:47 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-03 23:53:47 +0100 |
commit | 54def71ee15c38b390eb0fe4b6a9df3cf370cbc2 (patch) | |
tree | 20845eee39e07055b64f92aec88bc2f06cbecbef | |
parent | 2ccd749f26db9e6832f7f15b60cd1937d2aa291d (diff) |
Wake up more often to check if room.
This allows us to let a few be a few and not many.
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 4 |
1 files changed, 2 insertions, 2 deletions
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(); |