Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/253#discussion_r216118489
--- Diff: src/java/org/apache/cassandra/net/async/ByteBufDataOutputStreamPlus.java ---
@@ -196,10 +220,12 @@ protected void doFlush(int count) throws IOException
int byteCount = buffer.position();
currentBuf.writerIndex(byteCount);
- if (!Uninterruptibles.tryAcquireUninterruptibly(channelRateLimiter, byteCount,
2, TimeUnit.MINUTES))
+ if (!Uninterruptibles.tryAcquireUninterruptibly(channelRateLimiter, byteCount,
rateLimiterBlockTime, rateLimiterBlockTimeUnit))
--- End diff --
yes, i intentionally set it to 2 minutes.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscribe@cassandra.apache.org
For additional commands, e-mail: pr-help@cassandra.apache.org
|