Package io.netty.channel
Class PendingBytesTracker
- java.lang.Object
-
- io.netty.channel.PendingBytesTracker
-
- All Implemented Interfaces:
MessageSizeEstimator.Handle
- Direct Known Subclasses:
PendingBytesTracker.ChannelOutboundBufferPendingBytesTracker
,PendingBytesTracker.DefaultChannelPipelinePendingBytesTracker
,PendingBytesTracker.NoopPendingBytesTracker
abstract class PendingBytesTracker extends java.lang.Object implements MessageSizeEstimator.Handle
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
PendingBytesTracker.ChannelOutboundBufferPendingBytesTracker
private static class
PendingBytesTracker.DefaultChannelPipelinePendingBytesTracker
private static class
PendingBytesTracker.NoopPendingBytesTracker
-
Field Summary
Fields Modifier and Type Field Description private MessageSizeEstimator.Handle
estimatorHandle
-
Constructor Summary
Constructors Modifier Constructor Description private
PendingBytesTracker(MessageSizeEstimator.Handle estimatorHandle)
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract void
decrementPendingOutboundBytes(long bytes)
abstract void
incrementPendingOutboundBytes(long bytes)
(package private) static PendingBytesTracker
newTracker(Channel channel)
int
size(java.lang.Object msg)
Calculate the size of the given message.
-
-
-
Field Detail
-
estimatorHandle
private final MessageSizeEstimator.Handle estimatorHandle
-
-
Constructor Detail
-
PendingBytesTracker
private PendingBytesTracker(MessageSizeEstimator.Handle estimatorHandle)
-
-
Method Detail
-
size
public final int size(java.lang.Object msg)
Description copied from interface:MessageSizeEstimator.Handle
Calculate the size of the given message.- Specified by:
size
in interfaceMessageSizeEstimator.Handle
- Parameters:
msg
- The message for which the size should be calculated- Returns:
- size The size in bytes. The returned size must be >= 0
-
incrementPendingOutboundBytes
public abstract void incrementPendingOutboundBytes(long bytes)
-
decrementPendingOutboundBytes
public abstract void decrementPendingOutboundBytes(long bytes)
-
newTracker
static PendingBytesTracker newTracker(Channel channel)
-
-