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

pack-priv final Class IOUringSubmissionQueue

extends Object
Class Inheritance
Imports
io.netty.util.internal.PlatformDependent, io.netty.util.internal.logging.InternalLogger, .InternalLoggerFactory

Field Summary

Modifier and TypeField and Description
private int
head

private static final int
INT_SIZE

private final int
iosqeAsyncThreshold

private final long
kArrayAddress

private final long
kDroppedAddress

private static final int
KERNEL_TIMESPEC_SIZE

private static final int
KERNEL_TIMESPEC_TV_NSEC_FIELD

private static final int
KERNEL_TIMESPEC_TV_SEC_FIELD

private final long
kFlagsAddress

private final long
kHeadAddress

private final long
kTailAddress

private static final InternalLogger
logger

private int
numHandledFds

pack-priv final long
ringAddress

pack-priv final int
ringEntries

pack-priv final int
ringFd

private final int
ringMask

pack-priv final int
ringSize

private static final int
SQE_ADDRESS_FIELD

private static final int
SQE_FD_FIELD

private static final int
SQE_FLAGS_FIELD

private static final int
SQE_IOPRIO_FIELD

private static final int
SQE_LEN_FIELD

private static final int
SQE_OFFSET_FIELD

private static final int
SQE_OP_CODE_FIELD

private static final int
SQE_PAD_FIELD

private static final int
SQE_RW_FLAGS_FIELD

private static final long
SQE_SIZE

private static final int
SQE_USER_DATA_FIELD

pack-priv final long
submissionQueueArrayAddress

private int
tail

private final long
timeoutMemoryAddress

Constructor Summary

AccessConstructor and Description
pack-priv
IOUringSubmissionQueue(long kHeadAddress, long kTailAddress, long kRingMaskAddress, long kRingEntriesAddress, long kFlagsAddress, long kDroppedAddress, long kArrayAddress, long submissionQueueArrayAddress, int ringSize, long ringAddress, int ringFd, int iosqeAsyncThreshold)

Method Summary

Modifier and TypeMethod and Description
pack-priv boolean
addAccept(int fd, long address, long addressLength, short extraData)

pack-priv boolean
addClose(int fd, short extraData)

pack-priv boolean
addConnect(int fd, long socketAddress, long socketAddressLength, short extraData)

pack-priv boolean
addEventFdRead(int fd, long bufferAddress, int pos, int limit, short extraData)

private boolean
addPoll(int fd, int pollMask)

pack-priv boolean
addPollIn(int fd)

pack-priv boolean
addPollOut(int fd)

pack-priv boolean
addPollRdHup(int fd)

pack-priv boolean
addPollRemove(int fd, int pollMask)

pack-priv boolean
addRead(int fd, long bufferAddress, int pos, int limit, short extraData)

pack-priv boolean
addRecv(int fd, long bufferAddress, int pos, int limit, short extraData)

pack-priv boolean
addRecvmsg(int fd, long msgHdr, short extraData)

pack-priv boolean
addSend(int fd, long bufferAddress, int pos, int limit, short extraData)

pack-priv boolean
addSendmsg(int fd, long msgHdr, short extraData)

pack-priv boolean
addSendmsg(int fd, long msgHdr, int flags, short extraData)

pack-priv boolean
addTimeout(long nanoSeconds, short extraData)

pack-priv boolean
addWrite(int fd, long bufferAddress, int pos, int limit, short extraData)

pack-priv boolean
addWritev(int fd, long iovecArrayAddress, int length, short extraData)

public long
count()

pack-priv void
decrementHandledFds()

pack-priv boolean
enqueueSqe(byte op, int flags, int rwFlags, int fd, long bufferAddress, int length, long offset, short data)

private int
flags()

pack-priv void
incrementHandledFds()

public void
release()

pack-priv boolean
removeTimeout(short extraData)

private void
setData(long sqe, byte op, int flags, int rwFlags, int fd, long bufferAddress, int length, long offset, short data)

private void
setTimeout(long timeoutNanoSeconds)

pack-priv int
submit()

private int
submit(int toSubmit, int minComplete, int flags)

pack-priv int
submitAndWait()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

