Nested and Inner Type Summary

Modifier and Type	Class and Description
private static class	NioHandler.SelectorTuple

Field Summary

Modifier and Type	Field and Description
private int	cancelledKeys
private static final int	CLEANUP_INTERVAL
private static final boolean	DISABLE_KEY_SET_OPTIMIZATION
private static final InternalLogger	logger
private static final int	MIN_PREMATURE_SELECTOR_RETURNS
private boolean	needsToSelectAgain
private final SelectorProvider	provider
private SelectedSelectionKeySet	selectedKeys
private final IntSupplier	selectNowSupplier
private Selector	selector The NIO `Selector`.
private static final int	SELECTOR_AUTO_REBUILD_THRESHOLD
private final SelectStrategy	selectStrategy
private Selector	unwrappedSelector
private final AtomicBoolean	wakenUp Boolean that controls determines if a blocked Selector.select should break out of its selection process.

Constructor Summary

Access	Constructor and Description
private	NioHandler()
private	NioHandler(SelectorProvider selectorProvider, SelectStrategy strategy)

Method Summary

Modifier and Type	Method and Description
public void	deregister(IoHandle the `IoHandle` to deregister.. handle) Implements io.netty5.channel.IoHandler.deregister. Deregister a `IoHandle` for IO.
public void	destroy() Implements io.netty5.channel.IoHandler.destroy. Destroy the `IoHandler` and free all its resources.
private static void	handleLoopException(Throwable t)
public boolean	isCompatible(Class<? extends IoHandle> the type of the `IoHandle`. handleType) Implements io.netty5.channel.IoHandler.isCompatible. Returns `true` if the given type is compatible with this `IoHandler` and so can be registered, `false` otherwise.
public static IoHandlerFactory	newFactory() Returns a new `IoHandlerFactory` that creates `NioHandler` instances.
public static IoHandlerFactory	newFactory(final SelectorProvider selectorProvider, final SelectStrategyFactory selectStrategyFactory) Returns a new `IoHandlerFactory` that creates `NioHandler` instances.
private static NioProcessor	nioHandle(IoHandle handle)
private NioHandler.SelectorTuple	openSelector()
public void	prepareToDestroy() Implements io.netty5.channel.IoHandler.prepareToDestroy. Prepare to destroy this `IoHandler`.
private void	processSelectedKey(SelectionKey k)
private int	processSelectedKeys()
private int	processSelectedKeysOptimized()
private int	processSelectedKeysPlain(Set<SelectionKey> selectedKeys)
pack-priv void	rebuildSelector() Replaces the current `Selector` of this event loop with newly created `Selector`s to work around the infamous epoll 100% CPU bug.
public void	register(IoHandle the `Channel` to register.. handle) Implements io.netty5.channel.IoHandler.register. Register a `Channel` for IO.
public int	run(IoExecutionContext runner) Implements io.netty5.channel.IoHandler.run. Run the IO handled by this `IoHandler`.
private void	select(IoExecutionContext runner, boolean oldWakenUp)
private void	selectAgain()
private int	selectNow()
public SelectorProvider	selectorProvider() Returns the `SelectorProvider` used by this `NioHandler` to obtain the `Selector`.
private Selector	selectRebuildSelector(int selectCnt)
pack-priv Selector	unwrappedSelector()
public void	wakeup(boolean inEventLoop) Implements io.netty5.channel.IoHandler.wakeup. Wakeup the `IoHandler`, which means if any operation blocks it should be unblocked and return as soon as possible.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

cancelledKeys	back to summary
private int cancelledKeys

CLEANUP_INTERVAL	back to summary
private static final int CLEANUP_INTERVAL

DISABLE_KEY_SET_OPTIMIZATION	back to summary
private static final boolean DISABLE_KEY_SET_OPTIMIZATION

logger	back to summary
private static final InternalLogger logger

MIN_PREMATURE_SELECTOR_RETURNS	back to summary
private static final int MIN_PREMATURE_SELECTOR_RETURNS

needsToSelectAgain	back to summary
private boolean needsToSelectAgain

provider	back to summary
private final SelectorProvider provider

selectedKeys	back to summary
private SelectedSelectionKeySet selectedKeys

