Package io.netty.incubator.channel.uring
Class IOUringRecvByteAllocatorHandle
java.lang.Object
io.netty.channel.RecvByteBufAllocator.DelegatingHandle
io.netty.incubator.channel.uring.IOUringRecvByteAllocatorHandle
- All Implemented Interfaces:
io.netty.channel.RecvByteBufAllocator.ExtendedHandle
,io.netty.channel.RecvByteBufAllocator.Handle
final class IOUringRecvByteAllocatorHandle
extends io.netty.channel.RecvByteBufAllocator.DelegatingHandle
implements io.netty.channel.RecvByteBufAllocator.ExtendedHandle
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final io.netty.channel.unix.PreferredDirectByteBufAllocator
private boolean
-
Constructor Summary
ConstructorsConstructorDescriptionIOUringRecvByteAllocatorHandle
(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle) -
Method Summary
Modifier and TypeMethodDescriptionio.netty.buffer.ByteBuf
allocate
(io.netty.buffer.ByteBufAllocator alloc) boolean
boolean
continueReading
(io.netty.util.UncheckedBooleanSupplier maybeMoreDataSupplier) (package private) void
Methods inherited from class io.netty.channel.RecvByteBufAllocator.DelegatingHandle
attemptedBytesRead, attemptedBytesRead, delegate, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.RecvByteBufAllocator.Handle
attemptedBytesRead, attemptedBytesRead, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset
-
Field Details
-
preferredDirectByteBufAllocator
private final io.netty.channel.unix.PreferredDirectByteBufAllocator preferredDirectByteBufAllocator -
rdHupReceived
private boolean rdHupReceived
-
-
Constructor Details
-
IOUringRecvByteAllocatorHandle
IOUringRecvByteAllocatorHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
-
-
Method Details
-
rdHupReceived
void rdHupReceived() -
allocate
public io.netty.buffer.ByteBuf allocate(io.netty.buffer.ByteBufAllocator alloc) - Specified by:
allocate
in interfaceio.netty.channel.RecvByteBufAllocator.Handle
- Overrides:
allocate
in classio.netty.channel.RecvByteBufAllocator.DelegatingHandle
-
continueReading
public boolean continueReading()- Specified by:
continueReading
in interfaceio.netty.channel.RecvByteBufAllocator.Handle
- Overrides:
continueReading
in classio.netty.channel.RecvByteBufAllocator.DelegatingHandle
-
continueReading
public boolean continueReading(io.netty.util.UncheckedBooleanSupplier maybeMoreDataSupplier) - Specified by:
continueReading
in interfaceio.netty.channel.RecvByteBufAllocator.ExtendedHandle
-