diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java index 67a52c58f2..b1276c8724 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java @@ -378,6 +378,11 @@ class NioWorker implements Runnable { } static void write(final NioSocketChannel channel, boolean mightNeedWakeup) { + if (!channel.isConnected()) { + cleanUpWriteBuffer(channel); + return; + } + if (mightNeedWakeup) { NioWorker worker = channel.getWorker(); if (worker != null) { @@ -397,11 +402,6 @@ class NioWorker implements Runnable { } } - if (!channel.isConnected()) { - cleanUpWriteBuffer(channel); - return; - } - final NioSocketChannelConfig cfg = channel.getConfig(); final int writeSpinCount = cfg.getWriteSpinCount(); final int maxWrittenBytes;