andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

allowed low water mark to be same with high water mark

Browse Source
This commit is contained in:
Trustin Lee 2008-11-28 06:57:29 +00:00
parent 4e7852e29e
commit 3e09a4ee60
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/jboss/netty/channel/socket/nio/DefaultNioSocketChannelConfig.java
View File

@ -45,7 +45,7 @@ class DefaultNioSocketChannelConfig extends DefaultSocketChannelConfig
InternalLoggerFactory.getInstance(DefaultNioSocketChannelConfig.class); InternalLoggerFactory.getInstance(DefaultNioSocketChannelConfig.class);
private volatile int writeBufferHighWaterMark = 256 * 1024; private volatile int writeBufferHighWaterMark = 256 * 1024;
private volatile int writeBufferLowWaterMark = 64 * 1024; private volatile int writeBufferLowWaterMark = 128 * 1024;
private volatile ReceiveBufferSizePredictor predictor = private volatile ReceiveBufferSizePredictor predictor =
new DefaultReceiveBufferSizePredictor(); new DefaultReceiveBufferSizePredictor();
private volatile int writeSpinCount = 16; private volatile int writeSpinCount = 16;

3
src/main/java/org/jboss/netty/channel/socket/nio/NioSocketChannel.java
View File

@ -171,7 +171,8 @@ abstract class NioSocketChannel extends AbstractChannel
if (e != null) { if (e != null) {
int newWriteBufferSize = writeBufferSize.addAndGet( int newWriteBufferSize = writeBufferSize.addAndGet(
-((ChannelBuffer) e.getMessage()).readableBytes()); -((ChannelBuffer) e.getMessage()).readableBytes());
if (newWriteBufferSize <= getConfig().getWriteBufferLowWaterMark()) { if (newWriteBufferSize == 0 ||
newWriteBufferSize < getConfig().getWriteBufferLowWaterMark()) {
exceededHighWaterMark = true; exceededHighWaterMark = true;
} }
} }