diff --git a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java index 99fa276f93..ef50475640 100644 --- a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java +++ b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java @@ -621,8 +621,7 @@ public class DefaultChannelPipeline implements ChannelPipeline { if (ctx == null) { return false; } - ChannelBufferHolder in = ctx.in; - if (in != null && !in.isBypass() && in.hasByteBuffer()) { + if (ctx.inByteBridge != null) { return true; } ctx = ctx.next; @@ -634,8 +633,7 @@ public class DefaultChannelPipeline implements ChannelPipeline { if (ctx == null) { return false; } - ChannelBufferHolder in = ctx.inbound(); - if (in != null && !in.isBypass() && in.hasMessageBuffer()) { + if (ctx.inMsgBridge != null) { return true; } ctx = ctx.next; @@ -699,8 +697,7 @@ public class DefaultChannelPipeline implements ChannelPipeline { return false; } - ChannelBufferHolder out = ctx.outbound(); - if (out != null && !out.isBypass() && out.hasByteBuffer()) { + if (ctx.outByteBridge != null) { return true; } ctx = ctx.prev; @@ -713,8 +710,7 @@ public class DefaultChannelPipeline implements ChannelPipeline { return false; } - ChannelBufferHolder out = ctx.outbound(); - if (out != null && !out.isBypass() && out.hasMessageBuffer()) { + if (ctx.outMsgBridge != null) { return true; } ctx = ctx.prev;