Netty5/Transport/Classes/KQueue 5.0.0.Alpha5 · io.netty5.channel.kqueue.KQueueHandler

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 final IovArray	iovArray
private static final int	KQUEUE_WAKE_UP_IDENT
private final FileDescriptor	kqueueFd
private static final InternalLogger	logger
private final IntSupplier	selectNowSupplier
private final SelectStrategy	selectStrategy
private static final AtomicIntegerFieldUpdater<KQueueHandler>	WAKEN_UP_UPDATER
private volatile int	wakenUp

Constructor Summary

Access	Constructor and Description
private	KQueueHandler()
private	KQueueHandler(int maxEvents, SelectStrategy strategy)

Method Summary

Modifier and Type	Method and Description
private static AbstractKQueueChannel<?>	cast(IoHandle handle)
private IovArray	cleanArray()
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 void	evSet(AbstractKQueueChannel<?> ch, short filter, short flags, int fflags)
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.
private int	kqueueWait(IoExecutionContext context, boolean oldWakeup)
private int	kqueueWait(int timeoutSec, int timeoutNs)
private int	kqueueWaitNow()
public static IoHandlerFactory	newFactory() Returns a new `IoHandlerFactory` that creates `KQueueHandler` instances.
public static IoHandlerFactory	newFactory(final int maxEvents, final SelectStrategyFactory selectStrategyFactory) Returns a new `IoHandlerFactory` that creates `KQueueHandler` instances.
public void	prepareToDestroy() Implements io.netty5.channel.IoHandler.prepareToDestroy. Prepare to destroy this `IoHandler`.
private void	processReady(int ready)
public void	register(IoHandle the `Channel` to register.. handle) Implements io.netty5.channel.IoHandler.register. Register a `Channel` for IO.
public int	run(IoExecutionContext context) Implements io.netty5.channel.IoHandler.run. Run the IO handled by this `IoHandler`.
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.
private void	wakeup()

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

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

iovArray	back to summary
private final IovArray iovArray

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

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<KQueueHandler> WAKEN_UP_UPDATER

wakenUp	back to summary
private volatile int wakenUp

Constructor Detail

KQueueHandler	back to summary
private KQueueHandler()

KQueueHandler	back to summary
private KQueueHandler(int maxEvents, SelectStrategy strategy)

Method Detail

cast	back to summary
private static AbstractKQueueChannel<?> cast(IoHandle handle)

cleanArray	back to summary
private IovArray cleanArray()

deregister back to summary

deregister	back to summary
public void deregister(IoHandle handle) throws Exception 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 Exceptions Exception: thrown if an error happens during deregistration.

public void deregister(IoHandle handle) throws Exception

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

Exceptions

Exception:: thrown if an error happens during deregistration.

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

evSet	back to summary
private void evSet(AbstractKQueueChannel<?> ch, short filter, short flags, int fflags)

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

kqueueWait	back to summary
private int kqueueWait(IoExecutionContext context, 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

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

newFactory	back to summary
public static IoHandlerFactory newFactory(final int maxEvents, final SelectStrategyFactory selectStrategyFactory) Returns a new `IoHandlerFactory` that creates `KQueueHandler` instances.

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

processReady	back to summary
private void processReady(int ready)

register	back to summary
public void register(IoHandle handle) 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

public void register(IoHandle handle)

Implements io.netty5.channel.IoHandler.register.

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

Parameters

handle:IoHandle: the Channel to register..

Annotations

@Override

run back to summary

run	back to summary
public int run(IoExecutionContext context) 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 context)

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

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

wakeup	back to summary
private void wakeup()

public final Class KQueueHandler

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail