recycle() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 5

Entity Profile

Buffer→ Telemetry→ recycle() — netty Function Reference

Dependency Diagram

graph TD
  d80642d8_7dc6_939b_e48a_94fa31dc8c25["recycle()"]
  83722386_341f_50b9_cd3a_d141138801ae["PendingWriteQueue"]
  d80642d8_7dc6_939b_e48a_94fa31dc8c25 -->|defined in| 83722386_341f_50b9_cd3a_d141138801ae
  fdae4bff_68f1_815f_aa14_f77607b86568["recycle()"]
  fdae4bff_68f1_815f_aa14_f77607b86568 -->|calls| d80642d8_7dc6_939b_e48a_94fa31dc8c25
  58e262d9_3782_2194_e391_e963af8a705d["ChannelFuture()"]
  58e262d9_3782_2194_e391_e963af8a705d -->|calls| d80642d8_7dc6_939b_e48a_94fa31dc8c25
  9465da28_383b_e0f3_4e91_d1dcedaa5bdf["removeAndFailAll()"]
  9465da28_383b_e0f3_4e91_d1dcedaa5bdf -->|calls| d80642d8_7dc6_939b_e48a_94fa31dc8c25
  f0f44ded_1e1e_19f3_602d_994b28cd58fb["removeAndFail()"]
  f0f44ded_1e1e_19f3_602d_994b28cd58fb -->|calls| d80642d8_7dc6_939b_e48a_94fa31dc8c25
  a74a1023_8945_1782_ee15_7f4896283503["ChannelPromise()"]
  a74a1023_8945_1782_ee15_7f4896283503 -->|calls| d80642d8_7dc6_939b_e48a_94fa31dc8c25
  fdae4bff_68f1_815f_aa14_f77607b86568["recycle()"]
  d80642d8_7dc6_939b_e48a_94fa31dc8c25 -->|calls| fdae4bff_68f1_815f_aa14_f77607b86568
  style d80642d8_7dc6_939b_e48a_94fa31dc8c25 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/PendingWriteQueue.java lines 274–295

    private void recycle(PendingWrite write, boolean update) {
        final PendingWrite next = write.next;
        final long writeSize = write.size;

        if (update) {
            if (next == null) {
                // Handled last PendingWrite so rest head and tail
                // Guard against re-entrance by directly reset
                head = tail = null;
                size = 0;
                bytes = 0;
            } else {
                head = next;
                size --;
                bytes -= writeSize;
                assert size > 0 && bytes >= 0;
            }
        }

        write.recycle();
        tracker.decrementPendingOutboundBytes(writeSize);
    }