scheduleRead0() — netty Function Reference

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringDatagramChannel.java lines 471–492

        @Override
        protected int scheduleRead0(boolean first, boolean socketIsEmpty) {
            final IoUringRecvByteAllocatorHandle allocHandle = recvBufAllocHandle();
            ByteBuf byteBuf = allocHandle.allocate(alloc());
            assert readBuffer == null;
            readBuffer = byteBuf;

            int writable = byteBuf.writableBytes();
            allocHandle.attemptedBytesRead(writable);
            int datagramSize = ((IoUringDatagramChannelConfig) config()).getMaxDatagramPayloadSize();

            int numDatagram = datagramSize == 0 ? 1 : Math.max(1, byteBuf.writableBytes() / datagramSize);

            int scheduled = scheduleRecvmsg(byteBuf, numDatagram, datagramSize);
            if (scheduled == 0) {
                // We could not schedule any recvmmsg so we need to release the buffer as there will be no
                // completion event.
                readBuffer = null;
                byteBuf.release();
            }
            return scheduled;
        }