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, java.lang.AutoCloseable

Enclosing class:

IoUringSocketChannel

private final class IoUringSocketChannel.IoUringSocketUnsafe
extends AbstractIoUringStreamChannel.IoUringStreamUnsafe

Field Summary

Fields

Modifier and Type	Field	Description
private PendingZeroCopyWrites	pendingZeroCopyWrites	Holds buffers that we can't release yet as the kernel still holds a reference to these.

Fields inherited from class AbstractIoUringChannel.AbstractUringUnsafe

currentWrite, originalOutboundBuffer, retainedWriteBuffers

Constructor Summary

Constructors

Modifier	Constructor	Description
private	IoUringSocketUnsafe()

Method Summary

Modifier and Type	Method	Description
protected ChannelOutboundBuffer.MessageProcessor	filterWriteMultiple(IovArray iovArray)
private boolean	handleWriteCompleteZeroCopy(byte op, int res, int flags, long data)
private long	nextZeroCopyUserData()
(package private) java.util.List<ReferenceCounted>	retainWriteBuffers(ChannelOutboundBuffer buffer)
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(java.lang.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.
private void	takeSendZCBuffers(long data)
(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, prepareToDiscardOutboundMessages, recvBufAllocHandle, releaseWriteBuffers, schedulePollIn, scheduleRead, shutdownInput, submitWrite

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 java.lang.Object

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

Methods inherited from interface IoHandle

registered

Field Details

pendingZeroCopyWrites

private PendingZeroCopyWrites pendingZeroCopyWrites

Holds buffers that we can't release yet as the kernel still holds a reference to these.

Constructor Details

IoUringSocketUnsafe

private IoUringSocketUnsafe()

Method Details

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 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(IovArray iovArray)

Overrides:

filterWriteMultiple in class AbstractIoUringStreamChannel.IoUringStreamUnsafe

nextZeroCopyUserData

private long nextZeroCopyUserData()

retainWriteBuffers

java.util.List<ReferenceCounted> retainWriteBuffers(ChannelOutboundBuffer buffer)

Overrides:

retainWriteBuffers 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.

takeSendZCBuffers

private void takeSendZCBuffers(long data)

handleWriteCompleteZeroCopy

private boolean handleWriteCompleteZeroCopy(byte op,
 int res,
 int flags,
 long data)