diff --git a/src/main/java/org/jboss/netty/channel/socket/oio/OioWorker.java b/src/main/java/org/jboss/netty/channel/socket/oio/OioWorker.java index 583b73e963..4766b9c3ec 100644 --- a/src/main/java/org/jboss/netty/channel/socket/oio/OioWorker.java +++ b/src/main/java/org/jboss/netty/channel/socket/oio/OioWorker.java @@ -159,6 +159,8 @@ class OioWorker implements Runnable { future.setSuccess(); if (changed) { + channel.setInterestOpsNow(interestOps); + // Notify the worker so it stops or continues reading. Thread currentThread = Thread.currentThread(); Thread workerThread = channel.workerThread; @@ -166,7 +168,6 @@ class OioWorker implements Runnable { workerThread.interrupt(); } - channel.setInterestOpsNow(interestOps); fireChannelInterestChanged(channel); } } catch (Throwable t) {