private final class AdaptiveRecvByteBufAllocator.HandleImpl extends DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle
Modifier and Type | Field and Description |
---|---|
private boolean |
decreaseNow |
private int |
index |
private int |
maxIndex |
private int |
minIndex |
private int |
nextReceiveBufferSize |
Constructor and Description |
---|
HandleImpl(int minIndex,
int maxIndex,
int initial) |
Modifier and Type | Method and Description |
---|---|
int |
guess()
Similar to
RecvByteBufAllocator.Handle.allocate(ByteBufAllocator) except that it does not allocate anything but just tells the
capacity. |
void |
readComplete()
The read has completed.
|
private void |
record(int actualReadBytes) |
allocate, attemptedBytesRead, attemptedBytesRead, continueReading, continueReading, incMessagesRead, lastBytesRead, lastBytesRead, reset, totalBytesRead
private final int minIndex
private final int maxIndex
private int index
private int nextReceiveBufferSize
private boolean decreaseNow
public int guess()
RecvByteBufAllocator.Handle
RecvByteBufAllocator.Handle.allocate(ByteBufAllocator)
except that it does not allocate anything but just tells the
capacity.private void record(int actualReadBytes)
public void readComplete()
RecvByteBufAllocator.Handle
readComplete
in interface RecvByteBufAllocator.Handle
readComplete
in class DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle