PendingWrite() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ PendingWrite() — netty Function Reference

Dependency Diagram

graph TD
  032b8ad2_8f60_1b3c_6e7b_45c13f5ec8c9["PendingWrite()"]
  d4117dfa_49b0_1937_8865_6887ed2ababf["SpdySession"]
  032b8ad2_8f60_1b3c_6e7b_45c13f5ec8c9 -->|defined in| d4117dfa_49b0_1937_8865_6887ed2ababf
  bbdee975_a1f9_f99f_2ec4_5424a54aef39["activeStreams()"]
  032b8ad2_8f60_1b3c_6e7b_45c13f5ec8c9 -->|calls| bbdee975_a1f9_f99f_2ec4_5424a54aef39
  3bcbc20d_6da5_dffd_0ed3_b8024a177e7c["getSendWindowSize()"]
  032b8ad2_8f60_1b3c_6e7b_45c13f5ec8c9 -->|calls| 3bcbc20d_6da5_dffd_0ed3_b8024a177e7c
  style 032b8ad2_8f60_1b3c_6e7b_45c13f5ec8c9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http/src/main/java/io/netty/handler/codec/spdy/SpdySession.java lines 210–226

    PendingWrite getPendingWrite(int streamId) {
        if (streamId == SPDY_SESSION_STREAM_ID) {
            for (Map.Entry<Integer, StreamState> e: activeStreams().entrySet()) {
                StreamState state = e.getValue();
                if (state.getSendWindowSize() > 0) {
                    PendingWrite pendingWrite = state.getPendingWrite();
                    if (pendingWrite != null) {
                        return pendingWrite;
                    }
                }
            }
            return null;
        }

        StreamState state = activeStreams.get(streamId);
        return state != null ? state.getPendingWrite() : null;
    }