io.netty.channel.epoll

Class EpollIoHandler

java.lang.Object

io.netty.channel.epoll.EpollIoHandler

All Implemented Interfaces:

io.netty.channel.IoHandler

public class EpollIoHandler
extends Object
implements io.netty.channel.IoHandler

IoHandler which uses epoll under the covers. Only works on Linux!

Method Summary

Modifier and Type	Method and Description
void	closeFileDescriptors() This method is intended for use by process checkpoint/restore integration, such as OpenJDK CRaC.
void	destroy()
boolean	isCompatible(Class<? extends io.netty.channel.IoHandle> handleType)
static io.netty.channel.IoHandlerFactory	newFactory() Returns a new IoHandlerFactory that creates EpollIoHandler instances.
static io.netty.channel.IoHandlerFactory	newFactory(int maxEvents, io.netty.channel.SelectStrategyFactory selectStrategyFactory) Returns a new IoHandlerFactory that creates EpollIoHandler instances.
void	openFileDescriptors() This method is intended for use by a process checkpoint/restore integration, such as OpenJDK CRaC.
void	prepareToDestroy()
EpollIoRegistration	register(io.netty.channel.IoEventLoop eventLoop, io.netty.channel.IoHandle handle)
int	run(io.netty.channel.IoExecutionContext context)
void	wakeup(io.netty.channel.IoEventLoop eventLoop)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

newFactory

public static io.netty.channel.IoHandlerFactory newFactory()

Returns a new IoHandlerFactory that creates EpollIoHandler instances.

newFactory

public static io.netty.channel.IoHandlerFactory newFactory(int maxEvents,
                                                           io.netty.channel.SelectStrategyFactory selectStrategyFactory)

Returns a new IoHandlerFactory that creates EpollIoHandler instances.

openFileDescriptors

@UnstableApi
public void openFileDescriptors()

This method is intended for use by a process checkpoint/restore integration, such as OpenJDK CRaC.

wakeup

public void wakeup(io.netty.channel.IoEventLoop eventLoop)

Specified by:

wakeup in interface io.netty.channel.IoHandler

prepareToDestroy

public void prepareToDestroy()

Specified by:

prepareToDestroy in interface io.netty.channel.IoHandler

destroy

public void destroy()

Specified by:

destroy in interface io.netty.channel.IoHandler

register

public EpollIoRegistration register(io.netty.channel.IoEventLoop eventLoop,
                                    io.netty.channel.IoHandle handle)
                             throws Exception

Specified by:

register in interface io.netty.channel.IoHandler

Throws:

Exception

isCompatible

public boolean isCompatible(Class<? extends io.netty.channel.IoHandle> handleType)

Specified by:

isCompatible in interface io.netty.channel.IoHandler

run

public int run(io.netty.channel.IoExecutionContext context)

Specified by:

run in interface io.netty.channel.IoHandler

closeFileDescriptors

@UnstableApi
public void closeFileDescriptors()

This method is intended for use by process checkpoint/restore integration, such as OpenJDK CRaC. It's up to the caller to ensure that there is no concurrent use of the FDs while these are closed, e.g. by blocking the executor.