streamCancellation() — netty Function Reference

Architecture documentation for the streamCancellation() function in QpackEncoder.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ streamCancellation() — netty Function Reference

Dependency Diagram

graph TD
  554804fb_ef2d_c20a_03d3_e86785605525["streamCancellation()"]
  9e578dbc_12be_4439_554b_24e265961ea5["QpackEncoder"]
  554804fb_ef2d_c20a_03d3_e86785605525 -->|defined in| 9e578dbc_12be_4439_554b_24e265961ea5
  1d867d55_ac46_d432_63e0_92c3e1f26137["configureDynamicTable()"]
  554804fb_ef2d_c20a_03d3_e86785605525 -->|calls| 1d867d55_ac46_d432_63e0_92c3e1f26137
  70504f22_8dde_e329_ac4d_a33cfef182b5["forEach()"]
  554804fb_ef2d_c20a_03d3_e86785605525 -->|calls| 70504f22_8dde_e329_ac4d_a33cfef182b5
  style 554804fb_ef2d_c20a_03d3_e86785605525 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http3/src/main/java/io/netty/handler/codec/http3/QpackEncoder.java lines 168–185

    void streamCancellation(long streamId) throws QpackException {
        // If a configureDynamicTable(...) was called with a maxTableCapacity of 0 we will have not instanced
        // streamSectionTrackers. The remote peer might still send a stream cancellation for a stream, while it
        // is optional. See https://www.rfc-editor.org/rfc/rfc9204.html#section-2.2.2.2
        if (streamSectionTrackers == null) {
            return;
        }
        final Queue<Indices> tracker = streamSectionTrackers.remove(streamId);
        if (tracker != null) {
            for (;;) {
                Indices dynamicTableIndices = tracker.poll();
                if (dynamicTableIndices == null) {
                    break;
                }
                dynamicTableIndices.forEach(dynamicTable::acknowledgeInsertCountOnCancellation);
            }
        }
    }