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

Reduced unnecessary system calls triggered by Channel.isConnected()

Browse Source
This commit is contained in:
Trustin Lee 2009-09-21 02:08:19 +00:00
parent 588cfa8518
commit 80b6a5b7ae
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java
View File

@ -342,11 +342,6 @@ class NioWorker implements Runnable {
} }
static void write(final NioSocketChannel channel, boolean mightNeedWakeup) { static void write(final NioSocketChannel channel, boolean mightNeedWakeup) {
if (!channel.isConnected()) {
cleanUpWriteBuffer(channel);
return;
}
if (mightNeedWakeup && scheduleWriteIfNecessary(channel)) { if (mightNeedWakeup && scheduleWriteIfNecessary(channel)) {
return; return;
} }
@ -452,7 +447,9 @@ class NioWorker implements Runnable {
addOpWrite = true; addOpWrite = true;
break; break;
} }
} catch (AsynchronousCloseException e) { } catch (ClosedChannelException e) {
cleanUpWriteBuffer(channel);
// Doesn't need a user attention - ignore. // Doesn't need a user attention - ignore.
channel.currentWriteEvent = evt; channel.currentWriteEvent = evt;
channel.currentWriteIndex = bufIdx; channel.currentWriteIndex = bufIdx;