scheduleRecvmsg0() — netty Function Reference

Source Code

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

        private boolean scheduleRecvmsg0(long bufferAddress, int bufferLength, boolean first) {
            MsgHdrMemory msgHdrMemory = recvmsgHdrs.nextHdr();
            if (msgHdrMemory == null) {
                // We can not continue reading before we did not submit the recvmsg(s) and received the results.
                return false;
            }
            msgHdrMemory.set(socket, null, bufferAddress, bufferLength, (short) 0);

            int fd = fd().intValue();
            int msgFlags = first ? 0 : Native.MSG_DONTWAIT;
            IoRegistration registration = registration();
            // We always use idx here so we can detect if no idx was used by checking if data < 0 in
            // readComplete0(...)
            IoUringIoOps ops = IoUringIoOps.newRecvmsg(
                    fd, (byte) 0, msgFlags, msgHdrMemory.address(), msgHdrMemory.idx());
            long id = registration.submit(ops);
            if (id == 0) {
                // Submission failed we don't used the MsgHdrMemory and so should give it back.
                recvmsgHdrs.restoreNextHdr(msgHdrMemory);
                return false;
            }
            recvmsgHdrs.setId(msgHdrMemory.idx(), id);
            return true;
        }