blockedStreamShouldSpreadDataToChildren() — netty Function Reference

Architecture documentation for the blockedStreamShouldSpreadDataToChildren() function in WeightedFairQueueByteDistributorTest.java from the netty codebase.

Function java Buffer Allocators calls 4 called by 3

Entity Profile

Buffer→ Allocators→ blockedStreamShouldSpreadDataToChildren() — netty Function Reference

Dependency Diagram

graph TD
  d35333b0_3394_a15a_9e69_55c84468da13["blockedStreamShouldSpreadDataToChildren()"]
  67b7550d_3bc6_4a2b_6b2f_618af35d6df8["WeightedFairQueueByteDistributorTest"]
  d35333b0_3394_a15a_9e69_55c84468da13 -->|defined in| 67b7550d_3bc6_4a2b_6b2f_618af35d6df8
  89331c2b_8632_f9c3_a5a4_5c708a3c3295["blockedStreamNoDataShouldSpreadDataToChildren()"]
  89331c2b_8632_f9c3_a5a4_5c708a3c3295 -->|calls| d35333b0_3394_a15a_9e69_55c84468da13
  4d688891_004c_3973_4287_29ae85b7526d["blockedStreamWithDataAndNotAllowedToSendShouldSpreadDataToChildren()"]
  4d688891_004c_3973_4287_29ae85b7526d -->|calls| d35333b0_3394_a15a_9e69_55c84468da13
  e5c7c421_6012_fcf0_bbfc_0ea799957567["streamWithZeroFlowControlWindowAndDataShouldWriteOnlyOnce()"]
  e5c7c421_6012_fcf0_bbfc_0ea799957567 -->|calls| d35333b0_3394_a15a_9e69_55c84468da13
  11b51d3d_8188_9502_be8f_cc1ca56136d9["write()"]
  d35333b0_3394_a15a_9e69_55c84468da13 -->|calls| 11b51d3d_8188_9502_be8f_cc1ca56136d9
  7bda6a25_cd2a_2145_1a6b_a3c3169cec22["verifyWrite()"]
  d35333b0_3394_a15a_9e69_55c84468da13 -->|calls| 7bda6a25_cd2a_2145_1a6b_a3c3169cec22
  290143c2_0468_a100_788a_18d9e37200a9["verifyNeverWrite()"]
  d35333b0_3394_a15a_9e69_55c84468da13 -->|calls| 290143c2_0468_a100_788a_18d9e37200a9
  fa4d7172_24a5_f6ad_635f_9c2cba8fd926["captureWrites()"]
  d35333b0_3394_a15a_9e69_55c84468da13 -->|calls| fa4d7172_24a5_f6ad_635f_9c2cba8fd926
  style d35333b0_3394_a15a_9e69_55c84468da13 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/WeightedFairQueueByteDistributorTest.java lines 317–363

    private void blockedStreamShouldSpreadDataToChildren(boolean streamAShouldWriteZero) throws Http2Exception {
        initState(STREAM_B, 10, true);
        initState(STREAM_C, 10, true);
        initState(STREAM_D, 10, true);

        // Write up to 10 bytes.
        assertTrue(write(10));

        if (streamAShouldWriteZero) {
            verifyWrite(STREAM_A, 0);
        } else {
            verifyNeverWrite(STREAM_A);
        }
        verifyWrite(atMost(1), STREAM_C, 0);
        verifyWrite(atMost(1), STREAM_D, 0);

        // B is entirely written
        verifyWrite(STREAM_B, 10);

        // Now test that writes get delegated from A (which is blocked) to its children
        assertTrue(write(5));
        if (streamAShouldWriteZero) {
            verifyWrite(times(1), STREAM_A, 0);
        } else {
            verifyNeverWrite(STREAM_A);
        }
        verifyWrite(STREAM_D, 5);
        verifyWrite(atMost(1), STREAM_C, 0);

        assertTrue(write(5));
        if (streamAShouldWriteZero) {
            verifyWrite(times(1), STREAM_A, 0);
        } else {
            verifyNeverWrite(STREAM_A);
        }
        assertEquals(10, captureWrites(STREAM_C) + captureWrites(STREAM_D));

        assertTrue(write(5));
        assertFalse(write(5));
        if (streamAShouldWriteZero) {
            verifyWrite(times(1), STREAM_A, 0);
        } else {
            verifyNeverWrite(STREAM_A);
        }
        verifyWrite(times(2), STREAM_C, 5);
        verifyWrite(times(2), STREAM_D, 5);
    }

Domain

Buffer

Subdomains

Allocators

Defined In

codec-http2/src/test/java/io/netty/handler/codec/http2/WeightedFairQueueByteDistributorTest.java

Calls

Called By

Source

View on GitHub

Frequently Asked Questions

What does blockedStreamShouldSpreadDataToChildren() do?

blockedStreamShouldSpreadDataToChildren() is a function in the netty codebase, defined in codec-http2/src/test/java/io/netty/handler/codec/http2/WeightedFairQueueByteDistributorTest.java.

Where is blockedStreamShouldSpreadDataToChildren() defined?

blockedStreamShouldSpreadDataToChildren() is defined in codec-http2/src/test/java/io/netty/handler/codec/http2/WeightedFairQueueByteDistributorTest.java at line 317.

What does blockedStreamShouldSpreadDataToChildren() call?

blockedStreamShouldSpreadDataToChildren() calls 4 function(s): captureWrites, verifyNeverWrite, verifyWrite, write.

What calls blockedStreamShouldSpreadDataToChildren()?

blockedStreamShouldSpreadDataToChildren() is called by 3 function(s): blockedStreamNoDataShouldSpreadDataToChildren, blockedStreamWithDataAndNotAllowedToSendShouldSpreadDataToChildren, streamWithZeroFlowControlWindowAndDataShouldWriteOnlyOnce.

Analyze Your Own Codebase

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

Try Supermodel Free