addFlush() — netty Function Reference

Architecture documentation for the addFlush() function in ChannelOutboundBuffer.java from the netty codebase.

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ addFlush() — netty Function Reference

Dependency Diagram

graph TD
  064bcac5_7f92_8d78_e146_94926c257464["addFlush()"]
  509b1bc5_7cdc_9ee4_03d9_31eb2203d807["ChannelOutboundBuffer"]
  064bcac5_7f92_8d78_e146_94926c257464 -->|defined in| 509b1bc5_7cdc_9ee4_03d9_31eb2203d807
  857fc3b4_246b_e6ea_c28f_4628ee8724a7["cancel()"]
  064bcac5_7f92_8d78_e146_94926c257464 -->|calls| 857fc3b4_246b_e6ea_c28f_4628ee8724a7
  9442861d_ae43_c572_95ea_8e92ddbb709f["decrementPendingOutboundBytes()"]
  064bcac5_7f92_8d78_e146_94926c257464 -->|calls| 9442861d_ae43_c572_95ea_8e92ddbb709f
  style 064bcac5_7f92_8d78_e146_94926c257464 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java lines 146–170

    public void addFlush() {
        // There is no need to process all entries if there was already a flush before and no new messages
        // where added in the meantime.
        //
        // See https://github.com/netty/netty/issues/2577
        Entry entry = unflushedEntry;
        if (entry != null) {
            if (flushedEntry == null) {
                // there is no flushedEntry yet, so start with the entry
                flushedEntry = entry;
            }
            do {
                flushed ++;
                if (!entry.promise.setUncancellable()) {
                    // Was cancelled so make sure we free up memory and notify about the freed bytes
                    int pending = entry.cancel();
                    decrementPendingOutboundBytes(pending, false, true);
                }
                entry = entry.next;
            } while (entry != null);

            // All flushed so reset unflushedEntry
            unflushedEntry = null;
        }
    }