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

Fixed a bug where the future of the write request is sometimes not notified

Browse Source
This commit is contained in:
Trustin Lee 2009-09-29 10:01:51 +00:00
parent 6e68d6ba4f
commit 9791a0327f
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -451,12 +451,14 @@ class NioWorker implements Runnable {
// 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;
channel.inWriteNowLoop = false;
// But we still need to clean up the pending writes. // But we still need to clean up the pending writes.
cleanUpWriteBuffer(channel, e); cleanUpWriteBuffer(channel, e);
break; break;
} catch (Throwable t) { } catch (Throwable t) {
channel.currentWriteEvent = null; channel.currentWriteEvent = null;
channel.inWriteNowLoop = false;
evt.getFuture().setFailure(t); evt.getFuture().setFailure(t);
evt = null; evt = null;
fireExceptionCaught(channel, t); fireExceptionCaught(channel, t);