Fix for recent regression on infinite ClosedChannelException
This commit is contained in:
parent
21f1779e50
commit
31185897af
@ -448,11 +448,12 @@ class NioWorker implements Runnable {
|
||||
break;
|
||||
}
|
||||
} catch (ClosedChannelException e) {
|
||||
cleanUpWriteBuffer(channel);
|
||||
|
||||
// Doesn't need a user attention - ignore.
|
||||
channel.currentWriteEvent = evt;
|
||||
channel.currentWriteIndex = bufIdx;
|
||||
|
||||
// But we still need to clean up the pending writes.
|
||||
cleanUpWriteBuffer(channel);
|
||||
} catch (Throwable t) {
|
||||
channel.currentWriteEvent = null;
|
||||
evt.getFuture().setFailure(t);
|
||||
|
Loading…
Reference in New Issue
Block a user