closeStreams() — netty Function Reference

Architecture documentation for the closeStreams() function in QuicheQuicChannel.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 1

Entity Profile

Buffer→ Allocators→ closeStreams() — netty Function Reference

Dependency Diagram

graph TD
  d9ba5745_6917_1f04_889e_f4c2676bfdbb["closeStreams()"]
  3c534d05_bb5b_c991_5e03_7ec94e739cf7["QuicheQuicChannel"]
  d9ba5745_6917_1f04_889e_f4c2676bfdbb -->|defined in| 3c534d05_bb5b_c991_5e03_7ec94e739cf7
  d09a66fb_105e_24b9_4756_bb03a3f780fa["doClose()"]
  d09a66fb_105e_24b9_4756_bb03a3f780fa -->|calls| d9ba5745_6917_1f04_889e_f4c2676bfdbb
  06c11b43_b6ba_8483_0d22_78982d8c399e["isTimedOut()"]
  d9ba5745_6917_1f04_889e_f4c2676bfdbb -->|calls| 06c11b43_b6ba_8483_0d22_78982d8c399e
  style d9ba5745_6917_1f04_889e_f4c2676bfdbb fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/QuicheQuicChannel.java lines 804–821

    private void closeStreams() {
        if (streams.isEmpty()) {
            return;
        }
        final ClosedChannelException closedChannelException;
        if (isTimedOut()) {
            // Close the streams because of a timeout.
            closedChannelException = new QuicTimeoutClosedChannelException();
        } else {
            closedChannelException = new ClosedChannelException();
        }
        // Make a copy to ensure we not run into a situation when we change the underlying iterator from
        // another method and so run in an assert error.
        for (QuicheQuicStreamChannel stream: streams.values().toArray(new QuicheQuicStreamChannel[0])) {
            stream.unsafe().close(closedChannelException, voidPromise());
        }
        streams.clear();
    }