Package io.netty.incubator.channel.uring
Class IOUringSubmissionQueue
java.lang.Object
io.netty.incubator.channel.uring.IOUringSubmissionQueue
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate int
private static final int
private final int
private final long
private final long
private static final int
private static final int
private static final int
private final long
private final long
private final long
private static final io.netty.util.internal.logging.InternalLogger
private int
(package private) final long
(package private) final int
(package private) final int
private final int
(package private) final int
private static final int
private static final int
private static final int
private static final int
private static final int
private static final int
private static final int
private static final int
private static final int
private static final long
private static final int
(package private) final long
private int
private final long
-
Constructor Summary
ConstructorsConstructorDescriptionIOUringSubmissionQueue
(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 TypeMethodDescription(package private) boolean
addAccept
(int fd, long address, long addressLength, short extraData) (package private) boolean
addClose
(int fd, short extraData) (package private) boolean
addConnect
(int fd, long socketAddress, long socketAddressLength, short extraData) (package private) boolean
addEventFdRead
(int fd, long bufferAddress, int pos, int limit, short extraData) private boolean
addPoll
(int fd, int pollMask) (package private) boolean
addPollIn
(int fd) (package private) boolean
addPollOut
(int fd) (package private) boolean
addPollRdHup
(int fd) (package private) boolean
addPollRemove
(int fd, int pollMask) (package private) boolean
addRead
(int fd, long bufferAddress, int pos, int limit, short extraData) (package private) boolean
addRecv
(int fd, long bufferAddress, int pos, int limit, short extraData) (package private) boolean
addRecvmsg
(int fd, long msgHdr, short extraData) (package private) boolean
addSend
(int fd, long bufferAddress, int pos, int limit, short extraData) (package private) boolean
addSendmsg
(int fd, long msgHdr, int flags, short extraData) (package private) boolean
addSendmsg
(int fd, long msgHdr, short extraData) (package private) boolean
addTimeout
(long nanoSeconds, short extraData) (package private) boolean
addWrite
(int fd, long bufferAddress, int pos, int limit, short extraData) (package private) boolean
addWritev
(int fd, long iovecArrayAddress, int length, short extraData) long
count()
(package private) void
(package private) boolean
enqueueSqe
(byte op, int flags, int rwFlags, int fd, long bufferAddress, int length, long offset, short data) private int
flags()
(package private) void
void
release()
(package private) 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) (package private) int
submit()
private int
submit
(int toSubmit, int minComplete, int flags) (package private) int
-
Field Details
-
logger
private static final io.netty.util.internal.logging.InternalLogger logger -
SQE_SIZE
private static final long SQE_SIZE- See Also:
-
INT_SIZE
private static final int INT_SIZE- See Also:
-
KERNEL_TIMESPEC_SIZE
private static final int KERNEL_TIMESPEC_SIZE- See Also:
-
SQE_OP_CODE_FIELD
private static final int SQE_OP_CODE_FIELD- See Also:
-
SQE_FLAGS_FIELD
private static final int SQE_FLAGS_FIELD- See Also:
-
SQE_IOPRIO_FIELD
private static final int SQE_IOPRIO_FIELD- See Also:
-
SQE_FD_FIELD
private static final int SQE_FD_FIELD- See Also:
-
SQE_OFFSET_FIELD
private static final int SQE_OFFSET_FIELD- See Also:
-
SQE_ADDRESS_FIELD
private static final int SQE_ADDRESS_FIELD- See Also:
-
SQE_LEN_FIELD
private static final int SQE_LEN_FIELD- See Also:
-
SQE_RW_FLAGS_FIELD
private static final int SQE_RW_FLAGS_FIELD- See Also:
-
SQE_USER_DATA_FIELD
private static final int SQE_USER_DATA_FIELD- See Also:
-
SQE_PAD_FIELD
private static final int SQE_PAD_FIELD- See Also:
-
KERNEL_TIMESPEC_TV_SEC_FIELD
private static final int KERNEL_TIMESPEC_TV_SEC_FIELD- See Also:
-
KERNEL_TIMESPEC_TV_NSEC_FIELD
private static final int KERNEL_TIMESPEC_TV_NSEC_FIELD- See Also:
-
kHeadAddress
private final long kHeadAddress -
kTailAddress
private final long kTailAddress -
kFlagsAddress
private final long kFlagsAddress -
kDroppedAddress
private final long kDroppedAddress -
kArrayAddress
private final long kArrayAddress -
submissionQueueArrayAddress
final long submissionQueueArrayAddress -
ringEntries
final int ringEntries -
ringMask
private final int ringMask -
ringSize
final int ringSize -
ringAddress
final long ringAddress -
ringFd
final int ringFd -
timeoutMemoryAddress
private final long timeoutMemoryAddress -
iosqeAsyncThreshold
private final int iosqeAsyncThreshold -
numHandledFds
private int numHandledFds -
head
private int head -
tail
private int tail
-
-
Constructor Details
-
IOUringSubmissionQueue
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 Details
-
incrementHandledFds
void incrementHandledFds() -
decrementHandledFds
void decrementHandledFds() -
flags
private int flags() -
enqueueSqe
boolean enqueueSqe(byte op, int flags, int rwFlags, int fd, long bufferAddress, int length, long offset, short data) -
setData
private void setData(long sqe, byte op, int flags, int rwFlags, int fd, long bufferAddress, int length, long offset, short data) -
addTimeout
boolean addTimeout(long nanoSeconds, short extraData) -
removeTimeout
boolean removeTimeout(short extraData) -
addPollIn
boolean addPollIn(int fd) -
addPollRdHup
boolean addPollRdHup(int fd) -
addPollOut
boolean addPollOut(int fd) -
addPoll
private boolean addPoll(int fd, int pollMask) -
addRecvmsg
boolean addRecvmsg(int fd, long msgHdr, short extraData) -
addSendmsg
boolean addSendmsg(int fd, long msgHdr, short extraData) -
addSendmsg
boolean addSendmsg(int fd, long msgHdr, int flags, short extraData) -
addRead
boolean addRead(int fd, long bufferAddress, int pos, int limit, short extraData) -
addEventFdRead
boolean addEventFdRead(int fd, long bufferAddress, int pos, int limit, short extraData) -
addWrite
boolean addWrite(int fd, long bufferAddress, int pos, int limit, short extraData) -
addRecv
boolean addRecv(int fd, long bufferAddress, int pos, int limit, short extraData) -
addSend
boolean addSend(int fd, long bufferAddress, int pos, int limit, short extraData) -
addAccept
boolean addAccept(int fd, long address, long addressLength, short extraData) -
addPollRemove
boolean addPollRemove(int fd, int pollMask) -
addConnect
boolean addConnect(int fd, long socketAddress, long socketAddressLength, short extraData) -
addWritev
boolean addWritev(int fd, long iovecArrayAddress, int length, short extraData) -
addClose
boolean addClose(int fd, short extraData) -
submit
int submit() -
submitAndWait
int submitAndWait() -
submit
private int submit(int toSubmit, int minComplete, int flags) -
setTimeout
private void setTimeout(long timeoutNanoSeconds) -
count
public long count() -
release
public void release()
-