addFlushedToZcWriteQueue() — netty Function Reference

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringSocketChannel.java lines 293–309

        private void addFlushedToZcWriteQueue(ChannelOutboundBuffer channelOutboundBuffer) throws Exception {
            // We expect another notification as handleWriteError(...) will fail all flushed writes
            // and also release any buffers we need to ensure we retain these buffers
            // so we can release these once we see IORING_CQE_F_NOTIF set.
            try {
                channelOutboundBuffer.forEachFlushedMessage(m -> {
                    if (!(m instanceof ByteBuf)) {
                        return false;
                    }
                    zcWriteQueue.add(m);
                    ((ByteBuf) m).retain();
                    return true;
                });
            } finally {
                zcWriteQueue.add(ZC_BATCH_MARKER);
            }
        }