Class IoUringDatagramChannel.IoUringDatagramChannelUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe

io.netty.channel.uring.IoUringDatagramChannel.IoUringDatagramChannelUnsafe

All Implemented Interfaces:

Channel.Unsafe, IoHandle, IoUringIoHandle, AutoCloseable

Enclosing class:

IoUringDatagramChannel

private final class IoUringDatagramChannel.IoUringDatagramChannelUnsafe
extends AbstractIoUringChannel.AbstractUringUnsafe

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	IoUringDatagramChannel.IoUringDatagramChannelUnsafe.WriteProcessor

Field Summary

Fields

Modifier and Type	Field	Description
private ByteBuf	readBuffer
private final IoUringDatagramChannel.IoUringDatagramChannelUnsafe.WriteProcessor	writeProcessor

Constructor Summary

Constructors

Modifier	Constructor	Description
private	IoUringDatagramChannelUnsafe()

Method Summary

Modifier and Type	Method	Description
(package private) void	connectComplete(byte op, int res, int flags, long data)	Called once a connect was completed.
protected void	readComplete0(byte op, int res, int flags, short data, int outstanding)	Called once a read was completed.
private boolean	removeFromOutboundBuffer(ChannelOutboundBuffer outboundBuffer, int res, String errormsg)
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	scheduleRecvmsg(ByteBuf byteBuf, int numDatagram, int datagramSize)
private boolean	scheduleRecvmsg0(long bufferAddress, int bufferLength, boolean first, boolean more)
private boolean	scheduleSendmsg(ByteBuf data, InetSocketAddress remoteAddress, long bufferAddress, int bufferLength, int segmentSize, boolean first)
private boolean	scheduleWrite(Object msg, boolean first)
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.
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 AbstractIoUringChannel.AbstractUringUnsafe

cancelComplete0, canCloseNow0, close, close, connect, 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

Field Details

writeProcessor

private final IoUringDatagramChannel.IoUringDatagramChannelUnsafe.WriteProcessor writeProcessor

readBuffer

private ByteBuf readBuffer

Constructor Details

IoUringDatagramChannelUnsafe

private IoUringDatagramChannelUnsafe()

Method Details

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

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

scheduleRecvmsg

private int scheduleRecvmsg(ByteBuf byteBuf,
 int numDatagram,
 int datagramSize)

scheduleRecvmsg0

private boolean scheduleRecvmsg0(long bufferAddress,
 int bufferLength,
 boolean first,
 boolean more)

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.

removeFromOutboundBuffer

private boolean removeFromOutboundBuffer(ChannelOutboundBuffer outboundBuffer,
 int res,
 String errormsg)

connectComplete

void connectComplete(byte op,
 int res,
 int flags,
 long data)

Description copied from class: AbstractIoUringChannel.AbstractUringUnsafe

Called once a connect was completed.

Overrides:

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

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

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.

Specified by:

scheduleWriteSingle in class AbstractIoUringChannel.AbstractUringUnsafe

scheduleWrite

private boolean scheduleWrite(Object msg,
 boolean first)

scheduleSendmsg

private boolean scheduleSendmsg(ByteBuf data,
 InetSocketAddress remoteAddress,
 long bufferAddress,
 int bufferLength,
 int segmentSize,
 boolean first)

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