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
,java.lang.Comparable<io.netty.channel.Channel>
- Direct Known Subclasses:
IOUringSocketChannel
abstract class AbstractIOUringStreamChannel extends AbstractIOUringChannel implements io.netty.channel.socket.DuplexChannel
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
AbstractIOUringStreamChannel.IOUringStreamUnsafe
-
Nested classes/interfaces inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
AbstractIOUringChannel.AbstractUringUnsafe
-
-
Field Summary
Fields Modifier and Type Field Description private static io.netty.util.internal.logging.InternalLogger
logger
-
Fields inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
active, socket
-
-
Constructor Summary
Constructors Modifier Constructor Description (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, java.net.SocketAddress remote)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doRegister()
protected void
doShutdownOutput()
boolean
isInputShutdown()
boolean
isOutputShutdown()
boolean
isShutdown()
protected AbstractIOUringChannel.AbstractUringUnsafe
newUnsafe()
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
shutdownInput()
io.netty.channel.ChannelFuture
shutdownInput(io.netty.channel.ChannelPromise promise)
private void
shutdownInput0(io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture
shutdownOutput()
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
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, 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 java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface io.netty.channel.Channel
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, config, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, 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
-
-
-
-
Constructor Detail
-
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, java.net.SocketAddress remote)
-
-
Method Detail
-
newUnsafe
protected AbstractIOUringChannel.AbstractUringUnsafe 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
@UnstableApi protected final void doShutdownOutput() throws java.lang.Exception
- Overrides:
doShutdownOutput
in classio.netty.channel.AbstractChannel
- Throws:
java.lang.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
protected void doRegister() throws java.lang.Exception
- Overrides:
doRegister
in classAbstractIOUringChannel
- Throws:
java.lang.Exception
-
-