ioUringEnter() — netty Function Reference

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/SubmissionQueue.java lines 285–309

    private int ioUringEnter(int toSubmit, int minComplete, int flags) {
        int f = enterFlags | flags;

        if (IoUring.isSetupSubmitAllSupported()) {
            return ioUringEnter0(toSubmit, minComplete, f);
        }
        // If IORING_SETUP_SUBMIT_ALL is not supported we need to loop until we submitted everything as
        // io_uring_enter(...) will stop submitting once the first inline executed submission fails.
        int submitted = 0;
        for (;;) {
            int ret = ioUringEnter0(toSubmit, minComplete, f);
            if (ret < 0) {
                return ret;
            }
            submitted += ret;
            if (ret == toSubmit) {
                return submitted;
            }
            if (logger.isTraceEnabled()) {
                // some submission might fail if these are done inline and failed.
                logger.trace("Not all submissions succeeded. Only {} of {} SQEs were submitted.", ret, toSubmit);
            }
            toSubmit -= ret;
        }
    }