diff --git a/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java b/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java index 9c695c87d2..4b935e08a5 100755 --- a/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java +++ b/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java @@ -880,12 +880,12 @@ final class DefaultChannelHandlerContext extends DefaultAttributeMap implements if (pipeline.isInboundShutdown()) { return; } - - if (findContextInbound() == next) { + DefaultChannelHandlerContext nextInbound = findContextInbound(); + if (nextInbound == next) { next.invokeInboundBufferUpdated(); } else { // Pipeline changed since the task was submitted; try again. - fireInboundBufferUpdated0(next); + fireInboundBufferUpdated0(nextInbound); } } };