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
Fields Modifier and Type Field Description private io.netty.channel.unix.IovArray
iovArray
private io.netty.buffer.ByteBuf
readBuffer
-
Constructor Summary
Constructors Modifier Constructor Description private
IOUringStreamUnsafe()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
handleReadException(io.netty.channel.ChannelPipeline pipeline, io.netty.buffer.ByteBuf byteBuf, java.lang.Throwable cause, boolean close, IOUringRecvByteAllocatorHandle allocHandle)
protected java.util.concurrent.Executor
prepareToClose()
protected void
readComplete0(int res, int data, int outstanding)
Called once a read was completed.protected int
scheduleRead0()
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
scheduleWriteSingle(java.lang.Object msg)
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
-
-
-
-
Method Detail
-
prepareToClose
protected java.util.concurrent.Executor 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
protected int scheduleWriteSingle(java.lang.Object msg)
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, java.lang.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
-
-