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

Modifier	Constructor	Description
private	IoUringSocketUnsafe()

Method Summary

Modifier and Type	Method	Description
protected ChannelOutboundBuffer.MessageProcessor	filterWriteMultiple(IovArrayReferenceCollector collector)
private boolean	handleWriteCompleteZeroCopy(byte op, int res, int flags, long data)
protected int	scheduleWriteMultiple(ChannelOutboundBuffer in)	Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of AbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.
protected int	scheduleWriteSingle(Object msg)	Schedule the write of a single message and returns the number of AbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.
(package private) boolean	writeComplete0(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, unregistered

Methods inherited from class AbstractIoUringChannel.AbstractUringUnsafe

cancelComplete0, canCloseNow0, close, close, connect, connectComplete, deregister, flush0, handle, isReadMultishot, recvBufAllocHandle, schedulePollIn, scheduleRead, shutdownInput

Methods inherited from class AbstractChannel.AbstractUnsafe

annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface IoHandle

registered

Constructor Details

IoUringSocketUnsafe

private IoUringSocketUnsafe()

Method Details

scheduleWriteSingle

protected int scheduleWriteSingle(Object msg)

Description copied from class: AbstractIoUringChannel.AbstractUringUnsafe

Schedule the write of a single message and returns the number of AbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.

Overrides:

scheduleWriteSingle in class AbstractIoUringStreamChannel.IoUringStreamUnsafe

scheduleWriteMultiple

protected int scheduleWriteMultiple(ChannelOutboundBuffer in)

Description copied from class: AbstractIoUringChannel.AbstractUringUnsafe

Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of AbstractIoUringChannel.AbstractUringUnsafe.writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.

Overrides:

scheduleWriteMultiple in class AbstractIoUringStreamChannel.IoUringStreamUnsafe

filterWriteMultiple

protected ChannelOutboundBuffer.MessageProcessor filterWriteMultiple(IovArrayReferenceCollector collector)

Overrides:

filterWriteMultiple in class AbstractIoUringStreamChannel.IoUringStreamUnsafe

writeComplete0

boolean writeComplete0(byte op,
 int res,
 int flags,
 long data,
 int outstanding)

Description copied from class: AbstractIoUringChannel.AbstractUringUnsafe

Called once a write was completed.

Overrides:

writeComplete0 in class AbstractIoUringStreamChannel.IoUringStreamUnsafe

Parameters:

op - the op code

res - 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)