From 0beaa107b4be5e68928349c4131d01a655003641 Mon Sep 17 00:00:00 2001 From: Norman Maurer Date: Mon, 27 Feb 2012 20:45:46 +0100 Subject: [PATCH] Fix assert usage. Thanks Trustin for review --- .../java/io/netty/channel/socket/nio/AbstractNioWorker.java | 4 +++- .../java/io/netty/channel/socket/oio/AbstractOioWorker.java | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) 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 14ffdc6d99..a5a109d9c1 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 @@ -273,7 +273,9 @@ abstract class AbstractNioWorker implements Worker { @Override public void executeInIoThread(Runnable eventRunnable) { - assert eventQueue.offer(eventRunnable); + boolean added = eventQueue.offer(eventRunnable); + + assert added; // wake up the selector to speed things selector.wakeup(); diff --git a/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioWorker.java b/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioWorker.java index ea773bc442..fb1b403894 100644 --- a/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioWorker.java +++ b/transport/src/main/java/io/netty/channel/socket/oio/AbstractOioWorker.java @@ -90,8 +90,9 @@ abstract class AbstractOioWorker implements Worker @Override public void executeInIoThread(Runnable eventRunnable) { - assert eventQueue.offer(eventRunnable); + boolean added = eventQueue.offer(eventRunnable); + assert added; // as we set the SO_TIMEOUT to 1 second this task will get picked up in 1 second at latest }