[#972] Correctly mark the ChannelPipeline once a ChannelHandler was removed and because of this a buffer was freed
This commit is contained in:
parent
54af70f067
commit
4ac3bace0f
@ -626,6 +626,7 @@ final class DefaultChannelPipeline implements ChannelPipeline {
|
||||
|
||||
private void freeHandlerBuffers(ChannelHandler handler, ChannelHandlerContext ctx) {
|
||||
if (handler instanceof ChannelInboundHandler) {
|
||||
inboundBufferFreed = true;
|
||||
try {
|
||||
((ChannelInboundHandler) handler).freeInboundBuffer(ctx);
|
||||
} catch (Exception e) {
|
||||
@ -633,6 +634,7 @@ final class DefaultChannelPipeline implements ChannelPipeline {
|
||||
}
|
||||
}
|
||||
if (handler instanceof ChannelOutboundHandler) {
|
||||
outboundBufferFreed = true;
|
||||
try {
|
||||
((ChannelOutboundHandler) handler).freeOutboundBuffer(ctx);
|
||||
} catch (Exception e) {
|
||||
|
Loading…
x
Reference in New Issue
Block a user