Package io.netty.incubator.channel.uring

Class AbstractIOUringChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.incubator.channel.uring.AbstractIOUringChannel

All Implemented Interfaces:

io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.channel.unix.UnixChannel, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>

Direct Known Subclasses:

AbstractIOUringServerChannel, AbstractIOUringStreamChannel, IOUringDatagramChannel

abstract class AbstractIOUringChannel
extends io.netty.channel.AbstractChannel
implements io.netty.channel.unix.UnixChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	AbstractIOUringChannel.AbstractUringUnsafe

Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel

io.netty.channel.AbstractChannel.AbstractUnsafe

Nested classes/interfaces inherited from interface io.netty.channel.Channel

io.netty.channel.Channel.Unsafe

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	active
private static final int	CONNECT_SCHEDULED
private io.netty.channel.ChannelPromise	connectPromise	The future of the current connection attempt.
private ScheduledFuture<?>	connectTimeoutFuture
private io.netty.channel.ChannelPromise	delayedClose
private boolean	inputClosedSeenErrorOnRead
private byte	ioState
private SocketAddress	local
private static final io.netty.util.internal.logging.InternalLogger	logger
private static final io.netty.channel.ChannelMetadata	METADATA
private MsgHdrMemoryArray	msgHdrMemoryArray
private short	numOutstandingReads
private short	numOutstandingWrites
private static final int	POLL_IN_SCHEDULED
private static final int	POLL_OUT_SCHEDULED
private static final int	POLL_RDHUP_SCHEDULED
private static final int	READ_SCHEDULED
private SocketAddress	remote
private ByteBuffer	remoteAddressMemory
private SocketAddress	requestedRemoteAddress
(package private) final LinuxSocket	socket
private IOUringSubmissionQueue	submissionQueue
private static final int	WRITE_SCHEDULED

Constructor Summary

Constructors

Constructor	Description
AbstractIOUringChannel(io.netty.channel.Channel parent, LinuxSocket socket)
AbstractIOUringChannel(io.netty.channel.Channel parent, LinuxSocket socket, boolean active)
AbstractIOUringChannel(io.netty.channel.Channel parent, LinuxSocket fd, SocketAddress remote)

Method Summary

Modifier and Type	Method	Description
private void	cancelConnectTimeoutFuture()
protected static void	checkResolvable(InetSocketAddress addr)
void	clearPollFlag(int pollMask)
private void	computeRemote()
protected void	doBeginRead()
protected void	doBind(SocketAddress local)
protected void	doClose()
protected final void	doDeregister()
protected void	doDisconnect()
protected void	doRegister()
protected void	doWrite(io.netty.channel.ChannelOutboundBuffer in)
io.netty.channel.unix.FileDescriptor	fd()
protected Object	filterOutboundMessage(Object msg)
private void	freeMsgHdrArray()
private void	freeRemoteAddressMemory()
(package private) boolean	ioScheduled()
(package private) AbstractIOUringChannel.AbstractUringUnsafe	ioUringUnsafe()
boolean	isActive()
private static boolean	isAllowHalfClosure(io.netty.channel.ChannelConfig config)
protected boolean	isCompatible(io.netty.channel.EventLoop loop)
boolean	isOpen()
protected SocketAddress	localAddress0()
io.netty.channel.ChannelMetadata	metadata()
protected final io.netty.buffer.ByteBuf	newDirectBuffer(io.netty.buffer.ByteBuf buf)
protected final io.netty.buffer.ByteBuf	newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)
private static io.netty.buffer.ByteBuf	newDirectBuffer0(Object holder, io.netty.buffer.ByteBuf buf, io.netty.buffer.ByteBufAllocator alloc, int capacity)
protected abstract AbstractIOUringChannel.AbstractUringUnsafe	newUnsafe()
protected SocketAddress	remoteAddress0()
(package private) final void	resetCachedAddresses()
private void	schedulePollOut()
(package private) final void	schedulePollRdHup()
private int	scheduleWrite(io.netty.channel.ChannelOutboundBuffer in)
private boolean	shouldBreakIoUringInReady(io.netty.channel.ChannelConfig config)
(package private) IOUringSubmissionQueue	submissionQueue()
private void	submitConnect(InetSocketAddress inetSocketAddress)

Methods inherited from class io.netty.channel.AbstractChannel

alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from class io.netty.util.DefaultAttributeMap

attr, hasAttr

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty.util.AttributeMap

attr, hasAttr

Methods inherited from interface io.netty.channel.Channel

alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, config, eventLoop, flush, id, isRegistered, isWritable, localAddress, parent, pipeline, read, remoteAddress, unsafe

Methods inherited from interface io.netty.channel.ChannelOutboundInvoker

bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from interface java.lang.Comparable

compareTo

Field Details

logger

private static final io.netty.util.internal.logging.InternalLogger logger

METADATA

private static final io.netty.channel.ChannelMetadata METADATA

socket

final LinuxSocket socket

active

protected volatile boolean active

POLL_IN_SCHEDULED

private static final int POLL_IN_SCHEDULED

See Also:

• Constant Field Values

POLL_OUT_SCHEDULED

private static final int POLL_OUT_SCHEDULED

See Also:

• Constant Field Values

POLL_RDHUP_SCHEDULED

private static final int POLL_RDHUP_SCHEDULED

See Also:

• Constant Field Values

WRITE_SCHEDULED

private static final int WRITE_SCHEDULED

See Also:

• Constant Field Values

