From eafd8343ebc66c4d71b678d456b080449b5a42d9 Mon Sep 17 00:00:00 2001
From: Norman Maurer <norman@apache.org>
Date: Sun, 19 Feb 2012 13:59:09 +0100
Subject: [PATCH] Remove some casting. See #186

---
 .../netty/channel/socket/nio/AbstractNioChannel.java  | 11 +++++++----
 .../netty/channel/socket/nio/AbstractNioWorker.java   |  2 +-
 2 files changed, 8 insertions(+), 5 deletions(-)

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<C extends SelectableChannel & WritableByteChan
         return remoteAddress;
     }
     
+    @Override
+    public abstract NioChannelConfig getConfig();
+    
     int getRawInterestOps() {
         return super.getInterestOps();
     }
@@ -172,14 +175,14 @@ abstract class AbstractNioChannel<C extends SelectableChannel & WritableByteChan
         int writeBufferSize = this.writeBufferSize.get();
         if (writeBufferSize != 0) {
             if (highWaterMarkCounter.get() > 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<C extends SelectableChannel & WritableByteChan
 
             int messageSize = getMessageSize(e);
             int newWriteBufferSize = writeBufferSize.addAndGet(messageSize);
-            int highWaterMark =  ((NioChannelConfig) getConfig()).getWriteBufferHighWaterMark();
+            int highWaterMark =  getConfig().getWriteBufferHighWaterMark();
 
             if (newWriteBufferSize >= highWaterMark) {
                 if (newWriteBufferSize - messageSize < highWaterMark) {
@@ -354,7 +357,7 @@ abstract class AbstractNioChannel<C extends SelectableChannel & WritableByteChan
             if (e != null) {
                 int messageSize = getMessageSize(e);
                 int newWriteBufferSize = writeBufferSize.addAndGet(-messageSize);
-                int lowWaterMark = ((NioChannelConfig) getConfig()).getWriteBufferLowWaterMark();
+                int lowWaterMark = getConfig().getWriteBufferLowWaterMark();
 
                 if (newWriteBufferSize == 0 || newWriteBufferSize < lowWaterMark) {
                     if (newWriteBufferSize + messageSize >= 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<MessageEvent> writeBuffer = channel.writeBufferQueue;
-        final int writeSpinCount = ((NioChannelConfig) channel.getConfig()).getWriteSpinCount();
+        final int writeSpinCount = channel.getConfig().getWriteSpinCount();
         synchronized (channel.writeLock) {
             channel.inWriteNowLoop = true;
             for (;;) {