Break the loop on connection closure

This commit is contained in:
Trustin Lee 2009-09-29 09:37:44 +00:00
parent 31185897af
commit 4132804793

View File

@ -454,6 +454,7 @@ class NioWorker implements Runnable {
// But we still need to clean up the pending writes.
cleanUpWriteBuffer(channel);
break;
} catch (Throwable t) {
channel.currentWriteEvent = null;
evt.getFuture().setFailure(t);