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

Handle CancelledKeyException. See #327

Browse Source
This commit is contained in:
Norman Maurer 2012-08-31 12:44:17 +02:00
parent fee1492c6b
commit e2464a14a4
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/org/jboss/netty/channel/socket/nio/AbstractNioWorker.java
View File

@ -273,11 +273,15 @@ abstract class AbstractNioWorker implements Worker {
// loop over all keys as the selector may was unblocked because of a closed channel
for (SelectionKey key: selector.keys()) {
SelectableChannel ch = key.channel();
if ((ch instanceof DatagramChannel && !((DatagramChannel) ch).isConnected()) ||
ch instanceof SocketChannel && !((SocketChannel) ch).isConnected()) {
notConnected = true;
// cancel the key just to be on the safe side
key.cancel();
try {
if ((ch instanceof DatagramChannel && !((DatagramChannel) ch).isConnected()) ||
ch instanceof SocketChannel && !((SocketChannel) ch).isConnected()) {
notConnected = true;
// cancel the key just to be on the safe side
key.cancel();
}
} catch (CancelledKeyException e) {
// ignore
}
}
if (notConnected) {