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 classPendingBytesTracker.ChannelOutboundBufferPendingBytesTrackerprivate static classPendingBytesTracker.DefaultChannelPipelinePendingBytesTrackerprivate static classPendingBytesTracker.NoopPendingBytesTracker
-
Field Summary
Fields Modifier and Type Field Description private MessageSizeEstimator.HandleestimatorHandle
-
Constructor Summary
Constructors Modifier Constructor Description privatePendingBytesTracker(MessageSizeEstimator.Handle estimatorHandle)
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract voiddecrementPendingOutboundBytes(long bytes)abstract voidincrementPendingOutboundBytes(long bytes)(package private) static PendingBytesTrackernewTracker(Channel channel)intsize(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.HandleCalculate the size of the given message.- Specified by:
sizein 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)
-
-