READ_SCHEDULED

private static final int READ_SCHEDULED

See Also:

• Constant Field Values

CONNECT_SCHEDULED

private static final int CONNECT_SCHEDULED

See Also:

• Constant Field Values

ioState

private byte ioState

numOutstandingWrites

private short numOutstandingWrites

numOutstandingReads

private short numOutstandingReads

delayedClose

private io.netty.channel.ChannelPromise delayedClose

inputClosedSeenErrorOnRead

private boolean inputClosedSeenErrorOnRead

connectPromise

private io.netty.channel.ChannelPromise connectPromise

The future of the current connection attempt. If not null, subsequent connection attempts will fail.

connectTimeoutFuture

private ScheduledFuture<?> connectTimeoutFuture

requestedRemoteAddress

private SocketAddress requestedRemoteAddress

remoteAddressMemory

private ByteBuffer remoteAddressMemory

msgHdrMemoryArray

private MsgHdrMemoryArray msgHdrMemoryArray

submissionQueue

private IOUringSubmissionQueue submissionQueue

local

private volatile SocketAddress local

remote

private volatile SocketAddress remote

Constructor Details

AbstractIOUringChannel

AbstractIOUringChannel(io.netty.channel.Channel parent,
 LinuxSocket socket)

AbstractIOUringChannel

AbstractIOUringChannel(io.netty.channel.Channel parent,
 LinuxSocket socket,
 boolean active)

AbstractIOUringChannel

AbstractIOUringChannel(io.netty.channel.Channel parent,
 LinuxSocket fd,
 SocketAddress remote)

Method Details

isOpen

public boolean isOpen()

Specified by:

isOpen in interface io.netty.channel.Channel

isActive

public boolean isActive()

Specified by:

isActive in interface io.netty.channel.Channel

metadata

public io.netty.channel.ChannelMetadata metadata()

Specified by:

metadata in interface io.netty.channel.Channel

fd

public io.netty.channel.unix.FileDescriptor fd()

Specified by:

fd in interface io.netty.channel.unix.UnixChannel

newUnsafe

protected abstract AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()

Specified by:

newUnsafe in class io.netty.channel.AbstractChannel

ioUringUnsafe

AbstractIOUringChannel.AbstractUringUnsafe ioUringUnsafe()

isCompatible

protected boolean isCompatible(io.netty.channel.EventLoop loop)

Specified by:

isCompatible in class io.netty.channel.AbstractChannel

newDirectBuffer

protected final io.netty.buffer.ByteBuf newDirectBuffer(io.netty.buffer.ByteBuf buf)

newDirectBuffer

protected final io.netty.buffer.ByteBuf newDirectBuffer(Object holder,
 io.netty.buffer.ByteBuf buf)

newDirectBuffer0

private static io.netty.buffer.ByteBuf newDirectBuffer0(Object holder,
 io.netty.buffer.ByteBuf buf,
 io.netty.buffer.ByteBufAllocator alloc,
 int capacity)

doDisconnect

protected void doDisconnect()
                     throws Exception

Specified by:

doDisconnect in class io.netty.channel.AbstractChannel

Throws:

Exception

submissionQueue

IOUringSubmissionQueue submissionQueue()

freeRemoteAddressMemory

private void freeRemoteAddressMemory()

freeMsgHdrArray

private void freeMsgHdrArray()

ioScheduled

boolean ioScheduled()

doClose

protected void doClose()
                throws Exception

Specified by:

doClose in class io.netty.channel.AbstractChannel

Throws:

Exception

doBeginRead

protected void doBeginRead()

Specified by:

doBeginRead in class io.netty.channel.AbstractChannel

doWrite

protected void doWrite(io.netty.channel.ChannelOutboundBuffer in)

Specified by:

doWrite in class io.netty.channel.AbstractChannel

scheduleWrite

private int scheduleWrite(io.netty.channel.ChannelOutboundBuffer in)

schedulePollOut

private void schedulePollOut()

schedulePollRdHup

final void schedulePollRdHup()

resetCachedAddresses

final void resetCachedAddresses()

submitConnect

private void submitConnect(InetSocketAddress inetSocketAddress)

filterOutboundMessage

protected Object filterOutboundMessage(Object msg)

Overrides:

filterOutboundMessage in class io.netty.channel.AbstractChannel

doRegister

protected void doRegister()
                   throws Exception

Overrides:

doRegister in class io.netty.channel.AbstractChannel

Throws:

Exception

doDeregister

protected final void doDeregister()

Overrides:

doDeregister in class io.netty.channel.AbstractChannel

doBind

protected void doBind(SocketAddress local)
               throws Exception

Specified by:

doBind in class io.netty.channel.AbstractChannel

Throws:

Exception

checkResolvable

protected static void checkResolvable(InetSocketAddress addr)

localAddress0

protected SocketAddress localAddress0()

Specified by:

localAddress0 in class io.netty.channel.AbstractChannel

remoteAddress0

protected SocketAddress remoteAddress0()

Specified by:

remoteAddress0 in class io.netty.channel.AbstractChannel

isAllowHalfClosure

private static boolean isAllowHalfClosure(io.netty.channel.ChannelConfig config)

cancelConnectTimeoutFuture

private void cancelConnectTimeoutFuture()

computeRemote

private void computeRemote()

shouldBreakIoUringInReady

private boolean shouldBreakIoUringInReady(io.netty.channel.ChannelConfig config)

clearPollFlag

public void clearPollFlag(int pollMask)