Class IOUringSubmissionQueue


  • final class IOUringSubmissionQueue
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      Constructor Description
      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

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      (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 decrementHandledFds()  
      (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 incrementHandledFds()  
      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 submitAndWait()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • logger

        private static final io.netty.util.internal.logging.InternalLogger logger
      • KERNEL_TIMESPEC_TV_SEC_FIELD

        private static final int KERNEL_TIMESPEC_TV_SEC_FIELD
        See Also:
        Constant Field Values
      • KERNEL_TIMESPEC_TV_NSEC_FIELD

        private static final int KERNEL_TIMESPEC_TV_NSEC_FIELD
        See Also:
        Constant Field Values
      • 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 Detail

      • 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 Detail

      • 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()