consumeBytes() — netty Function Reference

Architecture documentation for the consumeBytes() function in Http2FrameCodec.java from the netty codebase.

Function java Buffer Allocators called by 2

Entity Profile

Buffer→ Allocators→ consumeBytes() — netty Function Reference

Dependency Diagram

graph TD
  dafb708f_d534_42b0_93ed_f04119450f7d["consumeBytes()"]
  ba77a225_4637_fe77_ee1f_54a9774ca7f8["Http2FrameCodec"]
  dafb708f_d534_42b0_93ed_f04119450f7d -->|defined in| ba77a225_4637_fe77_ee1f_54a9774ca7f8
  dabb27f9_26d0_6cce_3476_d90ad2682131["write()"]
  dabb27f9_26d0_6cce_3476_d90ad2682131 -->|calls| dafb708f_d534_42b0_93ed_f04119450f7d
  c2979b96_390d_7b64_2c99_e3e669d4bbfa["onDataRead()"]
  c2979b96_390d_7b64_2c99_e3e669d4bbfa -->|calls| dafb708f_d534_42b0_93ed_f04119450f7d
  style dafb708f_d534_42b0_93ed_f04119450f7d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/Http2FrameCodec.java lines 372–384

    final boolean consumeBytes(int streamId, int bytes) throws Http2Exception {
        Http2Stream stream = connection().stream(streamId);
        // Upgraded requests are ineligible for stream control. We add the null check
        // in case the stream has been deregistered.
        if (stream != null && streamId == Http2CodecUtil.HTTP_UPGRADE_STREAM_ID) {
            Boolean upgraded = stream.getProperty(upgradeKey);
            if (Boolean.TRUE.equals(upgraded)) {
                return false;
            }
        }

        return connection().local().flowController().consumeBytes(stream, bytes);
    }