Netty/Incubator/Transport/Classes/io_uring 0.0.25.Final · io.netty.incubator.channel.uring.IOUringEventLoop

Field Summary

Modifier and Type	Field and Description
private static final long	AWAKE
private final IOUringCompletionQueueCallback	callback
private final IntObjectMap<AbstractIOUringChannel>	channels
private final FileDescriptor	eventfd
private final long	eventfdReadBuf
private final byte[]	inet4AddressArray
private final byte[]	inet6AddressArray
private static final InternalLogger	logger Hides io.netty.util.concurrent.SingleThreadEventExecutor.logger.
private final AtomicLong	nextWakeupNanos
private static final long	NONE
private boolean	pendingWakeup
private long	prevDeadlineNanos
private short	prevTimeoutGeneration This is a "generation" counter that is passed to addTimeout.
private final RingBuffer	ringBuffer
private final Runnable	submitIOTask

Inherited from io.netty.channel.SingleThreadEventLoop:: DEFAULT_MAX_PENDING_TASKS

Constructor Summary

Access	Constructor and Description
pack-priv	IOUringEventLoop(IOUringEventLoopGroup parent, Executor executor, int ringSize, int iosqeAsyncThreshold, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory queueFactory)

Method Summary

Modifier and Type	Method and Description
pack-priv void	add(AbstractIOUringChannel ch)
private void	addEventFdRead(IOUringSubmissionQueue submissionQueue)
protected void	cleanup() Overrides io.netty.util.concurrent.SingleThreadEventExecutor.cleanup. Do nothing, sub-classes may override
private void	closeAll()
pack-priv RingBuffer	getRingBuffer()
private void	handle(int fd, int res, int flags, byte op, short data)
private void	handleConnect(AbstractIOUringChannel channel, int res)
pack-priv void	handleLoopException(Throwable t) Visible only for testing!
private void	handlePollAdd(AbstractIOUringChannel channel, int res, int pollMask)
private void	handleRead(AbstractIOUringChannel channel, int res, int data)
private void	handleWrite(AbstractIOUringChannel channel, int res, int data)
pack-priv byte[]	inet4AddressArray() `byte[]` that can be used as temporary storage to encode the ipv4 address
pack-priv byte[]	inet6AddressArray() `byte[]` that can be used as temporary storage to encode the ipv6 address
private static Queue<Runnable>	newTaskQueue(EventLoopTaskQueueFactory queueFactory)
protected Queue<Runnable>	newTaskQueue(int maxPendingTasks) Overrides io.netty.util.concurrent.SingleThreadEventExecutor.newTaskQueue. Create a new `Queue` which will holds the tasks to execute.
private static Queue<Runnable>	newTaskQueue0(int maxPendingTasks)
pack-priv void	remove(AbstractIOUringChannel ch)
protected void	run() Implements abstract io.netty.util.concurrent.SingleThreadEventExecutor.run. Run the tasks in the `taskQueue`
public void	submitIO() Submit the IO so the kernel can process it.
protected void	wakeup(boolean inEventLoop) Overrides io.netty.util.concurrent.SingleThreadEventExecutor.wakeup.

Inherited from io.netty.channel.SingleThreadEventLoop:: afterRunningAllTasks executeAfterEventLoopIteration hasTasks next parent pendingTasks register register register registeredChannels registeredChannelsIterator

Field Detail

AWAKE	back to summary
private static final long AWAKE

callback	back to summary
private final IOUringCompletionQueueCallback callback

channels	back to summary
private final IntObjectMap<AbstractIOUringChannel> channels

eventfd	back to summary
private final FileDescriptor eventfd

eventfdReadBuf	back to summary
private final long eventfdReadBuf

inet4AddressArray	back to summary
private final byte[] inet4AddressArray

inet6AddressArray	back to summary
private final byte[] inet6AddressArray

logger	back to summary
private static final InternalLogger logger Hides io.netty.util.concurrent.SingleThreadEventExecutor.logger.

nextWakeupNanos	back to summary
private final AtomicLong nextWakeupNanos

NONE	back to summary
private static final long NONE

pendingWakeup	back to summary
private boolean pendingWakeup

prevDeadlineNanos	back to summary
private long prevDeadlineNanos

prevTimeoutGeneration	back to summary
private short prevTimeoutGeneration This is a "generation" counter that is passed to addTimeout. It ensures that the expiry of a previous timeout doesn't make us think the current timeout has expired, which could lead to wrongly not removing the current timeout when it's adjusted again.

ringBuffer	back to summary
private final RingBuffer ringBuffer

submitIOTask	back to summary
private final Runnable submitIOTask

Constructor Detail

IOUringEventLoop	back to summary
pack-priv IOUringEventLoop(IOUringEventLoopGroup parent, Executor executor, int ringSize, int iosqeAsyncThreshold, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory queueFactory)

Method Detail

add	back to summary
pack-priv void add(AbstractIOUringChannel ch)

addEventFdRead	back to summary
private void addEventFdRead(IOUringSubmissionQueue submissionQueue)

cleanup	back to summary
protected void cleanup() Overrides io.netty.util.concurrent.SingleThreadEventExecutor.cleanup. Doc from io.netty.util.concurrent.SingleThreadEventExecutor.cleanup. Do nothing, sub-classes may override Annotations @Override

cleanup

back to summary

protected void cleanup()

Overrides io.netty.util.concurrent.SingleThreadEventExecutor.cleanup.

Doc from io.netty.util.concurrent.SingleThreadEventExecutor.cleanup.

Do nothing, sub-classes may override

Annotations

@Override

closeAll	back to summary
private void closeAll()

getRingBuffer	back to summary
pack-priv RingBuffer getRingBuffer()

handle	back to summary
private void handle(int fd, int res, int flags, byte op, short data)

handleConnect	back to summary
private void handleConnect(AbstractIOUringChannel channel, int res)

handleLoopException	back to summary
pack-priv void handleLoopException(Throwable t) Visible only for testing!

handlePollAdd	back to summary
private void handlePollAdd(AbstractIOUringChannel channel, int res, int pollMask)

handleRead	back to summary
private void handleRead(AbstractIOUringChannel channel, int res, int data)

handleWrite	back to summary
private void handleWrite(AbstractIOUringChannel channel, int res, int data)

inet4AddressArray	back to summary
pack-priv byte[] inet4AddressArray() `byte[]` that can be used as temporary storage to encode the ipv4 address

inet6AddressArray	back to summary
pack-priv byte[] inet6AddressArray() `byte[]` that can be used as temporary storage to encode the ipv6 address

newTaskQueue	back to summary
private static Queue<Runnable> newTaskQueue(EventLoopTaskQueueFactory queueFactory)

newTaskQueue back to summary

newTaskQueue	back to summary
protected Queue<Runnable> newTaskQueue(int maxPendingTasks) Overrides io.netty.util.concurrent.SingleThreadEventExecutor.newTaskQueue. Doc from io.netty.util.concurrent.SingleThreadEventExecutor.newTaskQueue. Create a new `Queue` which will holds the tasks to execute. This default implementation will return a `LinkedBlockingQueue` but if your sub-class of `SingleThreadEventExecutor` will not do any blocking calls on the this `Queue` it may make sense to `@Override` this and return some more performant implementation that does not support blocking operations at all. Annotations @Override

protected Queue<Runnable> newTaskQueue(int maxPendingTasks)

Overrides io.netty.util.concurrent.SingleThreadEventExecutor.newTaskQueue.

Doc from io.netty.util.concurrent.SingleThreadEventExecutor.newTaskQueue.

Create a new Queue which will holds the tasks to execute. This default implementation will return a LinkedBlockingQueue but if your sub-class of SingleThreadEventExecutor will not do any blocking calls on the this Queue it may make sense to @Override this and return some more performant implementation that does not support blocking operations at all.

Annotations

@Override

newTaskQueue0	back to summary
private static Queue<Runnable> newTaskQueue0(int maxPendingTasks)

remove	back to summary
pack-priv void remove(AbstractIOUringChannel ch)

run back to summary

run	back to summary
protected void run() Implements abstract io.netty.util.concurrent.SingleThreadEventExecutor.run. Doc from io.netty.util.concurrent.SingleThreadEventExecutor.run. Run the tasks in the `taskQueue` Annotations @Override

protected void run()

Implements abstract io.netty.util.concurrent.SingleThreadEventExecutor.run.

Doc from io.netty.util.concurrent.SingleThreadEventExecutor.run.

Run the tasks in the taskQueue

Annotations

@Override

submitIO	back to summary
public void submitIO() Submit the IO so the kernel can process it. This method can be called to "force" the submission (before it is submitted by netty itself).

wakeup	back to summary
protected void wakeup(boolean inEventLoop) Overrides io.netty.util.concurrent.SingleThreadEventExecutor.wakeup. Annotations @Override

wakeup

back to summary

protected void wakeup(boolean inEventLoop)

Overrides io.netty.util.concurrent.SingleThreadEventExecutor.wakeup.

Annotations

@Override

public final Class IOUringEventLoop

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail