From 5240772424d1b0a04bc0ea12ee86e57f9d0c79c1 Mon Sep 17 00:00:00 2001 From: norman Date: Thu, 12 Apr 2012 14:27:34 +0200 Subject: [PATCH] Fix regression which I introduced this morning --- .../socket/nio/NioServerSocketPipelineSink.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketPipelineSink.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketPipelineSink.java index da04451aad..246d3fed17 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketPipelineSink.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketPipelineSink.java @@ -216,16 +216,12 @@ class NioServerSocketPipelineSink extends AbstractNioChannelSink { try { for (;;) { try { - if (selector.select(1000) <= 0) { - - // just continue if there was nothing selected - continue; + if (selector.select(1000) > 0) { + // There was something selected if we reach this point, so clear + // the selected keys + selector.selectedKeys().clear(); } - // There was something selected if we reach this point, so clear - // the selected keys - selector.selectedKeys().clear(); - // accept connections in a for loop until no new connection is ready for (;;) { SocketChannel acceptedSocket = channel.socket.accept();