Fixed issue: NETTY-215 ChunkedWriteHandler stops handling write queue when ChunkedInput.nextChunk() fails.
* Fixed a bad file descriptor error
This commit is contained in:
parent
6dc0b12020
commit
347131e0fa
@ -221,7 +221,6 @@ public class ChunkedWriteHandler implements ChannelUpstreamHandler, ChannelDowns
|
||||
throws Exception {
|
||||
if (!future.isSuccess()) {
|
||||
currentEvent.getFuture().setFailure(future.getCause());
|
||||
((ChunkedInput) currentEvent.getMessage()).close();
|
||||
}
|
||||
}
|
||||
});
|
||||
@ -234,6 +233,11 @@ public class ChunkedWriteHandler implements ChannelUpstreamHandler, ChannelDowns
|
||||
ctx.sendDownstream(currentEvent);
|
||||
currentEvent = null;
|
||||
}
|
||||
|
||||
if (!channel.isConnected()) {
|
||||
discard(ctx);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user