scheduleRead0() — netty Function Reference

Source Code

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

        @Override
        protected int scheduleRead0(boolean first, boolean socketIsEmpty) {
            assert readBuffer == null;
            assert readId == 0 : readId;
            final IoUringRecvByteAllocatorHandle allocHandle = recvBufAllocHandle();

            if (bufferRing != null && bufferRing.isUsable()) {
                return scheduleReadProviderBuffer(bufferRing, first, socketIsEmpty);
            }

            // We either have no buffer ring configured or we force a recv without using a buffer ring.
            ByteBuf byteBuf = allocHandle.allocate(alloc());
            try {
                int fd = fd().intValue();
                IoRegistration registration = registration();
                short ioPrio = calculateRecvIoPrio(first, socketIsEmpty);
                int recvFlags = calculateRecvFlags(first);

                IoUringIoOps ops = IoUringIoOps.newRecv(fd, (byte) 0, ioPrio, recvFlags,
                        IoUring.memoryAddress(byteBuf) + byteBuf.writerIndex(), byteBuf.writableBytes(), nextOpsId());
                readId = registration.submit(ops);
                readOpCode = Native.IORING_OP_RECV;
                if (readId == 0) {
                    return 0;
                }
                readBuffer = byteBuf;
                byteBuf = null;
                return 1;
            } finally {
                if (byteBuf != null) {
                    byteBuf.release();
                }
            }
        }