clearPendingWrites() — netty Function Reference

Architecture documentation for the clearPendingWrites() function in SpdySession.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 1

Entity Profile

Buffer→ Allocators→ clearPendingWrites() — netty Function Reference

Dependency Diagram

graph TD
  9fbaca2b_7eb1_9706_12ed_505983bf6091["clearPendingWrites()"]
  589a9899_b8db_cc45_ce79_726a13b35861["StreamState"]
  9fbaca2b_7eb1_9706_12ed_505983bf6091 -->|defined in| 589a9899_b8db_cc45_ce79_726a13b35861
  48a1dc18_fe14_9d35_318c_77ebe0be3e98["removeStream()"]
  48a1dc18_fe14_9d35_318c_77ebe0be3e98 -->|calls| 9fbaca2b_7eb1_9706_12ed_505983bf6091
  c50340b2_7a64_7155_357b_e1811d66e95e["fail()"]
  9fbaca2b_7eb1_9706_12ed_505983bf6091 -->|calls| c50340b2_7a64_7155_357b_e1811d66e95e
  style 9fbaca2b_7eb1_9706_12ed_505983bf6091 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http/src/main/java/io/netty/handler/codec/spdy/SpdySession.java lines 314–322

        void clearPendingWrites(Throwable cause) {
            for (;;) {
                PendingWrite pendingWrite = pendingWriteQueue.poll();
                if (pendingWrite == null) {
                    break;
                }
                pendingWrite.fail(cause);
            }
        }