scheduleSendmsg() — netty Function Reference

Source Code

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

        private boolean scheduleSendmsg(InetSocketAddress remoteAddress, long bufferAddress,
                                        int bufferLength, int segmentSize, boolean first) {
            MsgHdrMemory hdr = sendmsgHdrs.nextHdr();
            if (hdr == null) {
                // There is no MsgHdrMemory left to use. We need to submit and wait for the writes to complete
                // before we can write again.
                return false;
            }
            hdr.set(socket, remoteAddress, bufferAddress, bufferLength, (short) segmentSize);

            int fd = fd().intValue();
            int msgFlags = first ? 0 : Native.MSG_DONTWAIT;
            IoRegistration registration = registration();
            IoUringIoOps ops = IoUringIoOps.newSendmsg(fd, (byte) 0, msgFlags, hdr.address(), hdr.idx());
            long id = registration.submit(ops);
            if (id == 0) {
                // Submission failed we don't used the MsgHdrMemory and so should give it back.
                sendmsgHdrs.restoreNextHdr(hdr);
                return false;
            }
            sendmsgHdrs.setId(hdr.idx(), id);
            return true;
        }