scheduleReadProviderBuffer() — netty Function Reference

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringStreamChannel.java lines 366–407

        private int scheduleReadProviderBuffer(IoUringBufferRing bufferRing, boolean first, boolean socketIsEmpty) {
            short bgId = bufferRing.bufferGroupId();
            try {
                boolean multishot = IoUring.isRecvMultishotEnabled();
                byte flags = (byte) Native.IOSQE_BUFFER_SELECT;
                short ioPrio;
                final int recvFlags;
                if (multishot) {
                    ioPrio = Native.IORING_RECV_MULTISHOT;
                    recvFlags = 0;
                } else {
                    // We should only use the calculate*() methods if this is not a multishot recv, as otherwise
                    // the would be applied until the multishot will be re-armed.
                    ioPrio = calculateRecvIoPrio(first, socketIsEmpty);
                    recvFlags = calculateRecvFlags(first);
                }
                if (IoUring.isRecvsendBundleEnabled()) {
                    // See https://github.com/axboe/liburing/wiki/
                    // What's-new-with-io_uring-in-6.10#add-support-for-sendrecv-bundles
                    ioPrio |= Native.IORING_RECVSEND_BUNDLE;
                }
                IoRegistration registration = registration();
                int fd = fd().intValue();
                IoUringIoOps ops = IoUringIoOps.newRecv(
                        fd, flags, ioPrio, recvFlags, 0,
                        0, nextOpsId(), bgId
                );
                readId = registration.submit(ops);
                readOpCode = Native.IORING_OP_RECV;
                if (readId == 0) {
                    return 0;
                }
                if (multishot) {
                    // Return -1 to signal we used multishot and so expect multiple recvComplete(...) calls.
                    return -1;
                }
                return 1;
            } catch (IllegalArgumentException illegalArgumentException) {
                this.handleReadException(pipeline(), null, illegalArgumentException, false, recvBufAllocHandle());
                return 0;
            }
        }