From 1a9c0fd5697214421700a7c894eb787fb866e72d Mon Sep 17 00:00:00 2001 From: Trustin Lee Date: Mon, 4 Jun 2012 11:18:48 -0700 Subject: [PATCH] Make use of the existance of bridge references to find a buffer --- .../io/netty/channel/DefaultChannelPipeline.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) 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;