Top Fields Constructors Methods
io.netty.incubator.channel.uring

pack-priv final Class Native

extends Object
Class Inheritance
Imports
io.netty.channel.unix.FileDescriptor, .PeerCredentials, .Unix, io.netty.util.internal.ClassInitializerUtil, .NativeLibraryLoader, .PlatformDependent, .SystemPropertyUtil, .ThrowableUtil, io.netty.util.internal.logging.InternalLogger, .InternalLoggerFactory, java.io.BufferedReader, .File, .FileReader, .IOException, java.nio.channels.Selector, java.nio.file.Path, java.security.AccessController, .PrivilegedAction, java.util.Arrays, .Locale

Field Summary

Modifier and TypeField and Description
pack-priv static final short
AF_INET

pack-priv static final short
AF_INET6

pack-priv static final int
CMSG_LEN

pack-priv static final int
CMSG_OFFSETOF_CMSG_LEN

pack-priv static final int
CMSG_OFFSETOF_CMSG_LEVEL

pack-priv static final int
CMSG_OFFSETOF_CMSG_TYPE

pack-priv static final int
CMSG_SPACE

pack-priv static final int
DEFAULT_IOSQE_ASYNC_THRESHOLD

When there are more FDs (= connections) than this setting, the FDs will be marked as IOSQE_ASYNC, under the expectation that read/write ops on the FDs will usually block.

pack-priv static final int
DEFAULT_RING_SIZE

pack-priv static final int
ERRNO_ECANCELED_NEGATIVE

pack-priv static final int
ERRNO_ETIME_NEGATIVE

pack-priv static final int
IN6_ADDRESS_OFFSETOF_S6_ADDR

pack-priv static final int
IN_ADDRESS_OFFSETOF_S_ADDR

pack-priv static final int
IORING_ENTER_GETEVENTS

pack-priv static final byte
IORING_OP_ACCEPT

pack-priv static final byte
IORING_OP_CLOSE

pack-priv static final byte
IORING_OP_CONNECT

pack-priv static final byte
IORING_OP_POLL_ADD

pack-priv static final byte
IORING_OP_POLL_REMOVE

pack-priv static final byte
IORING_OP_READ

pack-priv static final byte
IORING_OP_RECV

pack-priv static final byte
IORING_OP_RECVMSG

pack-priv static final byte
IORING_OP_SEND

pack-priv static final byte
IORING_OP_SENDMSG

pack-priv static final byte
IORING_OP_TIMEOUT

pack-priv static final byte
IORING_OP_TIMEOUT_REMOVE

pack-priv static final byte
IORING_OP_WRITE

pack-priv static final byte
IORING_OP_WRITEV

pack-priv static final int
IOSQE_ASYNC

pack-priv static final int
IOVEC_OFFSETOF_IOV_BASE

pack-priv static final int
IOVEC_OFFSETOF_IOV_LEN

pack-priv static final boolean
IS_SUPPORTING_TCP_FASTOPEN_CLIENT

tcp_fastopen client mode enabled state.

pack-priv static final boolean
IS_SUPPORTING_TCP_FASTOPEN_SERVER

tcp_fastopen server mode enabled state.

private static final InternalLogger
logger

pack-priv static final int
MSG_DONTWAIT

pack-priv static final int
MSG_FASTOPEN

pack-priv static final int
MSGHDR_OFFSETOF_MSG_CONTROL

pack-priv static final int
MSGHDR_OFFSETOF_MSG_CONTROLLEN

pack-priv static final int
MSGHDR_OFFSETOF_MSG_FLAGS

pack-priv static final int
MSGHDR_OFFSETOF_MSG_IOV

pack-priv static final int
MSGHDR_OFFSETOF_MSG_IOVLEN

pack-priv static final int
MSGHDR_OFFSETOF_MSG_NAME

pack-priv static final int
MSGHDR_OFFSETOF_MSG_NAMELEN

pack-priv static final int
POLLIN

pack-priv static final int
POLLOUT

pack-priv static final int
POLLRDHUP

private static final int[]
REQUIRED_IORING_OPS

pack-priv static final int
SIZEOF_IOVEC

pack-priv static final int
SIZEOF_MSGHDR

pack-priv static final int
SIZEOF_SIZE_T

pack-priv static final int
SIZEOF_SOCKADDR_IN

pack-priv static final int
SIZEOF_SOCKADDR_IN6

pack-priv static final int
SIZEOF_SOCKADDR_STORAGE

pack-priv static final int
SOCK_CLOEXEC

pack-priv static final int
SOCK_NONBLOCK

pack-priv static final int
SOCKADDR_IN6_OFFSETOF_SIN6_ADDR

pack-priv static final int
SOCKADDR_IN6_OFFSETOF_SIN6_FAMILY

pack-priv static final int
SOCKADDR_IN6_OFFSETOF_SIN6_FLOWINFO

pack-priv static final int
SOCKADDR_IN6_OFFSETOF_SIN6_PORT

pack-priv static final int
SOCKADDR_IN6_OFFSETOF_SIN6_SCOPE_ID

pack-priv static final int
SOCKADDR_IN_OFFSETOF_SIN_ADDR

pack-priv static final int
SOCKADDR_IN_OFFSETOF_SIN_FAMILY

pack-priv static final int
SOCKADDR_IN_OFFSETOF_SIN_PORT

pack-priv static final int
SOL_UDP

private static final int
TCP_FASTOPEN_MODE

private static final int
TFO_ENABLED_CLIENT_MASK

private static final int
TFO_ENABLED_SERVER_MASK

pack-priv static final int
UDP_SEGMENT

Constructor Summary

AccessConstructor and Description
private
Native()

Method Summary

Modifier and TypeMethod and Description
private static native int
blockingEventFd()

pack-priv static void
checkAllIOSupported(int ringFd)

pack-priv static void
checkKernelVersion(String kernelVersion)

private static boolean
checkKernelVersion0(String kernelVersion)

pack-priv static native long
cmsghdrData(long hdrAddr)

pack-priv static native int
createFile(String name)

pack-priv static RingBuffer
createRingBuffer(int ringSize)

pack-priv static RingBuffer
createRingBuffer(int ringSize, int iosqeAsyncThreshold)

pack-priv static RingBuffer
createRingBuffer()

pack-priv static native void
eventFdWrite(int fd, long value)

pack-priv static native int
ioUringEnter(int ringFd, int toSubmit, int minComplete, int flags)

pack-priv static native void
ioUringExit(long submissionQueueArrayAddress, int submissionQueueRingEntries, long submissionQueueRingAddress, int submissionQueueRingSize, long completionQueueRingAddress, int completionQueueRingSize, int ringFd)

private static native boolean
ioUringProbe(int ringFd, int[] ios)

private static native long[][]
ioUringSetup(int entries)

pack-priv static native String
kernelVersion()

private static void
loadNativeLibrary()

pack-priv static FileDescriptor
newBlockingEventFd()

private static native int
registerUnix()

private static int
tcpFastopenMode()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

AF_INETback to summary
pack-priv static final short AF_INET
AF_INET6back to summary
pack-priv static final short AF_INET6
CMSG_LENback to summary
pack-priv static final int CMSG_LEN
CMSG_OFFSETOF_CMSG_LENback to summary
pack-priv static final int CMSG_OFFSETOF_CMSG_LEN
CMSG_OFFSETOF_CMSG_LEVELback to summary
pack-priv static final int CMSG_OFFSETOF_CMSG_LEVEL
CMSG_OFFSETOF_CMSG_TYPEback to summary
pack-priv static final int CMSG_OFFSETOF_CMSG_TYPE
CMSG_SPACEback to summary
pack-priv static final int CMSG_SPACE
DEFAULT_IOSQE_ASYNC_THRESHOLDback to summary
pack-priv static final int DEFAULT_IOSQE_ASYNC_THRESHOLD

When there are more FDs (= connections) than this setting, the FDs will be marked as IOSQE_ASYNC, under the expectation that read/write ops on the FDs will usually block. If this expectation is correct, IOSQE_ASYNC can reduce CPU usage, but if the expectation is incorrect, it may add additional, unnecessary latency.

Default is to never use IOSQE_ASYNC.

DEFAULT_RING_SIZEback to summary
pack-priv static final int DEFAULT_RING_SIZE
ERRNO_ECANCELED_NEGATIVEback to summary
pack-priv static final int ERRNO_ECANCELED_NEGATIVE
ERRNO_ETIME_NEGATIVEback to summary
pack-priv static final int ERRNO_ETIME_NEGATIVE
IN6_ADDRESS_OFFSETOF_S6_ADDRback to summary
pack-priv static final int IN6_ADDRESS_OFFSETOF_S6_ADDR
IN_ADDRESS_OFFSETOF_S_ADDRback to summary
pack-priv static final int IN_ADDRESS_OFFSETOF_S_ADDR
IORING_ENTER_GETEVENTSback to summary
pack-priv static final int IORING_ENTER_GETEVENTS
IORING_OP_ACCEPTback to summary
pack-priv static final byte IORING_OP_ACCEPT
IORING_OP_CLOSEback to summary
pack-priv static final byte IORING_OP_CLOSE
IORING_OP_CONNECTback to summary
pack-priv static final byte IORING_OP_CONNECT
IORING_OP_POLL_ADDback to summary
pack-priv static final byte IORING_OP_POLL_ADD
IORING_OP_POLL_REMOVEback to summary
pack-priv static final byte IORING_OP_POLL_REMOVE
IORING_OP_READback to summary
pack-priv static final byte IORING_OP_READ
IORING_OP_RECVback to summary
pack-priv static final byte IORING_OP_RECV
IORING_OP_RECVMSGback to summary
pack-priv static final byte IORING_OP_RECVMSG
IORING_OP_SENDback to summary
pack-priv static final byte IORING_OP_SEND
IORING_OP_SENDMSGback to summary
pack-priv static final byte IORING_OP_SENDMSG
IORING_OP_TIMEOUTback to summary
pack-priv static final byte IORING_OP_TIMEOUT
IORING_OP_TIMEOUT_REMOVEback to summary
pack-priv static final byte IORING_OP_TIMEOUT_REMOVE
IORING_OP_WRITEback to summary
pack-priv static final byte IORING_OP_WRITE
IORING_OP_WRITEVback to summary
pack-priv static final byte IORING_OP_WRITEV
IOSQE_ASYNCback to summary
pack-priv static final int IOSQE_ASYNC
IOVEC_OFFSETOF_IOV_BASEback to summary
pack-priv static final int IOVEC_OFFSETOF_IOV_BASE
IOVEC_OFFSETOF_IOV_LENback to summary
pack-priv static final int IOVEC_OFFSETOF_IOV_LEN
IS_SUPPORTING_TCP_FASTOPEN_CLIENTback to summary
pack-priv static final boolean IS_SUPPORTING_TCP_FASTOPEN_CLIENT

tcp_fastopen client mode enabled state.

IS_SUPPORTING_TCP_FASTOPEN_SERVERback to summary
pack-priv static final boolean IS_SUPPORTING_TCP_FASTOPEN_SERVER

tcp_fastopen server mode enabled state.

loggerback to summary
private static final InternalLogger logger
MSG_DONTWAITback to summary
pack-priv static final int MSG_DONTWAIT
MSG_FASTOPENback to summary
pack-priv static final int MSG_FASTOPEN
MSGHDR_OFFSETOF_MSG_CONTROLback to summary
pack-priv static final int MSGHDR_OFFSETOF_MSG_CONTROL
MSGHDR_OFFSETOF_MSG_CONTROLLENback to summary
pack-priv static final int MSGHDR_OFFSETOF_MSG_CONTROLLEN
MSGHDR_OFFSETOF_MSG_FLAGSback to summary
pack-priv static final int MSGHDR_OFFSETOF_MSG_FLAGS
MSGHDR_OFFSETOF_MSG_IOVback to summary
pack-priv static final int MSGHDR_OFFSETOF_MSG_IOV
MSGHDR_OFFSETOF_MSG_IOVLENback to summary
pack-priv static final int MSGHDR_OFFSETOF_MSG_IOVLEN
MSGHDR_OFFSETOF_MSG_NAMEback to summary
pack-priv static final int MSGHDR_OFFSETOF_MSG_NAME
MSGHDR_OFFSETOF_MSG_NAMELENback to summary
pack-priv static final int MSGHDR_OFFSETOF_MSG_NAMELEN
POLLINback to summary
pack-priv static final int POLLIN
POLLOUTback to summary
pack-priv static final int POLLOUT
POLLRDHUPback to summary
pack-priv static final int POLLRDHUP
REQUIRED_IORING_OPSback to summary
private static final int[] REQUIRED_IORING_OPS
SIZEOF_IOVECback to summary
pack-priv static final int SIZEOF_IOVEC
SIZEOF_MSGHDRback to summary
pack-priv static final int SIZEOF_MSGHDR
SIZEOF_SIZE_Tback to summary
pack-priv static final int SIZEOF_SIZE_T
SIZEOF_SOCKADDR_INback to summary
pack-priv static final int SIZEOF_SOCKADDR_IN
SIZEOF_SOCKADDR_IN6back to summary
pack-priv static final int SIZEOF_SOCKADDR_IN6
SIZEOF_SOCKADDR_STORAGEback to summary
pack-priv static final int SIZEOF_SOCKADDR_STORAGE
SOCK_CLOEXECback to summary
pack-priv static final int SOCK_CLOEXEC
SOCK_NONBLOCKback to summary
pack-priv static final int SOCK_NONBLOCK
SOCKADDR_IN6_OFFSETOF_SIN6_ADDRback to summary
pack-priv static final int SOCKADDR_IN6_OFFSETOF_SIN6_ADDR
SOCKADDR_IN6_OFFSETOF_SIN6_FAMILYback to summary
pack-priv static final int SOCKADDR_IN6_OFFSETOF_SIN6_FAMILY
SOCKADDR_IN6_OFFSETOF_SIN6_FLOWINFOback to summary
pack-priv static final int SOCKADDR_IN6_OFFSETOF_SIN6_FLOWINFO
SOCKADDR_IN6_OFFSETOF_SIN6_PORTback to summary
pack-priv static final int SOCKADDR_IN6_OFFSETOF_SIN6_PORT
SOCKADDR_IN6_OFFSETOF_SIN6_SCOPE_IDback to summary
pack-priv static final int SOCKADDR_IN6_OFFSETOF_SIN6_SCOPE_ID
SOCKADDR_IN_OFFSETOF_SIN_ADDRback to summary
pack-priv static final int SOCKADDR_IN_OFFSETOF_SIN_ADDR
SOCKADDR_IN_OFFSETOF_SIN_FAMILYback to summary
pack-priv static final int SOCKADDR_IN_OFFSETOF_SIN_FAMILY
SOCKADDR_IN_OFFSETOF_SIN_PORTback to summary
pack-priv static final int SOCKADDR_IN_OFFSETOF_SIN_PORT
SOL_UDPback to summary
pack-priv static final int SOL_UDP
TCP_FASTOPEN_MODEback to summary
private static final int TCP_FASTOPEN_MODE
TFO_ENABLED_CLIENT_MASKback to summary
private static final int TFO_ENABLED_CLIENT_MASK
TFO_ENABLED_SERVER_MASKback to summary
private static final int TFO_ENABLED_SERVER_MASK
UDP_SEGMENTback to summary
pack-priv static final int UDP_SEGMENT

Constructor Detail

Nativeback to summary
private Native()

Method Detail

blockingEventFdback to summary
private static native int blockingEventFd()
checkAllIOSupportedback to summary
pack-priv static void checkAllIOSupported(int ringFd)
checkKernelVersionback to summary
pack-priv static void checkKernelVersion(String kernelVersion)
checkKernelVersion0back to summary
private static boolean checkKernelVersion0(String kernelVersion)
cmsghdrDataback to summary
pack-priv static native long cmsghdrData(long hdrAddr)
createFileback to summary
pack-priv static native int createFile(String name)
createRingBufferback to summary
pack-priv static RingBuffer createRingBuffer(int ringSize)
createRingBufferback to summary
pack-priv static RingBuffer createRingBuffer(int ringSize, int iosqeAsyncThreshold)
createRingBufferback to summary
pack-priv static RingBuffer createRingBuffer()
eventFdWriteback to summary
pack-priv static native void eventFdWrite(int fd, long value)
ioUringEnterback to summary
pack-priv static native int ioUringEnter(int ringFd, int toSubmit, int minComplete, int flags)
ioUringExitback to summary
pack-priv static native void ioUringExit(long submissionQueueArrayAddress, int submissionQueueRingEntries, long submissionQueueRingAddress, int submissionQueueRingSize, long completionQueueRingAddress, int completionQueueRingSize, int ringFd)
ioUringProbeback to summary
private static native boolean ioUringProbe(int ringFd, int[] ios)
ioUringSetupback to summary
private static native long[][] ioUringSetup(int entries)
kernelVersionback to summary
pack-priv static native String kernelVersion()
loadNativeLibraryback to summary
private static void loadNativeLibrary()
newBlockingEventFdback to summary
pack-priv static FileDescriptor newBlockingEventFd()
registerUnixback to summary
private static native int registerUnix()
tcpFastopenModeback to summary
private static int tcpFastopenMode()