safeFail() — netty Function Reference

Architecture documentation for the safeFail() function in PendingWriteQueue.java from the netty codebase.

Function java Buffer Search called by 2

Entity Profile

Buffer→ Search→ safeFail() — netty Function Reference

Dependency Diagram

graph TD
  a93247f6_033b_6516_d4f0_786bf935f89e["safeFail()"]
  83722386_341f_50b9_cd3a_d141138801ae["PendingWriteQueue"]
  a93247f6_033b_6516_d4f0_786bf935f89e -->|defined in| 83722386_341f_50b9_cd3a_d141138801ae
  9465da28_383b_e0f3_4e91_d1dcedaa5bdf["removeAndFailAll()"]
  9465da28_383b_e0f3_4e91_d1dcedaa5bdf -->|calls| a93247f6_033b_6516_d4f0_786bf935f89e
  f0f44ded_1e1e_19f3_602d_994b28cd58fb["removeAndFail()"]
  f0f44ded_1e1e_19f3_602d_994b28cd58fb -->|calls| a93247f6_033b_6516_d4f0_786bf935f89e
  style a93247f6_033b_6516_d4f0_786bf935f89e fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/PendingWriteQueue.java lines 297–301

    private static void safeFail(ChannelPromise promise, Throwable cause) {
        if (!(promise instanceof VoidChannelPromise) && !promise.tryFailure(cause)) {
            logger.warn("Failed to mark a promise as failure because it's done already: {}", promise, cause);
        }
    }