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 ClassesModifier and TypeClassDescription(package private) class
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
FieldsModifier and TypeFieldDescriptionprotected boolean
private static final int
private io.netty.channel.ChannelPromise
The future of the current connection attempt.private ScheduledFuture
<?> private io.netty.channel.ChannelPromise
private boolean
private byte
private SocketAddress
private static final io.netty.util.internal.logging.InternalLogger
private static final io.netty.channel.ChannelMetadata
private MsgHdrMemoryArray
private short
private short
private static final int
private static final int
private static final int
private static final int
private SocketAddress
private ByteBuffer
private SocketAddress
(package private) final LinuxSocket
private IOUringSubmissionQueue
private static final int
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractIOUringChannel
(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 TypeMethodDescriptionprivate void
protected static void
void
clearPollFlag
(int pollMask) private void
protected void
protected void
doBind
(SocketAddress local) protected void
doClose()
protected final void
protected void
protected void
protected void
doWrite
(io.netty.channel.ChannelOutboundBuffer in) io.netty.channel.unix.FileDescriptor
fd()
protected Object
private void
private void
(package private) boolean
(package private) AbstractIOUringChannel.AbstractUringUnsafe
boolean
isActive()
private static boolean
isAllowHalfClosure
(io.netty.channel.ChannelConfig config) protected boolean
isCompatible
(io.netty.channel.EventLoop loop) boolean
isOpen()
protected SocketAddress
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
protected SocketAddress
(package private) final void
private void
(package private) final void
private int
scheduleWrite
(io.netty.channel.ChannelOutboundBuffer in) private boolean
shouldBreakIoUringInReady
(io.netty.channel.ChannelConfig config) (package private) IOUringSubmissionQueue
private void
submitConnect
(InetSocketAddress inetSocketAddress) Methods inherited from class io.netty.channel.AbstractChannel
closeFuture, compareTo, doRegister, doShutdownOutput, equals, eventLoop, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, localAddress, maxMessagesPerWrite, newChannelPipeline, newId, parent, pipeline, remoteAddress, toString, unsafe, validateFileRegion, voidPromise
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, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, config, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, getOption, id, isRegistered, isWritable, localAddress, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, setOption, unsafe, 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
-
active
protected volatile boolean active -
POLL_IN_SCHEDULED
private static final int POLL_IN_SCHEDULED- See Also:
-
POLL_OUT_SCHEDULED
private static final int POLL_OUT_SCHEDULED- See Also:
-
POLL_RDHUP_SCHEDULED
private static final int POLL_RDHUP_SCHEDULED- See Also:
-
WRITE_SCHEDULED
private static final int WRITE_SCHEDULED- See Also:
-
READ_SCHEDULED
private static final int READ_SCHEDULED- See Also:
-
CONNECT_SCHEDULED
private static final int CONNECT_SCHEDULED- See Also:
-
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 connectPromiseThe future of the current connection attempt. If not null, subsequent connection attempts will fail. -
connectTimeoutFuture
-
requestedRemoteAddress
-
remoteAddressMemory
-
msgHdrMemoryArray
-
submissionQueue
-
local
-
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 interfaceio.netty.channel.Channel
-
isActive
public boolean isActive()- Specified by:
isActive
in interfaceio.netty.channel.Channel
-
metadata
public io.netty.channel.ChannelMetadata metadata()- Specified by:
metadata
in interfaceio.netty.channel.Channel
-
fd
public io.netty.channel.unix.FileDescriptor fd()- Specified by:
fd
in interfaceio.netty.channel.unix.UnixChannel
-
newUnsafe
- Specified by:
newUnsafe
in classio.netty.channel.AbstractChannel
-
ioUringUnsafe
AbstractIOUringChannel.AbstractUringUnsafe ioUringUnsafe() -
isCompatible
protected boolean isCompatible(io.netty.channel.EventLoop loop) - Specified by:
isCompatible
in classio.netty.channel.AbstractChannel
-
newDirectBuffer
protected final io.netty.buffer.ByteBuf newDirectBuffer(io.netty.buffer.ByteBuf buf) -
newDirectBuffer
-
newDirectBuffer0
private static io.netty.buffer.ByteBuf newDirectBuffer0(Object holder, io.netty.buffer.ByteBuf buf, io.netty.buffer.ByteBufAllocator alloc, int capacity) -
doDisconnect
- Specified by:
doDisconnect
in classio.netty.channel.AbstractChannel
- Throws:
Exception
-
submissionQueue
IOUringSubmissionQueue submissionQueue() -
freeRemoteAddressMemory
private void freeRemoteAddressMemory() -
freeMsgHdrArray
private void freeMsgHdrArray() -
ioScheduled
boolean ioScheduled() -
doClose
- Specified by:
doClose
in classio.netty.channel.AbstractChannel
- Throws:
Exception
-
doBeginRead
protected void doBeginRead()- Specified by:
doBeginRead
in classio.netty.channel.AbstractChannel
-
doWrite
protected void doWrite(io.netty.channel.ChannelOutboundBuffer in) - Specified by:
doWrite
in classio.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
-
filterOutboundMessage
- Overrides:
filterOutboundMessage
in classio.netty.channel.AbstractChannel
-
doRegister
- Overrides:
doRegister
in classio.netty.channel.AbstractChannel
- Throws:
Exception
-
doDeregister
protected final void doDeregister()- Overrides:
doDeregister
in classio.netty.channel.AbstractChannel
-
doBind
- Specified by:
doBind
in classio.netty.channel.AbstractChannel
- Throws:
Exception
-
checkResolvable
-
localAddress0
- Specified by:
localAddress0
in classio.netty.channel.AbstractChannel
-
remoteAddress0
- Specified by:
remoteAddress0
in classio.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)
-