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

Removed predictor from DefaultNioDatagramChannelConfig because it's already implemented in its superclass

Browse Source
This commit is contained in:
Trustin Lee 2009-06-11 05:09:11 +00:00
parent 1a309bff34
commit e4871f8460
1 changed files with 0 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/org/jboss/netty/channel/socket/nio/DefaultNioDatagramChannelConfig.java
View File

@ -25,7 +25,6 @@ package org.jboss.netty.channel.socket.nio;
import java.net.DatagramSocket; import java.net.DatagramSocket;
import java.util.Map; import java.util.Map;
import org.jboss.netty.channel.AdaptiveReceiveBufferSizePredictor;
import org.jboss.netty.channel.ReceiveBufferSizePredictor; import org.jboss.netty.channel.ReceiveBufferSizePredictor;
import org.jboss.netty.channel.socket.DefaultDatagramChannelConfig; import org.jboss.netty.channel.socket.DefaultDatagramChannelConfig;
import org.jboss.netty.logging.InternalLogger; import org.jboss.netty.logging.InternalLogger;
@ -51,8 +50,6 @@ class DefaultNioDatagramChannelConfig extends DefaultDatagramChannelConfig
private volatile int writeBufferHighWaterMark = 64 * 1024; private volatile int writeBufferHighWaterMark = 64 * 1024;
private volatile int writeBufferLowWaterMark = 32 * 1024; private volatile int writeBufferLowWaterMark = 32 * 1024;
private volatile ReceiveBufferSizePredictor predictor =
new AdaptiveReceiveBufferSizePredictor();
private volatile int writeSpinCount = 16; private volatile int writeSpinCount = 16;
DefaultNioDatagramChannelConfig(DatagramSocket socket) { DefaultNioDatagramChannelConfig(DatagramSocket socket) {
@ -149,18 +146,4 @@ class DefaultNioDatagramChannelConfig extends DefaultDatagramChannelConfig
} }
this.writeSpinCount = writeSpinCount; this.writeSpinCount = writeSpinCount;
} }
@Override
public ReceiveBufferSizePredictor getReceiveBufferSizePredictor() {
return predictor;
}
@Override
public void setReceiveBufferSizePredictor(
ReceiveBufferSizePredictor predictor) {
if (predictor == null) {
throw new NullPointerException("predictor");
}
this.predictor = predictor;
}
} }