streamSendFin() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ streamSendFin() — netty Function Reference

Dependency Diagram

graph TD
  4b35c56c_b5f6_95d5_5ce8_04d2faa00f46["streamSendFin()"]
  3c534d05_bb5b_c991_5e03_7ec94e739cf7["QuicheQuicChannel"]
  4b35c56c_b5f6_95d5_5ce8_04d2faa00f46 -->|defined in| 3c534d05_bb5b_c991_5e03_7ec94e739cf7
  d1677a38_89f2_14d4_c465_cc77599336d5["streamSend0()"]
  4b35c56c_b5f6_95d5_5ce8_04d2faa00f46 -->|calls| d1677a38_89f2_14d4_c465_cc77599336d5
  d7575fb7_9073_0e3e_6ab3_7d2612f1eb16["flushParent()"]
  4b35c56c_b5f6_95d5_5ce8_04d2faa00f46 -->|calls| d7575fb7_9073_0e3e_6ab3_7d2612f1eb16
  style 4b35c56c_b5f6_95d5_5ce8_04d2faa00f46 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/QuicheQuicChannel.java lines 875–892

    void streamSendFin(long streamId) throws Exception {
        QuicheQuicConnection conn = connection;
        try {
            // Just write an empty buffer and set fin to true.
            int res = streamSend0(conn, streamId, Unpooled.EMPTY_BUFFER, true);
            if (res < 0 && res != Quiche.QUICHE_ERR_DONE) {
                throw Quiche.convertToException(res);
            }
        } finally {
            // As we called quiche_conn_stream_send(...) we need to ensure we will call quiche_conn_send(...) either
            // now or we will do so once we see the channelReadComplete event.
            //
            // See https://docs.rs/quiche/0.6.0/quiche/struct.Connection.html#method.send
            if (connectionSend(conn) != SendResult.NONE) {
                flushParent();
            }
        }
    }