INT_SIZEback to summary
private static final int INT_SIZE
iosqeAsyncThresholdback to summary
private final int iosqeAsyncThreshold
kArrayAddressback to summary
private final long kArrayAddress
kDroppedAddressback to summary
private final long kDroppedAddress
KERNEL_TIMESPEC_SIZEback to summary
private static final int KERNEL_TIMESPEC_SIZE
KERNEL_TIMESPEC_TV_NSEC_FIELDback to summary
private static final int KERNEL_TIMESPEC_TV_NSEC_FIELD
KERNEL_TIMESPEC_TV_SEC_FIELDback to summary
private static final int KERNEL_TIMESPEC_TV_SEC_FIELD
kFlagsAddressback to summary
private final long kFlagsAddress
kHeadAddressback to summary
private final long kHeadAddress
kTailAddressback to summary
private final long kTailAddress
loggerback to summary
private static final InternalLogger logger
numHandledFdsback to summary
private int numHandledFds
ringAddressback to summary
pack-priv final long ringAddress
ringEntriesback to summary
pack-priv final int ringEntries
ringFdback to summary
pack-priv final int ringFd
ringMaskback to summary
private final int ringMask
ringSizeback to summary
pack-priv final int ringSize
SQE_ADDRESS_FIELDback to summary
private static final int SQE_ADDRESS_FIELD
SQE_FD_FIELDback to summary
private static final int SQE_FD_FIELD
SQE_FLAGS_FIELDback to summary
private static final int SQE_FLAGS_FIELD
SQE_IOPRIO_FIELDback to summary
private static final int SQE_IOPRIO_FIELD
SQE_LEN_FIELDback to summary
private static final int SQE_LEN_FIELD
SQE_OFFSET_FIELDback to summary
private static final int SQE_OFFSET_FIELD
SQE_OP_CODE_FIELDback to summary
private static final int SQE_OP_CODE_FIELD
SQE_PAD_FIELDback to summary
private static final int SQE_PAD_FIELD
SQE_RW_FLAGS_FIELDback to summary
private static final int SQE_RW_FLAGS_FIELD
SQE_SIZEback to summary
private static final long SQE_SIZE
SQE_USER_DATA_FIELDback to summary
private static final int SQE_USER_DATA_FIELD
submissionQueueArrayAddressback to summary
pack-priv final long submissionQueueArrayAddress
tailback to summary
private int tail
timeoutMemoryAddressback to summary
private final long timeoutMemoryAddress

Constructor Detail

IOUringSubmissionQueueback to summary
pack-priv IOUringSubmissionQueue(long kHeadAddress, long kTailAddress, long kRingMaskAddress, long kRingEntriesAddress, long kFlagsAddress, long kDroppedAddress, long kArrayAddress, long submissionQueueArrayAddress, int ringSize, long ringAddress, int ringFd, int iosqeAsyncThreshold)

Method Detail

addAcceptback to summary
pack-priv boolean addAccept(int fd, long address, long addressLength, short extraData)
addCloseback to summary
pack-priv boolean addClose(int fd, short extraData)
addConnectback to summary
pack-priv boolean addConnect(int fd, long socketAddress, long socketAddressLength, short extraData)
addEventFdReadback to summary
pack-priv boolean addEventFdRead(int fd, long bufferAddress, int pos, int limit, short extraData)
addPollback to summary
private boolean addPoll(int fd, int pollMask)
addPollInback to summary
pack-priv boolean addPollIn(int fd)
addPollOutback to summary
pack-priv boolean addPollOut(int fd)
addPollRdHupback to summary
pack-priv boolean addPollRdHup(int fd)
addPollRemoveback to summary
pack-priv boolean addPollRemove(int fd, int pollMask)
addReadback to summary
pack-priv boolean addRead(int fd, long bufferAddress, int pos, int limit, short extraData)
addRecvback to summary
pack-priv boolean addRecv(int fd, long bufferAddress, int pos, int limit, short extraData)
addRecvmsgback to summary
pack-priv boolean addRecvmsg(int fd, long msgHdr, short extraData)
addSendback to summary
pack-priv boolean addSend(int fd, long bufferAddress, int pos, int limit, short extraData)
addSendmsgback to summary
pack-priv boolean addSendmsg(int fd, long msgHdr, short extraData)
addSendmsgback to summary
pack-priv boolean addSendmsg(int fd, long msgHdr, int flags, short extraData)
addTimeoutback to summary
pack-priv boolean addTimeout(long nanoSeconds, short extraData)
addWriteback to summary
pack-priv boolean addWrite(int fd, long bufferAddress, int pos, int limit, short extraData)
addWritevback to summary
pack-priv boolean addWritev(int fd, long iovecArrayAddress, int length, short extraData)
countback to summary
public long count()
decrementHandledFdsback to summary
pack-priv void decrementHandledFds()
enqueueSqeback to summary
pack-priv boolean enqueueSqe(byte op, int flags, int rwFlags, int fd, long bufferAddress, int length, long offset, short data)
flagsback to summary
private int flags()
incrementHandledFdsback to summary
pack-priv void incrementHandledFds()
releaseback to summary
public void release()
removeTimeoutback to summary
pack-priv boolean removeTimeout(short extraData)
setDataback to summary
private void setData(long sqe, byte op, int flags, int rwFlags, int fd, long bufferAddress, int length, long offset, short data)
setTimeoutback to summary
private void setTimeout(long timeoutNanoSeconds)
submitback to summary
pack-priv int submit()
submitback to summary
private int submit(int toSubmit, int minComplete, int flags)
submitAndWaitback to summary
pack-priv int submitAndWait()