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 Classes

Modifier and Type	Class	Description
private final class	AbstractIOUringStreamChannel.IOUringStreamUnsafe

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

Fields

Modifier and Type	Field	Description
private static final 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, SocketAddress remote)

Method Summary

Modifier and Type	Method	Description
protected void	doRegister()
protected final 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 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, 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

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

protected AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()

Specified by:

newUnsafe in class AbstractIOUringChannel

shutdown

public io.netty.channel.ChannelFuture shutdown()

Specified by:

shutdown in interface io.netty.channel.socket.DuplexChannel

shutdown

public io.netty.channel.ChannelFuture shutdown(io.netty.channel.ChannelPromise promise)

Specified by:

shutdown in interface io.netty.channel.socket.DuplexChannel

doShutdownOutput

@UnstableApi
protected final void doShutdownOutput()
                               throws Exception

Overrides:

doShutdownOutput in class io.netty.channel.AbstractChannel

Throws:

Exception

shutdownInput0

private void shutdownInput0(io.netty.channel.ChannelPromise promise)

isOutputShutdown

public boolean isOutputShutdown()

Specified by:

isOutputShutdown in interface io.netty.channel.socket.DuplexChannel

isInputShutdown

public boolean isInputShutdown()

Specified by:

isInputShutdown in interface io.netty.channel.socket.DuplexChannel

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface io.netty.channel.socket.DuplexChannel

shutdownOutput

public io.netty.channel.ChannelFuture shutdownOutput()

Specified by:

shutdownOutput in interface io.netty.channel.socket.DuplexChannel

shutdownOutput

public io.netty.channel.ChannelFuture shutdownOutput(io.netty.channel.ChannelPromise promise)

Specified by:

shutdownOutput in interface io.netty.channel.socket.DuplexChannel

shutdownInput

public io.netty.channel.ChannelFuture shutdownInput()

Specified by:

shutdownInput in interface io.netty.channel.socket.DuplexChannel

shutdownInput

public io.netty.channel.ChannelFuture shutdownInput(io.netty.channel.ChannelPromise promise)

Specified by:

shutdownInput in interface io.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 Exception

Overrides:

doRegister in class AbstractIOUringChannel

Throws:

Exception