Class AbstractIoUringChannel.AbstractUringUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe

All Implemented Interfaces:

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

Direct Known Subclasses:

AbstractIoUringServerChannel.UringServerChannelUnsafe, AbstractIoUringStreamChannel.IoUringStreamUnsafe, IoUringDatagramChannel.IoUringDatagramChannelUnsafe

Enclosing class:

AbstractIoUringChannel

protected abstract class AbstractIoUringChannel.AbstractUringUnsafe
extends AbstractChannel.AbstractUnsafe
implements IoUringIoHandle

Field Summary

Fields

Modifier and Type	Field	Description
private IoUringRecvByteAllocatorHandle	allocHandle
private boolean	closed
(package private) final WriteOpsSnapshot	currentWrite
private ChannelPromise	deregisterPromise
(package private) final ChannelOutboundBuffer	originalOutboundBuffer
(package private) java.util.List<ReferenceCounted>	retainedWriteBuffers
private boolean	socketIsEmpty

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractUringUnsafe()

Method Summary

Modifier and Type	Method	Description
(package private) void	cancelComplete0(byte op, int res, int flags, short data)	Called once a cancel was completed.
private boolean	cancelOps(boolean cancelConnect)
private boolean	canCloseNow()
protected boolean	canCloseNow0()
final void	close()	Called once the IoHandle should be closed.
protected void	close(ChannelPromise promise, java.lang.Throwable cause, java.nio.channels.ClosedChannelException closeCause)
private void	closeNow()
private void	completeFastOpenWrite(byte op, int res, int flags, short data)
void	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
(package private) void	connectComplete(byte op, int res, int flags, long data)	Called once a connect was completed.
final void	deregister(ChannelPromise promise)	Deregister the Channel of the ChannelPromise from EventLoop and notify the ChannelPromise once the operation was complete.
private void	fillTFOInitData(MsgHdrMemory hdr, java.net.InetSocketAddress inetSocketAddress, ByteBuf initialData)
private void	fireEventAndClose(java.lang.Object evt)
protected final void	flush0()
private void	fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void	fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
final void	handle(IoRegistration registration, IoEvent ioEvent)	Be called once there is something to handle.
private void	handleDelayedClosed()
protected final boolean	isReadMultishot()
private void	pollAddComplete(int res, int flags, short data)
private void	pollIn(int res, int flags, short data)	Called once POLLIN event is ready to be processed
private void	pollOut(int res)	Called once POLLOUT event is ready to be processed
private void	pollRdHup(int res)	Called once POLLRDHUP event is ready to be processed
(package private) final void	prepareToDiscardOutboundMessages(ChannelOutboundBuffer buffer)
private void	readComplete(byte op, int res, int flags, short data)
protected abstract void	readComplete0(byte op, int res, int flags, short data, int outstandingCompletes)	Called once a read was completed.
final IoUringRecvByteAllocatorHandle	recvBufAllocHandle()	Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.
(package private) void	releaseWriteBuffers(java.util.List<ReferenceCounted> buffers, long data)
(package private) java.util.List<ReferenceCounted>	retainWriteBuffers(ChannelOutboundBuffer buffer)
private void	scheduleFirstRead()
private void	scheduleFirstReadIfNeeded()
(package private) final void	schedulePollIn()
protected final void	scheduleRead(boolean first)
protected abstract int	scheduleRead0(boolean first, boolean socketIsEmpty)	Schedule a read and returns the number of readComplete(byte, int, int, short) calls that are expected because of the scheduled read.
protected abstract int	scheduleWriteMultiple(ChannelOutboundBuffer in)	Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.
protected abstract int	scheduleWriteSingle(java.lang.Object msg)	Schedule the write of a single message and returns the number of writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.
(package private) final void	shutdownInput(boolean allDataRead)
(package private) final long	submitWrite(IoUringIoOps ops)
void	unregistered()	Called once this IoHandle was unregistered and so will not receive any more events via IoHandle.handle(IoRegistration, IoEvent).
private void	writeComplete(byte op, int res, int flags, long data)	Called once a write was completed.
(package private) abstract boolean	writeComplete0(byte op, int res, int flags, long data, int outstanding)	Called once a write was completed.
private boolean	writeCompleteAndReleaseBuffers(byte op, int res, int flags, long data)

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 java.lang.Object

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

Methods inherited from interface IoHandle

registered

Field Details

allocHandle

private IoUringRecvByteAllocatorHandle allocHandle

closed

private boolean closed

socketIsEmpty

private boolean socketIsEmpty

deregisterPromise

private ChannelPromise deregisterPromise

currentWrite

final WriteOpsSnapshot currentWrite

originalOutboundBuffer

final ChannelOutboundBuffer originalOutboundBuffer

retainedWriteBuffers

java.util.List<ReferenceCounted> retainedWriteBuffers

Constructor Details

AbstractUringUnsafe

protected AbstractUringUnsafe()

Method Details

submitWrite

final long submitWrite(IoUringIoOps ops)

prepareToDiscardOutboundMessages

final void prepareToDiscardOutboundMessages(ChannelOutboundBuffer buffer)

retainWriteBuffers

java.util.List<ReferenceCounted> retainWriteBuffers(ChannelOutboundBuffer buffer)

releaseWriteBuffers

void releaseWriteBuffers(java.util.List<ReferenceCounted> buffers,
 long data)

scheduleWriteMultiple

protected abstract int scheduleWriteMultiple(ChannelOutboundBuffer in)

Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.

scheduleWriteSingle

protected abstract int scheduleWriteSingle(java.lang.Object msg)

Schedule the write of a single message and returns the number of writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.

handle

public final void handle(IoRegistration registration,
 IoEvent ioEvent)

Description copied from interface: IoHandle

Be called once there is something to handle.

Specified by:

handle in interface IoHandle

Parameters:

registration - the IoRegistration for this IoHandle.

ioEvent - the IoEvent that must be handled. The IoEvent is only valid while this method is executed and so must not escape it.

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

handleDelayedClosed

private void handleDelayedClosed()

pollAddComplete

private void pollAddComplete(int res,
 int flags,
 short data)

close

public final void close()
                 throws java.lang.Exception

Description copied from interface: IoHandle

Called once the IoHandle should be closed. Even once this method is called this handle might still receive events via IoHandle.handle(IoRegistration, IoEvent) (if it was previous be registered and so its IoHandle.registered() method was called) until the IoHandle.unregistered() method is called.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface IoHandle

Throws:

java.lang.Exception

close

protected void close(ChannelPromise promise,
 java.lang.Throwable cause,
 java.nio.channels.ClosedChannelException closeCause)

Overrides:

close in class AbstractChannel.AbstractUnsafe

cancelOps

private boolean cancelOps(boolean cancelConnect)

canCloseNow

private boolean canCloseNow()

canCloseNow0

protected boolean canCloseNow0()

closeNow

private void closeNow()

flush0

protected final void flush0()

Overrides:

flush0 in class AbstractChannel.AbstractUnsafe

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
 java.lang.Throwable cause)

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
 boolean wasActive)

recvBufAllocHandle

public final IoUringRecvByteAllocatorHandle recvBufAllocHandle()

Description copied from interface: Channel.Unsafe

Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.

Specified by:

recvBufAllocHandle in interface Channel.Unsafe

Overrides:

recvBufAllocHandle in class AbstractChannel.AbstractUnsafe

shutdownInput

final void shutdownInput(boolean allDataRead)

fireEventAndClose

private void fireEventAndClose(java.lang.Object evt)

schedulePollIn

final void schedulePollIn()

isReadMultishot

protected final boolean isReadMultishot()

readComplete

private void readComplete(byte op,
 int res,
 int flags,
 short data)

readComplete0

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

Called once a read was completed.

pollRdHup

private void pollRdHup(int res)

Called once POLLRDHUP event is ready to be processed

pollIn

private void pollIn(int res,
 int flags,
 short data)

Called once POLLIN event is ready to be processed

scheduleFirstReadIfNeeded

private void scheduleFirstReadIfNeeded()

scheduleFirstRead

private void scheduleFirstRead()

scheduleRead

protected final void scheduleRead(boolean first)

scheduleRead0

protected abstract int scheduleRead0(boolean first,
 boolean socketIsEmpty)

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

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 readComplete(byte, int, int, short) calls expected or -1 if readComplete(byte, int, int, short) is called until the read is cancelled (multi-shot).

pollOut

private void pollOut(int res)

Called once POLLOUT event is ready to be processed

Parameters:

res - the result.

writeComplete

private void writeComplete(byte op,
 int res,
 int flags,
 long data)

Called once a write was completed.

Parameters:

op - the op code.

res - the result.

flags - the flags.

data - the data that was passed when submitting the op.

writeCompleteAndReleaseBuffers

private boolean writeCompleteAndReleaseBuffers(byte op,
 int res,
 int flags,
 long data)

completeFastOpenWrite

private void completeFastOpenWrite(byte op,
 int res,
 int flags,
 short data)

writeComplete0

abstract boolean writeComplete0(byte op,
 int res,
 int flags,
 long data,
 int outstanding)

Called once a write was completed.

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.

cancelComplete0

void cancelComplete0(byte op,
 int res,
 int flags,
 short data)

Called once a cancel was completed.

Parameters:

op - the op code

res - the result.

flags - the flags.

data - the data that was passed when submitting the op.

connectComplete

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

Called once a connect was completed.

Parameters:

op - the op code.

res - the result.

flags - the flags.

data - the data that was passed when submitting the op.

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

fillTFOInitData

private void fillTFOInitData(MsgHdrMemory hdr,
 java.net.InetSocketAddress inetSocketAddress,
 ByteBuf initialData)
                      throws java.lang.Exception

Throws:

java.lang.Exception

deregister

public final void deregister(ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Deregister the Channel of the ChannelPromise from EventLoop and notify the ChannelPromise once the operation was complete.

Specified by:

deregister in interface Channel.Unsafe

Overrides:

deregister in class AbstractChannel.AbstractUnsafe