writeComplete0() — netty Function Reference

Source Code

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

        @Override
        boolean writeComplete0(byte op, int res, int flags, short data, int outstanding) {
            ChannelOutboundBuffer outboundBuffer = outboundBuffer();

            // Reset the id as this write was completed and so don't need to be cancelled later.
            sendmsgHdrs.setId(data, MsgHdrMemoryArray.NO_ID);
            sendmsgResArray[data] = res;
            // Store the result so we can handle it as soon as we have no outstanding writes anymore.
            if (outstanding == 0) {
                // All writes are done as part of a batch. Let's remove these from the ChannelOutboundBuffer
                boolean writtenSomething = false;
                int numWritten = sendmsgHdrs.length();
                sendmsgHdrs.clear();
                for (int i = 0; i < numWritten; i++) {
                    writtenSomething |= removeFromOutboundBuffer(
                            outboundBuffer, sendmsgResArray[i], "io_uring sendmsg");
                }
                return writtenSomething;
            }
            return true;
        }