Netty5/Transport/Classes/Epoll 5.0.0.Alpha5 · io.netty5.channel.epoll.EpollHandler

Field Summary

Modifier and Type	Field and Description
private final boolean	allowGrowing
private static final long	AWAKE
private final IntObjectMap<AbstractEpollChannel<?>>	channels
private NativeDatagramPacketArray	datagramPacketArray
private static final long	EPOLL_WAIT_MILLIS_THRESHOLD
private final FileDescriptor	epollFd
private final FileDescriptor	eventFd
private final EpollEventArray	events
private IovArray	iovArray
private static final InternalLogger	logger
private static final long	MAX_SCHEDULED_TIMERFD_NS
private final AtomicLong	nextWakeupNanos
private static final long	NONE
private boolean	pendingWakeup
private long	prevDeadlineNanos
private final IntSupplier	selectNowSupplier
private final SelectStrategy	selectStrategy
private final FileDescriptor	timerFd

Constructor Summary

Access	Constructor and Description
private	EpollHandler()
pack-priv	EpollHandler(int maxEvents, SelectStrategy strategy)

Method Summary

Modifier and Type	Method and Description
private void	add(AbstractEpollChannel<?> ch) Register the given channel with this `EpollHandler`.
private static AbstractEpollChannel<?>	cast(IoHandle handle)
private NativeDatagramPacketArray	cleanDatagramPacketArray()
private IovArray	cleanIovArray()
public final void	deregister(IoHandle the `IoHandle` to deregister.. handle) Implements io.netty5.channel.IoHandler.deregister. Deregister a `IoHandle` for IO.
public final void	destroy() Implements io.netty5.channel.IoHandler.destroy. Destroy the `IoHandler` and free all its resources.
private int	epollBusyWait()
private long	epollWait(IoExecutionContext context, long deadlineNanos)
private int	epollWaitNoTimerChange()
private int	epollWaitNow()
private int	epollWaitTimeboxed()
pack-priv void	handleLoopException(Throwable t) Visible only for testing!
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 void	modify(AbstractEpollChannel<?> ch) The flags of the given epoll was modified so update the registration
public static IoHandlerFactory	newFactory() Returns a new `IoHandlerFactory` that creates `EpollHandler` instances.
public static IoHandlerFactory	newFactory(final int maxEvents, final SelectStrategyFactory selectStrategyFactory) Returns a new `IoHandlerFactory` that creates `EpollHandler` instances.
public void	prepareToDestroy() Implements io.netty5.channel.IoHandler.prepareToDestroy. Prepare to destroy this `IoHandler`.
private boolean	processReady(EpollEventArray events, int ready)
public final void	register(IoHandle the `Channel` to register.. handle) Implements io.netty5.channel.IoHandler.register. Register a `Channel` for IO.
private void	remove(AbstractEpollChannel<?> ch) Deregister the given channel from this `EpollHandler`.
public final int	run(IoExecutionContext context) Implements io.netty5.channel.IoHandler.run. Run the IO handled by this `IoHandler`.
public final 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

allowGrowing	back to summary
private final boolean allowGrowing

AWAKE	back to summary
private static final long AWAKE

channels	back to summary
private final IntObjectMap<AbstractEpollChannel<?>> channels

datagramPacketArray	back to summary
private NativeDatagramPacketArray datagramPacketArray

EPOLL_WAIT_MILLIS_THRESHOLD	back to summary
private static final long EPOLL_WAIT_MILLIS_THRESHOLD

epollFd	back to summary
private final FileDescriptor epollFd

eventFd	back to summary
private final FileDescriptor eventFd

events	back to summary
private final EpollEventArray events

iovArray	back to summary
private IovArray iovArray

logger	back to summary
private static final InternalLogger logger

MAX_SCHEDULED_TIMERFD_NS	back to summary
private static final long MAX_SCHEDULED_TIMERFD_NS

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

selectNowSupplier	back to summary
private final IntSupplier selectNowSupplier

selectStrategy	back to summary
private final SelectStrategy selectStrategy

timerFd	back to summary
private final FileDescriptor timerFd

Constructor Detail

EpollHandler	back to summary
private EpollHandler()

EpollHandler	back to summary
pack-priv EpollHandler(int maxEvents, SelectStrategy strategy)

Method Detail

add	back to summary
private void add(AbstractEpollChannel<?> ch) throws IOException Register the given channel with this `EpollHandler`.

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

cleanDatagramPacketArray	back to summary
private NativeDatagramPacketArray cleanDatagramPacketArray()

cleanIovArray	back to summary
private IovArray cleanIovArray()

deregister back to summary

deregister	back to summary
public final 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 final 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 final 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 final 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

epollBusyWait	back to summary
private int epollBusyWait() throws IOException

epollWait	back to summary
private long epollWait(IoExecutionContext context, long deadlineNanos) throws IOException

epollWaitNoTimerChange	back to summary
private int epollWaitNoTimerChange() throws IOException

epollWaitNow	back to summary
private int epollWaitNow() throws IOException

epollWaitTimeboxed	back to summary
private int epollWaitTimeboxed() throws IOException

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

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

modify	back to summary
private void modify(AbstractEpollChannel<?> ch) throws IOException The flags of the given epoll was modified so update the registration

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

newFactory	back to summary
public static IoHandlerFactory newFactory(final int maxEvents, final SelectStrategyFactory selectStrategyFactory) Returns a new `IoHandlerFactory` that creates `EpollHandler` 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 boolean processReady(EpollEventArray events, int ready)

register	back to summary
public final 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 final 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.

remove	back to summary
private void remove(AbstractEpollChannel<?> ch) throws IOException Deregister the given channel from this `EpollHandler`.

run back to summary

run	back to summary
public final 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 final 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 final 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 final 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 Class EpollHandler

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail