Netty 4.1.107.Final · io.netty.channel.kqueue.KQueueEventLoop

Field Summary

Modifier and Type	Field and Description
private final boolean	allowGrowing
private final KQueueEventArray	changeList
private final IntObjectMap<AbstractKQueueChannel>	channels
private final KQueueEventArray	eventList
private volatile int	ioRatio
private final IovArray	iovArray
private static final int	KQUEUE_MAX_TIMEOUT_SECONDS
private static final int	KQUEUE_WAKE_UP_IDENT
private final FileDescriptor	kqueueFd
private static final InternalLogger	logger Hides io.netty.util.concurrent.SingleThreadEventExecutor.logger.
private final IntSupplier	selectNowSupplier
private final SelectStrategy	selectStrategy
private static final AtomicIntegerFieldUpdater<KQueueEventLoop>	WAKEN_UP_UPDATER
private volatile int	wakenUp

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

Constructor Summary

Access	Constructor and Description
pack-priv	KQueueEventLoop(EventLoopGroup parent, Executor executor, int maxEvents, SelectStrategy strategy, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory)

Method Summary

Modifier and Type	Method and Description
pack-priv void	add(AbstractKQueueChannel ch)
pack-priv IovArray	cleanArray() Return a cleared `IovArray` that can be used for writes in this `EventLoop`.
protected void	cleanup() Overrides io.netty.util.concurrent.SingleThreadEventExecutor.cleanup. Do nothing, sub-classes may override
private void	closeAll()
pack-priv void	evSet(AbstractKQueueChannel ch, short filter, short flags, int fflags)
public int	getIoRatio() Returns the percentage of the desired amount of time spent for I/O in the event loop.
private static void	handleLoopException(Throwable t)
private int	kqueueWait(boolean oldWakeup)
private int	kqueueWait(int timeoutSec, int timeoutNs)
private int	kqueueWaitNow()
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)
private void	processReady(int ready)
public int	registeredChannels() Overrides io.netty.channel.SingleThreadEventLoop.registeredChannels. Returns the number of `Channel`s registered with this `EventLoop` or `-1` if operation is not supported.
public Iterator<Channel>	registeredChannelsIterator() Overrides io.netty.channel.SingleThreadEventLoop.registeredChannelsIterator.
pack-priv void	remove(AbstractKQueueChannel ch)
protected void	run() Implements abstract io.netty.util.concurrent.SingleThreadEventExecutor.run. Run the tasks in the `taskQueue`
public void	setIoRatio(int ioRatio) Sets the percentage of the desired amount of time spent for I/O in the event loop.
protected void	wakeup(boolean inEventLoop) Overrides io.netty.util.concurrent.SingleThreadEventExecutor.wakeup.
private void	wakeup()

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

Field Detail

allowGrowing	back to summary
private final boolean allowGrowing

changeList	back to summary
private final KQueueEventArray changeList

channels	back to summary
private final IntObjectMap<AbstractKQueueChannel> channels

eventList	back to summary
private final KQueueEventArray eventList

ioRatio	back to summary
private volatile int ioRatio

iovArray	back to summary
private final IovArray iovArray

KQUEUE_MAX_TIMEOUT_SECONDS	back to summary
private static final int KQUEUE_MAX_TIMEOUT_SECONDS

KQUEUE_WAKE_UP_IDENT	back to summary
private static final int KQUEUE_WAKE_UP_IDENT

kqueueFd	back to summary
private final FileDescriptor kqueueFd

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

selectNowSupplier	back to summary
private final IntSupplier selectNowSupplier

selectStrategy	back to summary
private final SelectStrategy selectStrategy

WAKEN_UP_UPDATER	back to summary
private static final AtomicIntegerFieldUpdater<KQueueEventLoop> WAKEN_UP_UPDATER

wakenUp	back to summary
private volatile int wakenUp

Constructor Detail

KQueueEventLoop	back to summary
pack-priv KQueueEventLoop(EventLoopGroup parent, Executor executor, int maxEvents, SelectStrategy strategy, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory)

Method Detail

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

cleanArray	back to summary
pack-priv IovArray cleanArray() Return a cleared `IovArray` that can be used for writes in this `EventLoop`.

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()

evSet	back to summary
pack-priv void evSet(AbstractKQueueChannel ch, short filter, short flags, int fflags)

getIoRatio	back to summary
public int getIoRatio() Returns the percentage of the desired amount of time spent for I/O in the event loop.

handleLoopException	back to summary
private static void handleLoopException(Throwable t)

kqueueWait	back to summary
private int kqueueWait(boolean oldWakeup) throws IOException

kqueueWait	back to summary
private int kqueueWait(int timeoutSec, int timeoutNs) throws IOException

kqueueWaitNow	back to summary
private int kqueueWaitNow() throws IOException

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)

processReady	back to summary
private void processReady(int ready)

registeredChannels back to summary

registeredChannels	back to summary
public int registeredChannels() Overrides io.netty.channel.SingleThreadEventLoop.registeredChannels. Doc from io.netty.channel.SingleThreadEventLoop.registeredChannels. Returns the number of `Channel`s registered with this `EventLoop` or `-1` if operation is not supported. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort. Annotations @Override

public int registeredChannels()

Overrides io.netty.channel.SingleThreadEventLoop.registeredChannels.

Doc from io.netty.channel.SingleThreadEventLoop.registeredChannels.

Returns the number of Channels registered with this EventLoop or -1 if operation is not supported. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort.

Annotations

@Override

registeredChannelsIterator back to summary

registeredChannelsIterator	back to summary
public Iterator<Channel> registeredChannelsIterator() Overrides io.netty.channel.SingleThreadEventLoop.registeredChannelsIterator. Returns:Iterator<Channel> Doc from io.netty.channel.SingleThreadEventLoop.registeredChannelsIterator. read-only iterator of active `Channel`s registered with this `EventLoop`. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort. This method is expected to be called from within event loop. Annotations @Override

public Iterator<Channel> registeredChannelsIterator()

Overrides io.netty.channel.SingleThreadEventLoop.registeredChannelsIterator.

Returns:Iterator<Channel>

Doc from io.netty.channel.SingleThreadEventLoop.registeredChannelsIterator.

read-only iterator of active Channels registered with this EventLoop. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort. This method is expected to be called from within event loop.

Annotations

@Override

remove	back to summary
pack-priv void remove(AbstractKQueueChannel ch) throws Exception

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

setIoRatio	back to summary
public void setIoRatio(int ioRatio) Sets the percentage of the desired amount of time spent for I/O in the event loop. The default value is `50`, which means the event loop will try to spend the same amount of time for I/O as for non-I/O tasks.

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

wakeup	back to summary
private void wakeup()

pack-priv final Class KQueueEventLoop

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail