diff --git a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java index 501af6473d..27fe0a8e44 100644 --- a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java +++ b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioChannel.java @@ -145,6 +145,9 @@ abstract class AbstractNioChannel 0) { - int lowWaterMark = ((NioChannelConfig) getConfig()).getWriteBufferLowWaterMark(); + int lowWaterMark = getConfig().getWriteBufferLowWaterMark(); if (writeBufferSize >= lowWaterMark) { interestOps |= Channel.OP_WRITE; } else { interestOps &= ~Channel.OP_WRITE; } } else { - int highWaterMark = ((NioChannelConfig) getConfig()).getWriteBufferHighWaterMark(); + int highWaterMark = getConfig().getWriteBufferHighWaterMark(); if (writeBufferSize >= highWaterMark) { interestOps |= Channel.OP_WRITE; } else { @@ -333,7 +336,7 @@ abstract class AbstractNioChannel= highWaterMark) { if (newWriteBufferSize - messageSize < highWaterMark) { @@ -354,7 +357,7 @@ abstract class AbstractNioChannel= lowWaterMark) { diff --git a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java index 8faccf893a..2b96e04f40 100644 --- a/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java +++ b/transport/src/main/java/io/netty/channel/socket/nio/AbstractNioWorker.java @@ -380,7 +380,7 @@ abstract class AbstractNioWorker implements Runnable { final SocketSendBufferPool sendBufferPool = this.sendBufferPool; final WritableByteChannel ch = channel.channel; final Queue writeBuffer = channel.writeBufferQueue; - final int writeSpinCount = ((NioChannelConfig) channel.getConfig()).getWriteSpinCount(); + final int writeSpinCount = channel.getConfig().getWriteSpinCount(); synchronized (channel.writeLock) { channel.inWriteNowLoop = true; for (;;) {