Top Fields Constructors Methods
io.netty.incubator.channel.uring

pack-priv final Class IOUringRecvByteAllocatorHandle

extends DelegatingHandle
implements ExtendedHandle
Class Inheritance
All Implemented Interfaces
io.netty.channel.RecvByteBufAllocator.ExtendedHandle, io.netty.channel.RecvByteBufAllocator.Handle
Imports
io.netty.buffer.ByteBuf, .ByteBufAllocator, io.netty.channel.RecvByteBufAllocator, io.netty.channel.unix.PreferredDirectByteBufAllocator, io.netty.util.UncheckedBooleanSupplier

Deprecated

as a consequence of RecvByteBufAllocator.DelegatingHandle and RecvByteBufAllocator.ExtendedHandle being deprecated. See corresponding docs for further information.

Field Summary

Modifier and TypeField and Description
private final PreferredDirectByteBufAllocator
preferredDirectByteBufAllocator

private boolean
rdHupReceived

Constructor Summary

AccessConstructor and Description
pack-priv
IOUringRecvByteAllocatorHandle(RecvByteBufAllocator.ExtendedHandle handle)

Deprecated as a consequence of RecvByteBufAllocator.ExtendedHandle being deprecated.

Method Summary

Modifier and TypeMethod and Description
public ByteBuf
allocate(ByteBufAllocator alloc)

Overrides io.netty.channel.RecvByteBufAllocator.DelegatingHandle.allocate.

Implements io.netty.channel.RecvByteBufAllocator.Handle.allocate.

Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.
public boolean
continueReading()

Overrides io.netty.channel.RecvByteBufAllocator.DelegatingHandle.continueReading.

Implements io.netty.channel.RecvByteBufAllocator.Handle.continueReading.

Determine if the current read loop should continue.
public boolean
continueReading(UncheckedBooleanSupplier
A supplier that determines if there maybe more data to read.
maybeMoreDataSupplier)

Implements io.netty.channel.RecvByteBufAllocator.ExtendedHandle.continueReading.

Same as Handle#continueReading() except "more data" is determined by the supplier parameter.
pack-priv void
rdHupReceived()

Inherited from io.netty.channel.RecvByteBufAllocator.DelegatingHandle:
attemptedBytesReadattemptedBytesReaddelegateguessincMessagesReadlastBytesReadlastBytesReadreadCompletereset

Field Detail

preferredDirectByteBufAllocatorback to summary
private final PreferredDirectByteBufAllocator preferredDirectByteBufAllocator
rdHupReceivedback to summary
private boolean rdHupReceived

Constructor Detail

IOUringRecvByteAllocatorHandleback to summary
pack-priv IOUringRecvByteAllocatorHandle(RecvByteBufAllocator.ExtendedHandle handle)

Deprecated

as a consequence of RecvByteBufAllocator.ExtendedHandle being deprecated. See corresponding docs for further information.

Method Detail

allocateback to summary
public ByteBuf allocate(ByteBufAllocator alloc)

Overrides io.netty.channel.RecvByteBufAllocator.DelegatingHandle.allocate.

Implements io.netty.channel.RecvByteBufAllocator.Handle.allocate.

Doc from io.netty.channel.RecvByteBufAllocator.Handle.allocate.

Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.

Annotations
@Override
continueReadingback to summary
public boolean continueReading()

Overrides io.netty.channel.RecvByteBufAllocator.DelegatingHandle.continueReading.

Implements io.netty.channel.RecvByteBufAllocator.Handle.continueReading.

Doc from io.netty.channel.RecvByteBufAllocator.Handle.continueReading.

Determine if the current read loop should continue.

Returns:boolean

true if the read loop should continue reading. false if the read loop is complete.

Annotations
@Override
continueReadingback to summary
public boolean continueReading(UncheckedBooleanSupplier maybeMoreDataSupplier)

Implements io.netty.channel.RecvByteBufAllocator.ExtendedHandle.continueReading.

Doc from io.netty.channel.RecvByteBufAllocator.ExtendedHandle.continueReading.

Same as Handle#continueReading() except "more data" is determined by the supplier parameter.

Parameters
maybeMoreDataSupplier:UncheckedBooleanSupplier

A supplier that determines if there maybe more data to read.

Annotations
@Override
rdHupReceivedback to summary
pack-priv void rdHupReceived()