diff --git a/transport/src/main/java/io/netty/channel/AbstractChannel.java b/transport/src/main/java/io/netty/channel/AbstractChannel.java index 21ac22afd6..951a6b6fb2 100644 --- a/transport/src/main/java/io/netty/channel/AbstractChannel.java +++ b/transport/src/main/java/io/netty/channel/AbstractChannel.java @@ -133,11 +133,6 @@ public abstract class AbstractChannel extends DefaultAttributeMap implements Cha }); } - @Override - public boolean isWritable() { - return pipeline.isWritable(); - } - @Override public final Integer id() { return id; diff --git a/transport/src/main/java/io/netty/channel/Channel.java b/transport/src/main/java/io/netty/channel/Channel.java index c2a968dd91..4f22560a06 100755 --- a/transport/src/main/java/io/netty/channel/Channel.java +++ b/transport/src/main/java/io/netty/channel/Channel.java @@ -108,11 +108,6 @@ public interface Channel extends AttributeMap, ChannelOutboundInvoker, ChannelPr */ boolean isActive(); - /** - * Return {@code true} if the outbound buffer of the {@link Channel} is writable. - */ - boolean isWritable(); - /** * Return the {@link ChannelMetadata} of the {@link Channel} which describe the nature of the {@link Channel}. */ diff --git a/transport/src/main/java/io/netty/channel/ChannelHandlerContext.java b/transport/src/main/java/io/netty/channel/ChannelHandlerContext.java index a6a327d6b1..d9a42f4a3d 100755 --- a/transport/src/main/java/io/netty/channel/ChannelHandlerContext.java +++ b/transport/src/main/java/io/netty/channel/ChannelHandlerContext.java @@ -128,12 +128,6 @@ public interface ChannelHandlerContext extends AttributeMap, ChannelPropertyAccess, ChannelInboundInvoker, ChannelOutboundInvoker { - /** - * Return {@link true} if the {@link ChannelHandlerContext} is writable, which means if the outbound buffer of - * the next in the {@link ChannelPipeline} is writable. - */ - boolean isWritable(); - /** * Return the {@link Channel} which is bound to the {@link ChannelHandlerContext}. */ diff --git a/transport/src/main/java/io/netty/channel/ChannelPipeline.java b/transport/src/main/java/io/netty/channel/ChannelPipeline.java index 4593327784..d036c57458 100644 --- a/transport/src/main/java/io/netty/channel/ChannelPipeline.java +++ b/transport/src/main/java/io/netty/channel/ChannelPipeline.java @@ -732,11 +732,6 @@ public interface ChannelPipeline extends ChannelInboundInvoker, ChannelOutboundI */ Map toMap(); - /** - * Return {@code true} if the outbound buffer is writable. - */ - boolean isWritable(); - @Override ChannelPipeline fireChannelRegistered(); diff --git a/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java b/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java index 86ae980bbd..4a50f8b3e2 100755 --- a/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java +++ b/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java @@ -1550,21 +1550,6 @@ final class DefaultChannelHandlerContext extends DefaultAttributeMap implements return channel().newFailedFuture(cause); } - @Override - public boolean isWritable() { - DefaultChannelHandlerContext ctx = prev; - for (;;) { - if (ctx.hasOutboundByteBuffer()) { - return ctx.isWritable(); - } - - if (ctx.hasOutboundMessageBuffer()) { - return ctx.isWritable(); - } - ctx = ctx.prev; - } - } - private void validateFuture(ChannelFuture future) { if (future == null) { throw new NullPointerException("future"); diff --git a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java index 01068f53b3..986706e3d7 100755 --- a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java +++ b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java @@ -1358,9 +1358,4 @@ final class DefaultChannelPipeline implements ChannelPipeline { public Iterator> iterator() { return toMap().entrySet().iterator(); } - - @Override - public boolean isWritable() { - return tail.isWritable(); - } }