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, totalBytesReadprivate final int minIndex
private final int maxIndex
private int index
private int nextReceiveBufferSize
private boolean decreaseNow
public int guess()
RecvByteBufAllocator.HandleRecvByteBufAllocator.Handle.allocate(ByteBufAllocator) except that it does not allocate anything but just tells the
capacity.private void record(int actualReadBytes)
public void readComplete()
RecvByteBufAllocator.HandlereadComplete in interface RecvByteBufAllocator.HandlereadComplete in class DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle