Modifier and Type	Class and Description
private class	AbstractIOUringStreamChannel.IOUringStreamUnsafe

Modifier and Type	Field and Description
private static final InternalLogger	logger Hides io.netty.incubator.channel.uring.AbstractIOUringChannel.logger.

Access	Constructor and Description
pack-priv	AbstractIOUringStreamChannel(Channel parent, LinuxSocket socket)
protected	AbstractIOUringStreamChannel(Channel parent, LinuxSocket socket, boolean active)
pack-priv	AbstractIOUringStreamChannel(Channel parent, LinuxSocket fd, SocketAddress remote)

Modifier and Type	Method and Description
protected void	doRegister() Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.doRegister. Is called after the `Channel` is registered with its `EventLoop` as part of the register process.
protected final void	doShutdownOutput() Overrides io.netty.channel.AbstractChannel.doShutdownOutput. Called when conditions justify shutting down the output portion of the channel.
public boolean	isInputShutdown() Implements io.netty.channel.socket.DuplexChannel.isInputShutdown. Returns `true` if and only if the remote peer shut down its output so that no more data is received from this channel.
public boolean	isOutputShutdown() Implements io.netty.channel.socket.DuplexChannel.isOutputShutdown.
public boolean	isShutdown() Implements io.netty.channel.socket.DuplexChannel.isShutdown. Determine if both the input and output of this channel have been shutdown.
protected AbstractIOUringChannel.AbstractUringUnsafe	newUnsafe() Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.newUnsafe. Create a new `AbstractUnsafe` instance which will be used for the life-time of the `Channel`
public ChannelFuture	shutdown() Implements io.netty.channel.socket.DuplexChannel.shutdown. Will shutdown the input and output sides of this channel.
public ChannelFuture	shutdown(final ChannelPromise will be completed when both shutdown operations complete. promise) Implements io.netty.channel.socket.DuplexChannel.shutdown. Will shutdown the input and output sides of this channel.
private static void	shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
public ChannelFuture	shutdownInput() Implements io.netty.channel.socket.DuplexChannel.shutdownInput.
public ChannelFuture	shutdownInput(final ChannelPromise promise) Implements io.netty.channel.socket.DuplexChannel.shutdownInput. Will shutdown the input and notify `ChannelPromise`.
private void	shutdownInput0(final ChannelPromise promise)
public ChannelFuture	shutdownOutput() Implements io.netty.channel.socket.DuplexChannel.shutdownOutput.
public ChannelFuture	shutdownOutput(final ChannelPromise promise) Implements io.netty.channel.socket.DuplexChannel.shutdownOutput. Will shutdown the output and notify `ChannelPromise`.
private void	shutdownOutputDone(final ChannelFuture shutdownOutputFuture, final ChannelPromise promise)

logger	back to summary
private static final InternalLogger logger Hides io.netty.incubator.channel.uring.AbstractIOUringChannel.logger.

AbstractIOUringStreamChannel	back to summary
pack-priv AbstractIOUringStreamChannel(Channel parent, LinuxSocket socket)

AbstractIOUringStreamChannel	back to summary
protected AbstractIOUringStreamChannel(Channel parent, LinuxSocket socket, boolean active)

AbstractIOUringStreamChannel	back to summary
pack-priv AbstractIOUringStreamChannel(Channel parent, LinuxSocket fd, SocketAddress remote)

Method Detail

doRegister back to summary

doRegister	back to summary
protected void doRegister() throws Exception Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.doRegister. Doc from io.netty.channel.AbstractChannel.doRegister. Is called after the `Channel` is registered with its `EventLoop` as part of the register process. Sub-classes may override this method Annotations @Override

protected void doRegister() throws Exception

Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.doRegister.

Doc from io.netty.channel.AbstractChannel.doRegister.

Is called after the Channel is registered with its EventLoop as part of the register process. Sub-classes may override this method

Annotations

@Override

doShutdownOutput	back to summary
protected final void doShutdownOutput() throws Exception Overrides io.netty.channel.AbstractChannel.doShutdownOutput. Doc from io.netty.channel.AbstractChannel.doShutdownOutput. Called when conditions justify shutting down the output portion of the channel. This may happen if a write operation throws an exception. Annotations @UnstableApi @Override

doShutdownOutput

back to summary

protected final void doShutdownOutput() throws Exception

Overrides io.netty.channel.AbstractChannel.doShutdownOutput.

Doc from io.netty.channel.AbstractChannel.doShutdownOutput.

Called when conditions justify shutting down the output portion of the channel. This may happen if a write operation throws an exception.

Annotations

@UnstableApi
@Override

isInputShutdown back to summary

isInputShutdown	back to summary
public boolean isInputShutdown() Implements io.netty.channel.socket.DuplexChannel.isInputShutdown. Doc from io.netty.channel.socket.DuplexChannel.isInputShutdown. Returns `true` if and only if the remote peer shut down its output so that no more data is received from this channel. Note that the semantic of this method is different from that of `Socket#shutdownInput()` and `Socket#isInputShutdown()`. Annotations @Override

public boolean isInputShutdown()

Implements io.netty.channel.socket.DuplexChannel.isInputShutdown.

Doc from io.netty.channel.socket.DuplexChannel.isInputShutdown.

Returns true if and only if the remote peer shut down its output so that no more data is received from this channel. Note that the semantic of this method is different from that of Socket#shutdownInput() and Socket#isInputShutdown().

Annotations

@Override

isOutputShutdown	back to summary
public boolean isOutputShutdown() Implements io.netty.channel.socket.DuplexChannel.isOutputShutdown. Annotations @Override

isOutputShutdown

back to summary

public boolean isOutputShutdown()

Implements io.netty.channel.socket.DuplexChannel.isOutputShutdown.

Annotations

@Override

isShutdown	back to summary
public boolean isShutdown() Implements io.netty.channel.socket.DuplexChannel.isShutdown. Doc from io.netty.channel.socket.DuplexChannel.isShutdown. Determine if both the input and output of this channel have been shutdown. Annotations @Override

isShutdown

back to summary

public boolean isShutdown()

Implements io.netty.channel.socket.DuplexChannel.isShutdown.

Doc from io.netty.channel.socket.DuplexChannel.isShutdown.

Determine if both the input and output of this channel have been shutdown.

Annotations

@Override

newUnsafe back to summary

newUnsafe	back to summary
protected AbstractIOUringChannel.AbstractUringUnsafe newUnsafe() Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.newUnsafe. Doc from io.netty.channel.AbstractChannel.newUnsafe. Create a new `AbstractUnsafe` instance which will be used for the life-time of the `Channel` Annotations @Override

protected AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.newUnsafe.

Doc from io.netty.channel.AbstractChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel

Annotations

@Override

shutdown	back to summary
public ChannelFuture shutdown() Implements io.netty.channel.socket.DuplexChannel.shutdown. Doc from io.netty.channel.socket.DuplexChannel.shutdown. Will shutdown the input and output sides of this channel. Returns:ChannelFuture will be completed when both shutdown operations complete. Annotations @Override

shutdown

back to summary

public ChannelFuture shutdown()

Implements io.netty.channel.socket.DuplexChannel.shutdown.

Doc from io.netty.channel.socket.DuplexChannel.shutdown.

Will shutdown the input and output sides of this channel.

Returns:ChannelFuture

will be completed when both shutdown operations complete.

Annotations

@Override

shutdown	back to summary
public ChannelFuture shutdown(final ChannelPromise promise) Implements io.netty.channel.socket.DuplexChannel.shutdown. Doc from io.netty.channel.socket.DuplexChannel.shutdown. Will shutdown the input and output sides of this channel. Parameters promise:ChannelPromise will be completed when both shutdown operations complete. Returns:ChannelFuture will be completed when both shutdown operations complete. Annotations @Override

shutdown

back to summary

public ChannelFuture shutdown(final ChannelPromise promise)

Implements io.netty.channel.socket.DuplexChannel.shutdown.

Doc from io.netty.channel.socket.DuplexChannel.shutdown.

Will shutdown the input and output sides of this channel.

Parameters

promise:ChannelPromise: will be completed when both shutdown operations complete.

Returns:ChannelFuture

will be completed when both shutdown operations complete.

Annotations

@Override

shutdownDone	back to summary
private static void shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)

shutdownInput	back to summary
public ChannelFuture shutdownInput() Implements io.netty.channel.socket.DuplexChannel.shutdownInput. Annotations @Override

shutdownInput

back to summary

public ChannelFuture shutdownInput()

Implements io.netty.channel.socket.DuplexChannel.shutdownInput.

Annotations

@Override

shutdownInput back to summary

shutdownInput	back to summary
public ChannelFuture shutdownInput(final ChannelPromise promise) Implements io.netty.channel.socket.DuplexChannel.shutdownInput. Doc from io.netty.channel.socket.DuplexChannel.shutdownInput. Will shutdown the input and notify `ChannelPromise`. Annotations @Override

public ChannelFuture shutdownInput(final ChannelPromise promise)

Implements io.netty.channel.socket.DuplexChannel.shutdownInput.

Doc from io.netty.channel.socket.DuplexChannel.shutdownInput.

Will shutdown the input and notify ChannelPromise.

Annotations

@Override

shutdownInput0	back to summary
private void shutdownInput0(final ChannelPromise promise)

shutdownOutput	back to summary
public ChannelFuture shutdownOutput() Implements io.netty.channel.socket.DuplexChannel.shutdownOutput. Annotations @Override

shutdownOutput

back to summary

public ChannelFuture shutdownOutput()

Implements io.netty.channel.socket.DuplexChannel.shutdownOutput.

Annotations

@Override

shutdownOutput back to summary

shutdownOutput	back to summary
public ChannelFuture shutdownOutput(final ChannelPromise promise) Implements io.netty.channel.socket.DuplexChannel.shutdownOutput. Doc from io.netty.channel.socket.DuplexChannel.shutdownOutput. Will shutdown the output and notify `ChannelPromise`. Annotations @Override

public ChannelFuture shutdownOutput(final ChannelPromise promise)

Implements io.netty.channel.socket.DuplexChannel.shutdownOutput.

Doc from io.netty.channel.socket.DuplexChannel.shutdownOutput.

Will shutdown the output and notify ChannelPromise.

Annotations

@Override

shutdownOutputDone	back to summary
private void shutdownOutputDone(final ChannelFuture shutdownOutputFuture, final ChannelPromise promise)

io.netty.incubator.channel.uring back to summary

private final Class AbstractIOUringStreamChannel.IOUringStreamUnsafe

Class Inheritance

extends AbstractUringUnsafe

java.lang.Object
io.netty.channel.AbstractChannel.AbstractUnsafe
io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
io.netty.incubator.channel.uring.AbstractIOUringStreamChannel.IOUringStreamUnsafe

Field Summary

Modifier and Type	Field and Description
private IovArray	iovArray
private ByteBuf	readBuffer

Constructor Summary

Access	Constructor and Description
private	IOUringStreamUnsafe()

Method Summary

Modifier and Type	Method and Description
private void	handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, IOUringRecvByteAllocatorHandle allocHandle) Deprecated as a consequence of `IOUringRecvByteAllocatorHandle` being deprecated.
protected Executor	prepareToClose() Overrides io.netty.channel.AbstractChannel.AbstractUnsafe.prepareToClose. Prepares to close the `Channel`.
protected void	readComplete0(int res, int data, int outstanding) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0. Called once a read was completed.
protected int	scheduleRead0() Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0. Schedule a read and returns the number of `readComplete(int, int)` calls that are expected because of the scheduled read.
protected int	scheduleWriteMultiple(ChannelOutboundBuffer in) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple. Schedule the write of multiple messages in the `ChannelOutboundBuffer` and returns the number of `writeComplete(int, int)` calls that are expected because of the scheduled write.
protected int	scheduleWriteSingle(Object msg) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle. Schedule the write of a single message and returns the number of `writeComplete(int, int)` calls that are expected because of the scheduled write
pack-priv boolean	writeComplete0(int res, int data, int outstanding) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0. Called once a write was completed.

Inherited from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe:: close connect connectComplete flush0 newIOUringHandle pollIn pollOut pollRdHup processDelayedClose readComplete recvBufAllocHandle schedulePollIn scheduleRead shutdownInput writeComplete

Field Detail

iovArray	back to summary
private IovArray iovArray

readBuffer	back to summary
private ByteBuf readBuffer

Constructor Detail

IOUringStreamUnsafe	back to summary
private IOUringStreamUnsafe()

Method Detail

handleReadException	back to summary
private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, IOUringRecvByteAllocatorHandle allocHandle) Deprecated as a consequence of `IOUringRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

prepareToClose back to summary

prepareToClose	back to summary
protected Executor prepareToClose() Overrides io.netty.channel.AbstractChannel.AbstractUnsafe.prepareToClose. Doc from io.netty.channel.AbstractChannel.AbstractUnsafe.prepareToClose. Prepares to close the `Channel`. If this method returns an `Executor`, the caller must call the `Executor#execute(Runnable)` method with a task that calls `doClose()` on the returned `Executor`. If this method returns `null`, `doClose()` must be called from the caller thread. (i.e. `EventLoop`) Annotations @Override

protected Executor prepareToClose()

Overrides io.netty.channel.AbstractChannel.AbstractUnsafe.prepareToClose.

Doc from io.netty.channel.AbstractChannel.AbstractUnsafe.prepareToClose.

Prepares to close the Channel. If this method returns an Executor, the caller must call the Executor#execute(Runnable) method with a task that calls doClose() on the returned Executor. If this method returns null, doClose() must be called from the caller thread. (i.e. EventLoop)

Annotations

@Override

readComplete0	back to summary
protected void readComplete0(int res, int data, int outstanding) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0. Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0. Called once a read was completed. Annotations @Override

readComplete0

back to summary

protected void readComplete0(int res, int data, int outstanding)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0.

Called once a read was completed.

Annotations

@Override

scheduleRead0 back to summary

scheduleRead0	back to summary
protected int scheduleRead0() Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0. Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0. Schedule a read and returns the number of `readComplete(int, int)` calls that are expected because of the scheduled read. Annotations @Override

protected int scheduleRead0()

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0.

Schedule a read and returns the number of readComplete(int, int) calls that are expected because of the scheduled read.

Annotations

@Override

scheduleWriteMultiple back to summary

scheduleWriteMultiple	back to summary
protected int scheduleWriteMultiple(ChannelOutboundBuffer in) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple. Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple. Schedule the write of multiple messages in the `ChannelOutboundBuffer` and returns the number of `writeComplete(int, int)` calls that are expected because of the scheduled write. Annotations @Override

protected int scheduleWriteMultiple(ChannelOutboundBuffer in)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple.

Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write.

Annotations

@Override

scheduleWriteSingle back to summary

scheduleWriteSingle	back to summary
protected int scheduleWriteSingle(Object msg) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle. Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle. Schedule the write of a single message and returns the number of `writeComplete(int, int)` calls that are expected because of the scheduled write Annotations @Override

protected int scheduleWriteSingle(Object msg)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle.

Schedule the write of a single message and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write

Annotations

@Override

writeComplete0	back to summary
pack-priv boolean writeComplete0(int res, int data, int outstanding) Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0. Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0. Called once a write was completed. Annotations @Override

writeComplete0

back to summary

pack-priv boolean writeComplete0(int res, int data, int outstanding)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0.

Called once a write was completed.

Annotations

@Override

pack-priv abstract Class AbstractIOUringStreamChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class AbstractIOUringStreamChannel.IOUringStreamUnsafe

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail