failFlushed() — netty Function Reference

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

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ failFlushed() — netty Function Reference

Dependency Diagram

graph TD
  03cc489f_2713_64b1_01f8_eca6d57d3c3d["failFlushed()"]
  509b1bc5_7cdc_9ee4_03d9_31eb2203d807["ChannelOutboundBuffer"]
  03cc489f_2713_64b1_01f8_eca6d57d3c3d -->|defined in| 509b1bc5_7cdc_9ee4_03d9_31eb2203d807
  cd969e8c_0b55_2177_ee6c_1c15a5b3292f["remove0()"]
  03cc489f_2713_64b1_01f8_eca6d57d3c3d -->|calls| cd969e8c_0b55_2177_ee6c_1c15a5b3292f
  style 03cc489f_2713_64b1_01f8_eca6d57d3c3d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java lines 677–697

    void failFlushed(Throwable cause, boolean notify) {
        // Make sure that this method does not reenter.  A listener added to the current promise can be notified by the
        // current thread in the tryFailure() call of the loop below, and the listener can trigger another fail() call
        // indirectly (usually by closing the channel.)
        //
        // See https://github.com/netty/netty/issues/1501
        if (inFail) {
            return;
        }

        try {
            inFail = true;
            for (;;) {
                if (!remove0(cause, notify)) {
                    break;
                }
            }
        } finally {
            inFail = false;
        }
    }