summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-01-03 23:53:47 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-01-03 23:53:47 +0100
commit54def71ee15c38b390eb0fe4b6a9df3cf370cbc2 (patch)
tree20845eee39e07055b64f92aec88bc2f06cbecbef /messagebus
parent2ccd749f26db9e6832f7f15b60cd1937d2aa291d (diff)
Wake up more often to check if room.
This allows us to let a few be a few and not many.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java4
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();