Class AdaptiveRecvByteBufAllocator.HandleImpl

java.lang.Object

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

io.netty.channel.AdaptiveRecvByteBufAllocator.HandleImpl

All Implemented Interfaces:

RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

Enclosing class:

AdaptiveRecvByteBufAllocator

private final class AdaptiveRecvByteBufAllocator.HandleImpl
extends DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

Field Summary

Fields

Modifier and Type	Field	Description
private final AdaptiveCalculator	calculator

Constructor Summary

Constructors

Constructor	Description
HandleImpl(int minimum, int initial, int maximum)

Method Summary

Modifier and Type	Method	Description
int	guess()	Similar to RecvByteBufAllocator.Handle.allocate(ByteBufAllocator) except that it does not allocate anything but just tells the capacity.
void	lastBytesRead(int bytes)	Set the bytes that have been read for the last read operation.
void	readComplete()	The read has completed.

Methods inherited from class DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

allocate, attemptedBytesRead, attemptedBytesRead, continueReading, continueReading, incMessagesRead, lastBytesRead, reset, totalBytesRead

Methods inherited from class Object

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

Field Details

calculator

private final AdaptiveCalculator calculator

Constructor Details

HandleImpl

HandleImpl(int minimum,
 int initial,
 int maximum)

Method Details

lastBytesRead

public void lastBytesRead(int bytes)

Description copied from interface: RecvByteBufAllocator.Handle

Set the bytes that have been read for the last read operation. This may be used to increment the number of bytes that have been read.

Specified by:

lastBytesRead in interface RecvByteBufAllocator.Handle

Overrides:

lastBytesRead in class DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

Parameters:

bytes - The number of bytes from the previous read operation. This may be negative if an read error occurs. If a negative value is seen it is expected to be return on the next call to RecvByteBufAllocator.Handle.lastBytesRead(). A negative value will signal a termination condition enforced externally to this class and is not required to be enforced in RecvByteBufAllocator.Handle.continueReading().

guess

public int guess()

Description copied from interface: RecvByteBufAllocator.Handle

Similar to RecvByteBufAllocator.Handle.allocate(ByteBufAllocator) except that it does not allocate anything but just tells the capacity.

readComplete

public void readComplete()

Description copied from interface: RecvByteBufAllocator.Handle

The read has completed.

Specified by:

readComplete in interface RecvByteBufAllocator.Handle

Overrides:

readComplete in class DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle