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

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 of AbstractIOUringChannel.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 the ChannelOutboundBuffer and returns the number of AbstractIOUringChannel.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 of AbstractIOUringChannel.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

Methods inherited from class java.lang.Object

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

Field Detail

readBuffer

private io.netty.buffer.ByteBuf readBuffer

iovArray

private io.netty.channel.unix.IovArray iovArray

Constructor Detail

IOUringStreamUnsafe

private IOUringStreamUnsafe()

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 the ChannelOutboundBuffer and returns the number of AbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int) calls that are expected because of the scheduled write.

Specified by:

scheduleWriteMultiple in class AbstractIOUringChannel.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 of AbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int) calls that are expected because of the scheduled write

Specified by:

scheduleWriteSingle in class AbstractIOUringChannel.AbstractUringUnsafe

scheduleRead0

protected int scheduleRead0()

Description copied from class: AbstractIOUringChannel.AbstractUringUnsafe

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

Specified by:

scheduleRead0 in class AbstractIOUringChannel.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 class AbstractIOUringChannel.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 class AbstractIOUringChannel.AbstractUringUnsafe