acceptStream() — netty Function Reference

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

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ acceptStream() — netty Function Reference

Dependency Diagram

graph TD
  1e0c440c_4db6_c649_af40_45384c42fcc7["acceptStream()"]
  d4117dfa_49b0_1937_8865_6887ed2ababf["SpdySession"]
  1e0c440c_4db6_c649_af40_45384c42fcc7 -->|defined in| d4117dfa_49b0_1937_8865_6887ed2ababf
  1115b459_503e_d9f7_1645_aefceb20efeb["StreamState()"]
  1e0c440c_4db6_c649_af40_45384c42fcc7 -->|calls| 1115b459_503e_d9f7_1645_aefceb20efeb
  style 1e0c440c_4db6_c649_af40_45384c42fcc7 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http/src/main/java/io/netty/handler/codec/spdy/SpdySession.java lines 67–81

    void acceptStream(
            int streamId, byte priority, boolean remoteSideClosed, boolean localSideClosed,
            int sendWindowSize, int receiveWindowSize, boolean remote) {
        if (!remoteSideClosed || !localSideClosed) {
            StreamState state = activeStreams.put(streamId, new StreamState(
                    priority, remoteSideClosed, localSideClosed, sendWindowSize, receiveWindowSize));
            if (state == null) {
                if (remote) {
                    activeRemoteStreams.incrementAndGet();
                } else {
                    activeLocalStreams.incrementAndGet();
                }
            }
        }
    }