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 Object
implements MessageSizeEstimator.Handle

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	PendingBytesTracker.ChannelOutboundBufferPendingBytesTracker
private static final class	PendingBytesTracker.DefaultChannelPipelinePendingBytesTracker
private static final class	PendingBytesTracker.NoopPendingBytesTracker

Field Summary

Fields

Modifier and Type	Field	Description
private final MessageSizeEstimator.Handle	estimatorHandle

Constructor Summary

Constructors

Modifier	Constructor	Description
private	PendingBytesTracker(MessageSizeEstimator.Handle estimatorHandle)

Method Summary

Modifier and Type	Method	Description
abstract void	decrementPendingOutboundBytes(long bytes)
abstract void	incrementPendingOutboundBytes(long bytes)
(package private) static PendingBytesTracker	newTracker(Channel channel)
final int	size(Object msg)	Calculate the size of the given message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

estimatorHandle

private final MessageSizeEstimator.Handle estimatorHandle

Constructor Details

PendingBytesTracker

private PendingBytesTracker(MessageSizeEstimator.Handle estimatorHandle)

Method Details

size

public final int size(Object msg)

Description copied from interface: MessageSizeEstimator.Handle

Calculate the size of the given message.

Specified by:

size in interface MessageSizeEstimator.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)