Package io.netty.channel.uring

Class AbstractIoUringServerChannel.UringServerChannelUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe

io.netty.channel.uring.AbstractIoUringServerChannel.UringServerChannelUnsafe

All Implemented Interfaces:

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

Enclosing class:

AbstractIoUringServerChannel

private final class AbstractIoUringServerChannel.UringServerChannelUnsafe
extends AbstractIoUringChannel.AbstractUringUnsafe

Constructor Summary

Constructors

Modifier	Constructor	Description
private	UringServerChannelUnsafe()

Method Summary

Modifier and Type	Method	Description
void	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
protected void	readComplete0(byte op, int res, int flags, short data, int outstanding)	Called once a read was completed.
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.
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, 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

Constructor Detail

UringServerChannelUnsafe

private UringServerChannelUnsafe()

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

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

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.

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

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

connect

public void connect(java.net.SocketAddress remoteAddress,
                    java.net.SocketAddress localAddress,
                    ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Connect the Channel of the given ChannelFuture with the given remote SocketAddress. If a specific local SocketAddress should be used it need to be given as argument. Otherwise just pass null to it. The ChannelPromise will get notified once the connect operation was complete.

Specified by:

connect in interface Channel.Unsafe

Overrides:

connect in class AbstractIoUringChannel.AbstractUringUnsafe

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