removeAndFail() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ removeAndFail() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/PendingWriteQueue.java lines 207–219

    public void removeAndFail(Throwable cause) {
        assert executor.inEventLoop();
        ObjectUtil.checkNotNull(cause, "cause");

        PendingWrite write = head;
        if (write == null) {
            return;
        }
        ReferenceCountUtil.safeRelease(write.msg);
        ChannelPromise promise = write.promise;
        safeFail(promise, cause);
        recycle(write, true);
    }