Package io.netty.incubator.channel.uring
Class AbstractIOUringStreamChannel
java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.incubator.channel.uring.AbstractIOUringChannel
io.netty.incubator.channel.uring.AbstractIOUringStreamChannel
- All Implemented Interfaces:
io.netty.channel.Channel
,io.netty.channel.ChannelOutboundInvoker
,io.netty.channel.socket.DuplexChannel
,io.netty.channel.unix.UnixChannel
,io.netty.util.AttributeMap
,Comparable<io.netty.channel.Channel>
- Direct Known Subclasses:
IOUringSocketChannel
abstract class AbstractIOUringStreamChannel
extends AbstractIOUringChannel
implements io.netty.channel.socket.DuplexChannel
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate final class
Nested classes/interfaces inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
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
FieldsModifier and TypeFieldDescriptionprivate static final io.netty.util.internal.logging.InternalLogger
Fields inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
active, socket
-
Constructor Summary
ConstructorsModifierConstructorDescription(package private)
AbstractIOUringStreamChannel
(io.netty.channel.Channel parent, LinuxSocket socket) protected
AbstractIOUringStreamChannel
(io.netty.channel.Channel parent, LinuxSocket socket, boolean active) (package private)
AbstractIOUringStreamChannel
(io.netty.channel.Channel parent, LinuxSocket fd, SocketAddress remote) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected final void
boolean
boolean
boolean
io.netty.channel.ChannelFuture
shutdown()
io.netty.channel.ChannelFuture
shutdown
(io.netty.channel.ChannelPromise promise) private static void
shutdownDone
(io.netty.channel.ChannelFuture shutdownOutputFuture, io.netty.channel.ChannelFuture shutdownInputFuture, io.netty.channel.ChannelPromise promise) io.netty.channel.ChannelFuture
io.netty.channel.ChannelFuture
shutdownInput
(io.netty.channel.ChannelPromise promise) private void
shutdownInput0
(io.netty.channel.ChannelPromise promise) io.netty.channel.ChannelFuture
io.netty.channel.ChannelFuture
shutdownOutput
(io.netty.channel.ChannelPromise promise) private void
shutdownOutputDone
(io.netty.channel.ChannelFuture shutdownOutputFuture, io.netty.channel.ChannelPromise promise) Methods inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
checkResolvable, clearPollFlag, doBeginRead, doBind, doClose, doDeregister, doDisconnect, doWrite, fd, filterOutboundMessage, ioScheduled, ioUringUnsafe, isActive, isCompatible, isOpen, localAddress0, metadata, newDirectBuffer, newDirectBuffer, remoteAddress0, resetCachedAddresses, schedulePollRdHup, submissionQueue
Methods inherited from class io.netty.channel.AbstractChannel
closeFuture, compareTo, doRegister, 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, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, 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
-
-
Constructor Details
-
AbstractIOUringStreamChannel
AbstractIOUringStreamChannel(io.netty.channel.Channel parent, LinuxSocket socket) -
AbstractIOUringStreamChannel
protected AbstractIOUringStreamChannel(io.netty.channel.Channel parent, LinuxSocket socket, boolean active) -
AbstractIOUringStreamChannel
AbstractIOUringStreamChannel(io.netty.channel.Channel parent, LinuxSocket fd, SocketAddress remote)
-
-
Method Details
-
newUnsafe
- Specified by:
newUnsafe
in classAbstractIOUringChannel
-
shutdown
public io.netty.channel.ChannelFuture shutdown()- Specified by:
shutdown
in interfaceio.netty.channel.socket.DuplexChannel
-
shutdown
public io.netty.channel.ChannelFuture shutdown(io.netty.channel.ChannelPromise promise) - Specified by:
shutdown
in interfaceio.netty.channel.socket.DuplexChannel
-
doShutdownOutput
- Overrides:
doShutdownOutput
in classio.netty.channel.AbstractChannel
- Throws:
Exception
-
shutdownInput0
private void shutdownInput0(io.netty.channel.ChannelPromise promise) -
isOutputShutdown
public boolean isOutputShutdown()- Specified by:
isOutputShutdown
in interfaceio.netty.channel.socket.DuplexChannel
-
isInputShutdown
public boolean isInputShutdown()- Specified by:
isInputShutdown
in interfaceio.netty.channel.socket.DuplexChannel
-
isShutdown
public boolean isShutdown()- Specified by:
isShutdown
in interfaceio.netty.channel.socket.DuplexChannel
-
shutdownOutput
public io.netty.channel.ChannelFuture shutdownOutput()- Specified by:
shutdownOutput
in interfaceio.netty.channel.socket.DuplexChannel
-
shutdownOutput
public io.netty.channel.ChannelFuture shutdownOutput(io.netty.channel.ChannelPromise promise) - Specified by:
shutdownOutput
in interfaceio.netty.channel.socket.DuplexChannel
-
shutdownInput
public io.netty.channel.ChannelFuture shutdownInput()- Specified by:
shutdownInput
in interfaceio.netty.channel.socket.DuplexChannel
-
shutdownInput
public io.netty.channel.ChannelFuture shutdownInput(io.netty.channel.ChannelPromise promise) - Specified by:
shutdownInput
in interfaceio.netty.channel.socket.DuplexChannel
-
shutdownOutputDone
private void shutdownOutputDone(io.netty.channel.ChannelFuture shutdownOutputFuture, io.netty.channel.ChannelPromise promise) -
shutdownDone
private static void shutdownDone(io.netty.channel.ChannelFuture shutdownOutputFuture, io.netty.channel.ChannelFuture shutdownInputFuture, io.netty.channel.ChannelPromise promise) -
doRegister
- Overrides:
doRegister
in classAbstractIOUringChannel
- Throws:
Exception
-