netty Architecture Docs
Home / Function/ minChunkShouldBeAllocatedPerStream() — netty Function Reference

minChunkShouldBeAllocatedPerStream() — netty Function Reference

Architecture documentation for the minChunkShouldBeAllocatedPerStream() function in UniformStreamByteDistributorTest.java from the netty codebase.

Function java Buffer Allocators calls 5

Entity Profile

Dependency Diagram

graph TD
  1bcd0e0b_21ac_c26f_1eac_6781515ba458["minChunkShouldBeAllocatedPerStream()"]
  c9ed8a9b_20d0_d85d_3ba2_4bce8a2cb72f["UniformStreamByteDistributorTest"]
  1bcd0e0b_21ac_c26f_1eac_6781515ba458 -->|defined in| c9ed8a9b_20d0_d85d_3ba2_4bce8a2cb72f
  a6c2aca6_aa8e_1f2c_221a_88b9bd0bd852["setPriority()"]
  1bcd0e0b_21ac_c26f_1eac_6781515ba458 -->|calls| a6c2aca6_aa8e_1f2c_221a_88b9bd0bd852
  874cc0a8_d364_ef65_d3c3_16d61b243e73["initState()"]
  1bcd0e0b_21ac_c26f_1eac_6781515ba458 -->|calls| 874cc0a8_d364_ef65_d3c3_16d61b243e73
  25e52e77_a9b5_a8d2_5680_6ca6e99dc744["write()"]
  1bcd0e0b_21ac_c26f_1eac_6781515ba458 -->|calls| 25e52e77_a9b5_a8d2_5680_6ca6e99dc744
  ab8d170f_1b6f_fcf3_9851_b2a9d9bc0c37["captureWrite()"]
  1bcd0e0b_21ac_c26f_1eac_6781515ba458 -->|calls| ab8d170f_1b6f_fcf3_9851_b2a9d9bc0c37
  ba51586b_9db8_a3bc_5389_8ae4d02826b8["resetWriter()"]
  1bcd0e0b_21ac_c26f_1eac_6781515ba458 -->|calls| ba51586b_9db8_a3bc_5389_8ae4d02826b8
  style 1bcd0e0b_21ac_c26f_1eac_6781515ba458 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/UniformStreamByteDistributorTest.java lines 161–189

    @Test
    public void minChunkShouldBeAllocatedPerStream() throws Http2Exception {
        // Re-assign weights.
        setPriority(STREAM_A, 0, (short) 50, false);
        setPriority(STREAM_B, 0, (short) 200, false);
        setPriority(STREAM_C, STREAM_A, (short) 100, false);
        setPriority(STREAM_D, STREAM_A, (short) 100, false);

        // Update the streams.
        initState(STREAM_A, CHUNK_SIZE, true);
        initState(STREAM_B, CHUNK_SIZE, true);
        initState(STREAM_C, CHUNK_SIZE, true);
        initState(STREAM_D, CHUNK_SIZE, true);

        // Only write 3 * chunkSize, so that we'll only write to the first 3 streams.
        int written = 3 * CHUNK_SIZE;
        assertTrue(write(written));
        assertEquals(CHUNK_SIZE, captureWrite(STREAM_A));
        assertEquals(CHUNK_SIZE, captureWrite(STREAM_B));
        assertEquals(CHUNK_SIZE, captureWrite(STREAM_C));
        verifyNoMoreInteractions(writer);

        resetWriter();

        // Now write again and verify that the last stream is written to.
        assertFalse(write(CHUNK_SIZE));
        assertEquals(CHUNK_SIZE, captureWrite(STREAM_D));
        verifyNoMoreInteractions(writer);
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does minChunkShouldBeAllocatedPerStream() do?
minChunkShouldBeAllocatedPerStream() is a function in the netty codebase, defined in codec-http2/src/test/java/io/netty/handler/codec/http2/UniformStreamByteDistributorTest.java.
Where is minChunkShouldBeAllocatedPerStream() defined?
minChunkShouldBeAllocatedPerStream() is defined in codec-http2/src/test/java/io/netty/handler/codec/http2/UniformStreamByteDistributorTest.java at line 161.
What does minChunkShouldBeAllocatedPerStream() call?
minChunkShouldBeAllocatedPerStream() calls 5 function(s): captureWrite, initState, resetWriter, setPriority, write.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free