submitAndWaitWithTimeout() — netty Function Reference

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringIoHandler.java lines 312–342

    private int submitAndWaitWithTimeout(SubmissionQueue submissionQueue,
                                         boolean linkTimeout, long timeoutNanoSeconds) {
        if (timeoutNanoSeconds != -1) {
            long udata = UserData.encode(RINGFD_ID,
                    linkTimeout ? Native.IORING_OP_LINK_TIMEOUT : Native.IORING_OP_TIMEOUT, (short) 0);
            // We use the same timespec pointer for all add*Timeout operations. This only works because we call
            // submit directly after it. This ensures the submitted timeout is considered "stable" and so can be reused.
            long seconds, nanoSeconds;
            if (timeoutNanoSeconds == 0) {
                seconds = 0;
                nanoSeconds = 0;
            } else {
                seconds = (int) min(timeoutNanoSeconds / 1000000000L, Integer.MAX_VALUE);
                nanoSeconds = (int) max(timeoutNanoSeconds - seconds * 1000000000L, 0);
            }

            timeoutMemory.putLong(KERNEL_TIMESPEC_TV_SEC_FIELD, seconds);
            timeoutMemory.putLong(KERNEL_TIMESPEC_TV_NSEC_FIELD, nanoSeconds);
            if (linkTimeout) {
                submissionQueue.addLinkTimeout(timeoutMemoryAddress, udata);
            } else {
                submissionQueue.addTimeout(timeoutMemoryAddress, udata);
            }
        }
        int submitted = submissionQueue.submitAndGet();
        // Clear the iovArray as we can re-use it now as things are considered stable after submission:
        // See https://man7.org/linux/man-pages/man3/io_uring_prep_sendmsg.3.html
        iovArray.clear();
        msgHdrMemoryArray.clear();
        return submitted;
    }