Top Inners Fields Constructors Methods
io.netty.incubator.channel.uring

pack-priv abstract Class AbstractIOUringChannel

extends AbstractChannel
implements UnixChannel
Class Inheritance
All Implemented Interfaces
io.netty.channel.unix.UnixChannel, io.netty.channel.Channel, java.lang.Comparable, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap
Known Direct Subclasses
io.netty.incubator.channel.uring.AbstractIOUringServerChannel, io.netty.incubator.channel.uring.AbstractIOUringStreamChannel, io.netty.incubator.channel.uring.IOUringDatagramChannel
Imports
io.netty.buffer.ByteBuf, .ByteBufAllocator, .ByteBufHolder, .ByteBufUtil, .Unpooled, io.netty.channel.AbstractChannel, .Channel, .ChannelConfig, .ChannelFuture, .ChannelFutureListener, .ChannelMetadata, .ChannelOption, .ChannelOutboundBuffer, .ChannelPromise, .ChannelPromiseNotifier, .ConnectTimeoutException, .EventLoop, .RecvByteBufAllocator, io.netty.channel.socket.ChannelInputShutdownEvent, .ChannelInputShutdownReadComplete, .SocketChannelConfig, io.netty.channel.unix.Buffer, .Errors, .FileDescriptor, .UnixChannel, .UnixChannelUtil, io.netty.util.ReferenceCountUtil, io.netty.util.internal.logging.InternalLogger, .InternalLoggerFactory, java.io.IOException, java.net.InetSocketAddress, .SocketAddress, java.nio.ByteBuffer, java.nio.channels.AlreadyConnectedException, .ClosedChannelException, .ConnectionPendingException, .NotYetConnectedException, .UnresolvedAddressException, java.util.concurrent.ScheduledFuture, .TimeUnit

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv abstract class
AbstractIOUringChannel.AbstractUringUnsafe

Field Summary

Modifier and TypeField and Description
protected volatile boolean
active

private static final int
CONNECT_SCHEDULED

private ChannelPromise
connectPromise

The future of the current connection attempt.

private ScheduledFuture<?>
connectTimeoutFuture

private ChannelPromise
delayedClose

private boolean
inputClosedSeenErrorOnRead

private byte
ioState

private volatile SocketAddress
local

private static final InternalLogger
logger

Hides io.netty.channel.AbstractChannel.logger.

private static final 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 volatile SocketAddress
remote

private ByteBuffer
remoteAddressMemory

private SocketAddress
requestedRemoteAddress

pack-priv final LinuxSocket
socket

private IOUringSubmissionQueue
submissionQueue

private static final int
WRITE_SCHEDULED

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractIOUringChannel(final Channel parent, LinuxSocket socket)

pack-priv
AbstractIOUringChannel(final Channel parent, LinuxSocket socket, boolean active)

pack-priv
AbstractIOUringChannel(Channel parent, LinuxSocket fd, SocketAddress remote)

Method Summary

Modifier and TypeMethod and Description
private void
cancelConnectTimeoutFuture()

protected static void
checkResolvable(InetSocketAddress addr)

public void
clearPollFlag(int pollMask)

private void
computeRemote()

protected void
doBeginRead()

Implements abstract io.netty.channel.AbstractChannel.doBeginRead.

Schedule a read operation.
protected void
doBind(final SocketAddress local)

Implements abstract io.netty.channel.AbstractChannel.doBind.

Bind the Channel to the SocketAddress
protected void
doClose()

Implements abstract io.netty.channel.AbstractChannel.doClose.

Close the Channel
protected final void
doDeregister()

Overrides io.netty.channel.AbstractChannel.doDeregister.

Deregister the Channel from its EventLoop.
protected void
doDisconnect()

Implements abstract io.netty.channel.AbstractChannel.doDisconnect.

Disconnect this Channel from its remote peer
protected void
doRegister()

Overrides io.netty.channel.AbstractChannel.doRegister.

Is called after the Channel is registered with its EventLoop as part of the register process.
protected void
doWrite(ChannelOutboundBuffer in)

Implements abstract io.netty.channel.AbstractChannel.doWrite.

Flush the content of the given buffer to the remote peer.
public FileDescriptor
fd()

Implements io.netty.channel.unix.UnixChannel.fd.

Returns the FileDescriptor that is used by this Channel.
protected Object
filterOutboundMessage(Object msg)

Overrides io.netty.channel.AbstractChannel.filterOutboundMessage.

Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another.
private void
freeMsgHdrArray()

private void
freeRemoteAddressMemory()

pack-priv boolean
ioScheduled()

pack-priv AbstractIOUringChannel.AbstractUringUnsafe
ioUringUnsafe()

public boolean
isActive()

Implements io.netty.channel.Channel.isActive.

Return true if the Channel is active and so connected.
private static boolean
isAllowHalfClosure(ChannelConfig config)

protected boolean
isCompatible(final EventLoop loop)

Implements abstract io.netty.channel.AbstractChannel.isCompatible.

Return true if the given EventLoop is compatible with this instance.
public boolean
isOpen()

Implements io.netty.channel.Channel.isOpen.

Returns true if the Channel is open and may get active later
protected SocketAddress
localAddress0()

Implements abstract io.netty.channel.AbstractChannel.localAddress0.

Returns the SocketAddress which is bound locally.
public ChannelMetadata
metadata()

Implements io.netty.channel.Channel.metadata.

Return the ChannelMetadata of the Channel which describe the nature of the Channel.
protected final ByteBuf
newDirectBuffer(ByteBuf buf)

protected final ByteBuf
newDirectBuffer(Object holder, ByteBuf buf)

private static ByteBuf
newDirectBuffer0(Object holder, ByteBuf buf, ByteBufAllocator alloc, int capacity)

protected abstract AbstractIOUringChannel.AbstractUringUnsafe
newUnsafe()

Implements abstract io.netty.channel.AbstractChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel
protected SocketAddress
remoteAddress0()

Implements abstract io.netty.channel.AbstractChannel.remoteAddress0.

Return the SocketAddress which the Channel is connected to.
pack-priv final void
resetCachedAddresses()

private void
schedulePollOut()

pack-priv final void
schedulePollRdHup()

private int
scheduleWrite(ChannelOutboundBuffer in)

private boolean
shouldBreakIoUringInReady(ChannelConfig config)

pack-priv IOUringSubmissionQueue
submissionQueue()

private void
submitConnect(InetSocketAddress inetSocketAddress)

Inherited from io.netty.channel.AbstractChannel:
allocbindbindbytesBeforeUnwritablebytesBeforeWritablecloseclosecloseFuturecompareToconnectconnectconnectconnectderegisterderegisterdisconnectdisconnectdoShutdownOutputequalseventLoopflushhashCodeidinvalidateLocalAddressinvalidateRemoteAddressisRegisteredisWritablelocalAddressmaxMessagesPerWritenewChannelPipelinenewFailedFuturenewIdnewProgressivePromisenewPromisenewSucceededFutureparentpipelinereadremoteAddresstoStringunsafevalidateFileRegionvoidPromisewritewritewriteAndFlushwriteAndFlush