Class IoUringAdaptiveBufferRingAllocator

java.lang.Object

io.netty.channel.uring.AbstractIoUringBufferRingAllocator

io.netty.channel.uring.IoUringAdaptiveBufferRingAllocator

All Implemented Interfaces:

IoUringBufferRingAllocator

public final class IoUringAdaptiveBufferRingAllocator
extends AbstractIoUringBufferRingAllocator

IoUringBufferRingAllocator implementation which uses an adaptive strategy to allocate buffers, which will decrease / increase the buffer size depending on if the allocated buffers were completely used or not before.

Field Summary

Fields

Modifier and Type	Field	Description
private final AdaptiveCalculator	calculator
static final int	DEFAULT_INITIAL
static final int	DEFAULT_MAXIMUM
static final int	DEFAULT_MINIMUM

Constructor Summary

Constructors

Constructor	Description
IoUringAdaptiveBufferRingAllocator()
IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator)	Creates new instance.
IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator, int minimum, int initial, int maximum)	Creates new instance.
IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator, int minimum, int initial, int maximum, boolean largeAllocation)	Creates new instance.

Method Summary

Modifier and Type	Method	Description
void	lastBytesRead(int attempted, int actual)	Does nothing by default, sub-classes might override this.
protected int	nextBufferSize()	Return the next buffer size of each ByteBuf that is put into the buffer ring.

Methods inherited from class AbstractIoUringBufferRingAllocator

allocate, allocateBatch

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_MINIMUM

public static final int DEFAULT_MINIMUM

See Also:

• Constant Field Values

DEFAULT_INITIAL

public static final int DEFAULT_INITIAL

See Also:

• Constant Field Values

DEFAULT_MAXIMUM

public static final int DEFAULT_MAXIMUM

See Also:

• Constant Field Values

calculator

private final AdaptiveCalculator calculator

Constructor Details

IoUringAdaptiveBufferRingAllocator

public IoUringAdaptiveBufferRingAllocator()

IoUringAdaptiveBufferRingAllocator

public IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator)

Creates new instance.

Parameters:

allocator - the ByteBufAllocator to use.

IoUringAdaptiveBufferRingAllocator

public IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator,
 int minimum,
 int initial,
 int maximum)

Creates new instance.

Parameters:

allocator - the ByteBufAllocator to use for the allocations

minimum - the inclusive lower bound of the expected buffer size

initial - the initial buffer size when no feed back was received

maximum - the inclusive upper bound of the expected buffer size

IoUringAdaptiveBufferRingAllocator

public IoUringAdaptiveBufferRingAllocator(ByteBufAllocator allocator,
 int minimum,
 int initial,
 int maximum,
 boolean largeAllocation)

Creates new instance.

Parameters:

allocator - the ByteBufAllocator to use for the allocations

minimum - the inclusive lower bound of the expected buffer size

initial - the initial buffer size when no feed back was received

maximum - the inclusive upper bound of the expected buffer size

largeAllocation - true if we should do a large allocation for the whole buffer ring and then slice out the buffers or false if we should do one allocation per buffer.

Method Details

nextBufferSize

protected int nextBufferSize()

Description copied from class: AbstractIoUringBufferRingAllocator

Return the next buffer size of each ByteBuf that is put into the buffer ring.

Specified by:

nextBufferSize in class AbstractIoUringBufferRingAllocator

Returns:

the next size.

lastBytesRead

public void lastBytesRead(int attempted,
 int actual)

Description copied from class: AbstractIoUringBufferRingAllocator

Does nothing by default, sub-classes might override this.

Specified by:

lastBytesRead in interface IoUringBufferRingAllocator

Overrides:

lastBytesRead in class AbstractIoUringBufferRingAllocator

Parameters:

attempted - the attempted bytes to read.

actual - the number of bytes that could be read.