Package io.netty.channel.uring

Class AbstractIoUringStreamChannel.IoUringStreamUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe

io.netty.channel.uring.AbstractIoUringStreamChannel.IoUringStreamUnsafe

All Implemented Interfaces:

Channel.Unsafe, IoHandle, IoUringIoHandle, java.lang.AutoCloseable

Direct Known Subclasses:

IoUringDomainSocketChannel.IoUringDomainSocketUnsafe, IoUringSocketChannel.IoUringSocketUnsafe

Enclosing class:

AbstractIoUringStreamChannel

protected class AbstractIoUringStreamChannel.IoUringStreamUnsafe
extends AbstractIoUringChannel.AbstractUringUnsafe

Field Summary

Fields

Modifier and Type	Field	Description
private ByteBuf	fileRegionChunkBuf
private ByteBuf	readBuffer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IoUringStreamUnsafe()

Method Summary

Modifier and Type	Method	Description
private int	calculateRecvFlags(boolean first)
private short	calculateRecvIoPrio(boolean first, boolean socketIsEmpty)
protected ChannelOutboundBuffer.MessageProcessor	filterWriteMultiple(IovArrayReferenceCollector collector)
protected void	handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean allDataRead, IoUringRecvByteAllocatorHandle allocHandle)
private boolean	handleWriteCompleteFileRegion(ChannelOutboundBuffer channelOutboundBuffer, IoUringFileRegion fileRegion, int res, short data)
private boolean	handleWriteCompleteGenericFileRegion(ChannelOutboundBuffer channelOutboundBuffer, FileRegion region, int res)
protected void	readComplete0(byte op, int res, int flags, short data, int outstanding)	Called once a read was completed.
private void	releaseFileRegionChunkBuf()
private void	scheduleNextRead(ChannelPipeline pipeline, IoUringRecvByteAllocatorHandle allocHandle, boolean rearm, boolean completeRead)
protected int	scheduleRead0(boolean first, boolean socketIsEmpty)	Schedule a read and returns the number of AbstractIoUringChannel.AbstractUringUnsafe.readComplete(byte, int, int, short) calls that are expected because of the scheduled read.
private int	scheduleReadProviderBuffer(IoUringBufferRing bufferRing, boolean first, boolean socketIsEmpty)
private int	scheduleWriteFileRegion(int fd, IoRegistration registration, FileRegion region)
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.
void	unregistered()	Called once this IoHandle was unregistered and so will not receive any more events via IoHandle.handle(IoRegistration, IoEvent).
(package private) boolean	writeComplete0(byte op, int res, int flags, long data, int outstanding)	Called once a write was completed.

Methods inherited from class io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe

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

Methods inherited from class io.netty.channel.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 io.netty.channel.IoHandle

registered

Field Detail

readBuffer

private ByteBuf readBuffer

fileRegionChunkBuf

private ByteBuf fileRegionChunkBuf

Constructor Detail

IoUringStreamUnsafe

protected IoUringStreamUnsafe()

Method Detail

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.

Specified by:

scheduleWriteMultiple in class AbstractIoUringChannel.AbstractUringUnsafe

filterWriteMultiple

protected ChannelOutboundBuffer.MessageProcessor filterWriteMultiple(IovArrayReferenceCollector collector)

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.

Specified by:

scheduleWriteSingle in class AbstractIoUringChannel.AbstractUringUnsafe

scheduleWriteFileRegion

private int scheduleWriteFileRegion(int fd,
                                    IoRegistration registration,
                                    FileRegion region)

calculateRecvFlags

private int calculateRecvFlags(boolean first)

calculateRecvIoPrio

private short calculateRecvIoPrio(boolean first,
                                  boolean socketIsEmpty)

scheduleRead0

protected int scheduleRead0(boolean first,
                            boolean socketIsEmpty)

Description copied from class: AbstractIoUringChannel.AbstractUringUnsafe

Schedule a read and returns the number of AbstractIoUringChannel.AbstractUringUnsafe.readComplete(byte, int, int, short) calls that are expected because of the scheduled read.

Specified by:

scheduleRead0 in class AbstractIoUringChannel.AbstractUringUnsafe

Parameters:

first - true if this is the first read of a read loop.

socketIsEmpty - true if the socket is guaranteed to be empty, false otherwise.

Returns:

the number of AbstractIoUringChannel.AbstractUringUnsafe.readComplete(byte, int, int, short) calls expected or -1 if AbstractIoUringChannel.AbstractUringUnsafe.readComplete(byte, int, int, short) is called until the read is cancelled (multi-shot).

scheduleReadProviderBuffer

private int scheduleReadProviderBuffer(IoUringBufferRing bufferRing,
                                       boolean first,
                                       boolean socketIsEmpty)

readComplete0

protected void readComplete0(byte op,
                             int res,
                             int flags,
                             short data,
                             int outstanding)

Description copied from class: AbstractIoUringChannel.AbstractUringUnsafe

Called once a read was completed.

Specified by:

readComplete0 in class AbstractIoUringChannel.AbstractUringUnsafe

scheduleNextRead

private void scheduleNextRead(ChannelPipeline pipeline,
                              IoUringRecvByteAllocatorHandle allocHandle,
                              boolean rearm,
                              boolean completeRead)

handleReadException

protected final void handleReadException(ChannelPipeline pipeline,
                                         ByteBuf byteBuf,
                                         java.lang.Throwable cause,
                                         boolean allDataRead,
                                         IoUringRecvByteAllocatorHandle allocHandle)

handleWriteCompleteFileRegion

private boolean handleWriteCompleteFileRegion(ChannelOutboundBuffer channelOutboundBuffer,
                                              IoUringFileRegion fileRegion,
                                              int res,
                                              short data)

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.

Specified by:

writeComplete0 in class AbstractIoUringChannel.AbstractUringUnsafe

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.

handleWriteCompleteGenericFileRegion

private boolean handleWriteCompleteGenericFileRegion(ChannelOutboundBuffer channelOutboundBuffer,
                                                     FileRegion region,
                                                     int res)

releaseFileRegionChunkBuf

private void releaseFileRegionChunkBuf()

unregistered

public void unregistered()

Description copied from interface: IoHandle

Called once this IoHandle was unregistered and so will not receive any more events via IoHandle.handle(IoRegistration, IoEvent).

Specified by:

unregistered in interface IoHandle

Overrides:

unregistered in class AbstractIoUringChannel.AbstractUringUnsafe