Package io.netty.channel.uring
Interface IoUringBufferRingAllocator
-
- All Known Implementing Classes:
AbstractIoUringBufferRingAllocator
,IoUringAdaptiveBufferRingAllocator
,IoUringFixedBufferRingAllocator
public interface IoUringBufferRingAllocator
Allocator that is responsible to allocate buffers for a buffer ring.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description ByteBuf
allocate()
Creates a new receive buffer to use by the buffer ring.default void
allocateBatch(java.util.function.Consumer<ByteBuf> consumer, int num)
Fill innum
ofByteBuf
s.void
lastBytesRead(int attempted, int actual)
Set the bytes that have been read for the last read operation that was full-filled out of the buffer ring.
-
-
-
Method Detail
-
allocate
ByteBuf allocate()
Creates a new receive buffer to use by the buffer ring. The returnedByteBuf
must be direct.
-
lastBytesRead
void lastBytesRead(int attempted, int actual)
Set the bytes that have been read for the last read operation that was full-filled out of the buffer ring.- Parameters:
attempted
- the attempted bytes to read.actual
- the number of bytes that could be read.
-
allocateBatch
default void allocateBatch(java.util.function.Consumer<ByteBuf> consumer, int num)
- Parameters:
consumer
- theConsumer
that will consume the buffers.num
- the number of buffers that are passed toConsumer.accept(Object)
.
-
-