selectNowSupplier	back to summary
private final IntSupplier selectNowSupplier

selector	back to summary
private Selector selector The NIO `Selector`.

SELECTOR_AUTO_REBUILD_THRESHOLD	back to summary
private static final int SELECTOR_AUTO_REBUILD_THRESHOLD

selectStrategy	back to summary
private final SelectStrategy selectStrategy

unwrappedSelector	back to summary
private Selector unwrappedSelector

wakenUp	back to summary
private final AtomicBoolean wakenUp Boolean that controls determines if a blocked Selector.select should break out of its selection process. In our case we use a timeout for the select method and the select method will block for that time unless waken up.

Constructor Detail

NioHandler	back to summary
private NioHandler()

NioHandler	back to summary
private NioHandler(SelectorProvider selectorProvider, SelectStrategy strategy)

Method Detail

deregister back to summary

deregister	back to summary
public void deregister(IoHandle handle) Implements io.netty5.channel.IoHandler.deregister. Doc from io.netty5.channel.IoHandler.deregister. Deregister a `IoHandle` for IO. Parameters handle:IoHandle the `IoHandle` to deregister.. Annotations @Override

public void deregister(IoHandle handle)

Implements io.netty5.channel.IoHandler.deregister.

Doc from io.netty5.channel.IoHandler.deregister.

Deregister a IoHandle for IO.

Parameters

handle:IoHandle: the IoHandle to deregister..

Annotations

@Override

destroy back to summary

destroy	back to summary
public void destroy() Implements io.netty5.channel.IoHandler.destroy. Doc from io.netty5.channel.IoHandler.destroy. Destroy the `IoHandler` and free all its resources. Annotations @Override

public void destroy()

Implements io.netty5.channel.IoHandler.destroy.

Doc from io.netty5.channel.IoHandler.destroy.

Destroy the IoHandler and free all its resources.

Annotations

@Override

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

isCompatible back to summary

isCompatible	back to summary
public boolean isCompatible(Class<? extends IoHandle> handleType) Implements io.netty5.channel.IoHandler.isCompatible. Doc from io.netty5.channel.IoHandler.isCompatible. Returns `true` if the given type is compatible with this `IoHandler` and so can be registered, `false` otherwise. Parameters handleType:Class<? extends IoHandle> the type of the `IoHandle`. Returns:boolean if compatible of not. Annotations @Override

public boolean isCompatible(Class<? extends IoHandle> handleType)

Implements io.netty5.channel.IoHandler.isCompatible.

Doc from io.netty5.channel.IoHandler.isCompatible.

Returns true if the given type is compatible with this IoHandler and so can be registered, false otherwise.

Parameters

handleType:Class<? extends IoHandle>: the type of the IoHandle.

Returns:boolean

if compatible of not.

Annotations

@Override

newFactory	back to summary
public static IoHandlerFactory newFactory() Returns a new `IoHandlerFactory` that creates `NioHandler` instances.

newFactory	back to summary
public static IoHandlerFactory newFactory(final SelectorProvider selectorProvider, final SelectStrategyFactory selectStrategyFactory) Returns a new `IoHandlerFactory` that creates `NioHandler` instances.

nioHandle	back to summary
private static NioProcessor nioHandle(IoHandle handle)

openSelector	back to summary
private NioHandler.SelectorTuple openSelector()

prepareToDestroy back to summary

prepareToDestroy	back to summary
public void prepareToDestroy() Implements io.netty5.channel.IoHandler.prepareToDestroy. Doc from io.netty5.channel.IoHandler.prepareToDestroy. Prepare to destroy this `IoHandler`. This method will be called before `destroy()` and may be called multiple times. Annotations @Override

public void prepareToDestroy()

Implements io.netty5.channel.IoHandler.prepareToDestroy.

Doc from io.netty5.channel.IoHandler.prepareToDestroy.

Prepare to destroy this IoHandler. This method will be called before destroy() and may be called multiple times.

Annotations

@Override

processSelectedKey	back to summary
private void processSelectedKey(SelectionKey k)

processSelectedKeys	back to summary
private int processSelectedKeys()

processSelectedKeysOptimized	back to summary
private int processSelectedKeysOptimized()

processSelectedKeysPlain	back to summary
private int processSelectedKeysPlain(Set<SelectionKey> selectedKeys)

rebuildSelector	back to summary
pack-priv void rebuildSelector() Replaces the current `Selector` of this event loop with newly created `Selector`s to work around the infamous epoll 100% CPU bug.

register	back to summary
public void register(IoHandle handle) throws Exception Implements io.netty5.channel.IoHandler.register. Doc from io.netty5.channel.IoHandler.register. Register a `Channel` for IO. Parameters handle:IoHandle the `Channel` to register.. Annotations @Override Exceptions Exception: thrown if an error happens during registration.

public void register(IoHandle handle) throws Exception

Implements io.netty5.channel.IoHandler.register.

Doc from io.netty5.channel.IoHandler.register.

Parameters

handle:IoHandle: the Channel to register..

Annotations

@Override

Exceptions

Exception:: thrown if an error happens during registration.

run back to summary

run	back to summary
public int run(IoExecutionContext runner) Implements io.netty5.channel.IoHandler.run. Doc from io.netty5.channel.IoHandler.run. Run the IO handled by this `IoHandler`. The `IoExecutionContext` should be used to ensure we not execute too long and so block the processing of other task that are scheduled on the `EventLoop`. This is done by taking `IoExecutionContext#delayNanos(long)` or `IoExecutionContext#deadlineNanos()` into account. Returns:int the number of `IoHandle` for which I/O was handled. Annotations @Override

public int run(IoExecutionContext runner)

Implements io.netty5.channel.IoHandler.run.

Doc from io.netty5.channel.IoHandler.run.

Run the IO handled by this IoHandler. The IoExecutionContext should be used to ensure we not execute too long and so block the processing of other task that are scheduled on the EventLoop. This is done by taking IoExecutionContext#delayNanos(long) or IoExecutionContext#deadlineNanos() into account.

Returns:int

the number of IoHandle for which I/O was handled.

Annotations

@Override

select	back to summary
private void select(IoExecutionContext runner, boolean oldWakenUp) throws IOException

selectAgain	back to summary
private void selectAgain()

selectNow	back to summary
private int selectNow() throws IOException

selectorProvider	back to summary
public SelectorProvider selectorProvider() Returns the `SelectorProvider` used by this `NioHandler` to obtain the `Selector`.

selectRebuildSelector	back to summary
private Selector selectRebuildSelector(int selectCnt) throws IOException

unwrappedSelector	back to summary
pack-priv Selector unwrappedSelector()

wakeup back to summary

wakeup	back to summary
public void wakeup(boolean inEventLoop) Implements io.netty5.channel.IoHandler.wakeup. Doc from io.netty5.channel.IoHandler.wakeup. Wakeup the `IoHandler`, which means if any operation blocks it should be unblocked and return as soon as possible. Annotations @Override

public void wakeup(boolean inEventLoop)

Implements io.netty5.channel.IoHandler.wakeup.

Doc from io.netty5.channel.IoHandler.wakeup.

Wakeup the IoHandler, which means if any operation blocks it should be unblocked and return as soon as possible.

Annotations

@Override

io.netty5.channel.nio back to summary

private final Class NioHandler.SelectorTuple

Class Inheritance

extends Object

java.lang.Object
io.netty5.channel.nio.NioHandler.SelectorTuple

Field Summary

Modifier and Type	Field and Description
pack-priv final Selector	selector
pack-priv final Selector	unwrappedSelector

Constructor Summary

Access	Constructor and Description
pack-priv	SelectorTuple(Selector unwrappedSelector)
pack-priv	SelectorTuple(Selector unwrappedSelector, Selector selector)

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

selector	back to summary
pack-priv final Selector selector

unwrappedSelector	back to summary
pack-priv final Selector unwrappedSelector

Constructor Detail

SelectorTuple	back to summary
pack-priv SelectorTuple(Selector unwrappedSelector)

SelectorTuple	back to summary
pack-priv SelectorTuple(Selector unwrappedSelector, Selector selector)

public final Class NioHandler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class NioHandler.SelectorTuple

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail