Package io.netty.channel.uring

Class IoUringDomainSocketChannel.IoUringDomainSocketUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe

io.netty.channel.uring.AbstractIoUringStreamChannel.IoUringStreamUnsafe

io.netty.channel.uring.IoUringDomainSocketChannel.IoUringDomainSocketUnsafe

All Implemented Interfaces:

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

Enclosing class:

IoUringDomainSocketChannel

private final class IoUringDomainSocketChannel.IoUringDomainSocketUnsafe
extends AbstractIoUringStreamChannel.IoUringStreamUnsafe

Field Summary

Fields

Modifier and Type	Field	Description
private MsgHdrMemory	readMsgHdrMemory
private MsgHdrMemory	writeMsgHdrMemory

Constructor Summary

Constructors

Modifier	Constructor	Description
private	IoUringDomainSocketUnsafe()

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.
private IoUringIoOps	prepSendFdIoOps(FileDescriptor fileDescriptor, MsgHdrMemory msgHdrMemory)
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.
private int	scheduleRecvReadFd()
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.AbstractIoUringStreamChannel.IoUringStreamUnsafe

filterWriteMultiple, handleReadException, scheduleWriteMultiple

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

Field Detail

writeMsgHdrMemory

private MsgHdrMemory writeMsgHdrMemory

readMsgHdrMemory

private MsgHdrMemory readMsgHdrMemory

Constructor Detail

IoUringDomainSocketUnsafe

private IoUringDomainSocketUnsafe()

Method Detail

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

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.

prepSendFdIoOps

private IoUringIoOps prepSendFdIoOps(FileDescriptor fileDescriptor,
                                     MsgHdrMemory msgHdrMemory)

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.

Overrides:

scheduleRead0 in class AbstractIoUringStreamChannel.IoUringStreamUnsafe

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

scheduleRecvReadFd

private int scheduleRecvReadFd()

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.

Overrides:

readComplete0 in class AbstractIoUringStreamChannel.IoUringStreamUnsafe

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 AbstractIoUringStreamChannel.IoUringStreamUnsafe