From 393f7b2306f282df852bb487173c725396607ea7 Mon Sep 17 00:00:00 2001 From: milenkovicm Date: Fri, 3 Jan 2014 16:16:12 +0000 Subject: [PATCH] ChannelOutboundBuffer returns total pending write size total pending write size may be used to optimize write batching --- .../src/main/java/io/netty/channel/ChannelOutboundBuffer.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java b/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java index a52700c3d1..59bd315714 100644 --- a/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java +++ b/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java @@ -545,6 +545,10 @@ public final class ChannelOutboundBuffer { RECYCLER.recycle(this, handle); } + public long totalPendingWriteBytes() { + return this.totalPendingSize; + } + private static final class Entry { Object msg; ByteBuffer[] buffers;