andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixed indefinite blocking

Browse Source
This commit is contained in:
Trustin Lee 2009-07-08 11:44:36 +00:00
parent 31ec36f3bb
commit 580a6e491a
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/jboss/netty/channel/socket/nio/NioServerSocketPipelineSink.java
View File

@ -227,6 +227,8 @@ class NioServerSocketPipelineSink extends AbstractChannelSink {
try { try {
if (selector.select(1000) > 0) { if (selector.select(1000) > 0) {
selector.selectedKeys().clear(); selector.selectedKeys().clear();
}
for (;;) { for (;;) {
SocketChannel acceptedSocket = channel.socket.accept(); SocketChannel acceptedSocket = channel.socket.accept();
if (acceptedSocket != null) { if (acceptedSocket != null) {
@ -235,7 +237,6 @@ class NioServerSocketPipelineSink extends AbstractChannelSink {
break; break;
} }
} }
}
} catch (SocketTimeoutException e) { } catch (SocketTimeoutException e) {
// Thrown every second to get ClosedChannelException // Thrown every second to get ClosedChannelException
// raised. // raised.