Class IoUringSocketChannel.IoUringSocketUnsafe
java.lang.Object
io.netty.channel.AbstractChannel.AbstractUnsafe
io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe
io.netty.channel.uring.AbstractIoUringStreamChannel.IoUringStreamUnsafe
io.netty.channel.uring.IoUringSocketChannel.IoUringSocketUnsafe
- All Implemented Interfaces:
Channel.Unsafe, IoHandle, IoUringIoHandle, AutoCloseable
- Enclosing class:
IoUringSocketChannel
private final class IoUringSocketChannel.IoUringSocketUnsafe
extends AbstractIoUringStreamChannel.IoUringStreamUnsafe
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected ChannelOutboundBuffer.MessageProcessorfilterWriteMultiple(IovArrayReferenceCollector collector) private booleanhandleWriteCompleteZeroCopy(byte op, int res, int flags, long data) protected intSchedule the write of multiple messages in theChannelOutboundBufferand returns the number ofAbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long)calls that are expected because of the scheduled write.protected intSchedule the write of a single message and returns the number ofAbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long)calls that are expected because of the scheduled write.(package private) booleanwriteComplete0(byte op, int res, int flags, long data, int outstanding) Called once a write was completed.Methods inherited from class AbstractIoUringStreamChannel.IoUringStreamUnsafe
handleReadException, readComplete0, scheduleRead0, unregisteredMethods inherited from class AbstractIoUringChannel.AbstractUringUnsafe
cancelComplete0, canCloseNow0, close, close, connect, connectComplete, deregister, flush0, handle, isReadMultishot, recvBufAllocHandle, schedulePollIn, scheduleRead, shutdownInputMethods inherited from class AbstractChannel.AbstractUnsafe
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, writeMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface IoHandle
registered
-
Constructor Details
-
IoUringSocketUnsafe
private IoUringSocketUnsafe()
-
-
Method Details
-
scheduleWriteSingle
Description copied from class:AbstractIoUringChannel.AbstractUringUnsafeSchedule the write of a single message and returns the number ofAbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long)calls that are expected because of the scheduled write.- Overrides:
scheduleWriteSinglein classAbstractIoUringStreamChannel.IoUringStreamUnsafe
-
scheduleWriteMultiple
Description copied from class:AbstractIoUringChannel.AbstractUringUnsafeSchedule the write of multiple messages in theChannelOutboundBufferand returns the number ofAbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long)calls that are expected because of the scheduled write.- Overrides:
scheduleWriteMultiplein classAbstractIoUringStreamChannel.IoUringStreamUnsafe
-
filterWriteMultiple
protected ChannelOutboundBuffer.MessageProcessor filterWriteMultiple(IovArrayReferenceCollector collector) - Overrides:
filterWriteMultiplein classAbstractIoUringStreamChannel.IoUringStreamUnsafe
-
writeComplete0
boolean writeComplete0(byte op, int res, int flags, long data, int outstanding) Description copied from class:AbstractIoUringChannel.AbstractUringUnsafeCalled once a write was completed.- Overrides:
writeComplete0in classAbstractIoUringStreamChannel.IoUringStreamUnsafe- Parameters:
op- the op coderes- the result.flags- the flags.data- the data that was passed when submitting the op.outstanding- the outstanding write completions.
-
handleWriteCompleteZeroCopy
private boolean handleWriteCompleteZeroCopy(byte op, int res, int flags, long data)
-