ChannelOutboundBuffer returns total pending write size
total pending write size may be used to optimize write batching
This commit is contained in:
parent
b9bbded84e
commit
393f7b2306
@ -545,6 +545,10 @@ public final class ChannelOutboundBuffer {
|
|||||||
RECYCLER.recycle(this, handle);
|
RECYCLER.recycle(this, handle);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public long totalPendingWriteBytes() {
|
||||||
|
return this.totalPendingSize;
|
||||||
|
}
|
||||||
|
|
||||||
private static final class Entry {
|
private static final class Entry {
|
||||||
Object msg;
|
Object msg;
|
||||||
ByteBuffer[] buffers;
|
ByteBuffer[] buffers;
|
||||||
|
Loading…
Reference in New Issue
Block a user