run() — netty Function Reference

Source Code

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

    @Override
    public int run(IoHandlerContext context) {
        if (closeCompleted) {
            if (context.shouldReportActiveIoTime()) {
                context.reportActiveIoTime(0);
            }
            return 0;
        }
        SubmissionQueue submissionQueue = ringBuffer.ioUringSubmissionQueue();
        CompletionQueue completionQueue = ringBuffer.ioUringCompletionQueue();
        if (!completionQueue.hasCompletions() && context.canBlock()) {
            if (eventfdReadSubmitted == 0) {
                submitEventFdRead();
            }
            long timeoutNanos = context.deadlineNanos() == -1 ? -1 : context.delayNanos(System.nanoTime());
            submitAndWaitWithTimeout(submissionQueue, false, timeoutNanos);
        } else {
            // Even if we have some completions already pending we can still try to even fetch more.
            submitAndClearNow(submissionQueue);
        }

        int processed;
        if (context.shouldReportActiveIoTime()) {
            // Timer starts after the blocking wait, around the processing of completions.
            long activeIoStartTimeNanos = System.nanoTime();
            processed = processCompletionsAndHandleOverflow(submissionQueue, completionQueue, this::handle);
            long activeIoEndTimeNanos = System.nanoTime();
            context.reportActiveIoTime(activeIoEndTimeNanos - activeIoStartTimeNanos);
        } else {
            processed = processCompletionsAndHandleOverflow(submissionQueue, completionQueue, this::handle);
        }
        return processed;
    }