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