Package io.netty.incubator.channel.uring
Class AbstractIOUringStreamChannel.IOUringStreamUnsafe
java.lang.Object
io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
io.netty.incubator.channel.uring.AbstractIOUringStreamChannel.IOUringStreamUnsafe
- All Implemented Interfaces:
io.netty.channel.Channel.Unsafe
- Enclosing class:
AbstractIOUringStreamChannel
private final class AbstractIOUringStreamChannel.IOUringStreamUnsafe
extends AbstractIOUringChannel.AbstractUringUnsafe
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate io.netty.channel.unix.IovArray
private io.netty.buffer.ByteBuf
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
handleReadException
(io.netty.channel.ChannelPipeline pipeline, io.netty.buffer.ByteBuf byteBuf, Throwable cause, boolean close, IOUringRecvByteAllocatorHandle allocHandle) protected Executor
protected void
readComplete0
(int res, int data, int outstanding) Called once a read was completed.protected int
Schedule a read and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.readComplete(int, int)
calls that are expected because of the scheduled read.protected int
scheduleWriteMultiple
(io.netty.channel.ChannelOutboundBuffer in) Schedule the write of multiple messages in theChannelOutboundBuffer
and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write.protected int
Schedule the write of a single message and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write(package private) boolean
writeComplete0
(int res, int data, int outstanding) Called once a write was completed.Methods inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
close, connect, connectComplete, flush0, newIOUringHandle, pollIn, pollOut, pollRdHup, processDelayedClose, readComplete, recvBufAllocHandle, schedulePollIn, scheduleRead, shutdownInput, writeComplete
-
Field Details
-
readBuffer
private io.netty.buffer.ByteBuf readBuffer -
iovArray
private io.netty.channel.unix.IovArray iovArray
-
-
Constructor Details
-
IOUringStreamUnsafe
private IOUringStreamUnsafe()
-
-
Method Details
-
prepareToClose
-
scheduleWriteMultiple
protected int scheduleWriteMultiple(io.netty.channel.ChannelOutboundBuffer in) Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Schedule the write of multiple messages in theChannelOutboundBuffer
and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write.- Specified by:
scheduleWriteMultiple
in classAbstractIOUringChannel.AbstractUringUnsafe
-
scheduleWriteSingle
Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Schedule the write of a single message and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write- Specified by:
scheduleWriteSingle
in classAbstractIOUringChannel.AbstractUringUnsafe
-
scheduleRead0
protected int scheduleRead0()Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Schedule a read and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.readComplete(int, int)
calls that are expected because of the scheduled read.- Specified by:
scheduleRead0
in classAbstractIOUringChannel.AbstractUringUnsafe
-
readComplete0
protected void readComplete0(int res, int data, int outstanding) Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Called once a read was completed.- Specified by:
readComplete0
in classAbstractIOUringChannel.AbstractUringUnsafe
-
handleReadException
private void handleReadException(io.netty.channel.ChannelPipeline pipeline, io.netty.buffer.ByteBuf byteBuf, Throwable cause, boolean close, IOUringRecvByteAllocatorHandle allocHandle) -
writeComplete0
boolean writeComplete0(int res, int data, int outstanding) Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Called once a write was completed.- Specified by:
writeComplete0
in classAbstractIOUringChannel.AbstractUringUnsafe
-