Home / Function/ writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() — netty Function Reference

writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() — netty Function Reference

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

Entity Profile

Dependency Diagram

graph TD
  29e725a2_b72b_804f_d9ab_387652d77c78["writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue()"]
  67b7550d_3bc6_4a2b_6b2f_618af35d6df8["WeightedFairQueueByteDistributorTest"]
  29e725a2_b72b_804f_d9ab_387652d77c78 -->|defined in| 67b7550d_3bc6_4a2b_6b2f_618af35d6df8
  11b51d3d_8188_9502_be8f_cc1ca56136d9["write()"]
  29e725a2_b72b_804f_d9ab_387652d77c78 -->|calls| 11b51d3d_8188_9502_be8f_cc1ca56136d9
  fa4d7172_24a5_f6ad_635f_9c2cba8fd926["captureWrites()"]
  29e725a2_b72b_804f_d9ab_387652d77c78 -->|calls| fa4d7172_24a5_f6ad_635f_9c2cba8fd926
  290143c2_0468_a100_788a_18d9e37200a9["verifyNeverWrite()"]
  29e725a2_b72b_804f_d9ab_387652d77c78 -->|calls| 290143c2_0468_a100_788a_18d9e37200a9
  style 29e725a2_b72b_804f_d9ab_387652d77c78 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/WeightedFairQueueByteDistributorTest.java lines 97–124

    @Test
    public void writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() throws Http2Exception {
        initState(STREAM_A, 400, true);
        initState(STREAM_B, 500, true);
        initState(STREAM_C, 600, true);
        initState(STREAM_D, 700, true);

        setPriority(STREAM_B, STREAM_A, DEFAULT_PRIORITY_WEIGHT, true);
        setPriority(STREAM_D, STREAM_C, DEFAULT_PRIORITY_WEIGHT, true);

        // Block B, but it should still remain in the queue/tree structure.
        initState(STREAM_B, 0, false);

        // Get the streams before the write, because they may be closed.
        Http2Stream streamA = stream(STREAM_A);
        Http2Stream streamB = stream(STREAM_B);
        Http2Stream streamC = stream(STREAM_C);
        Http2Stream streamD = stream(STREAM_D);

        reset(writer);
        doAnswer(writeAnswer(true)).when(writer).write(any(Http2Stream.class), anyInt());

        assertFalse(write(400 + 600 + 700));
        assertEquals(400, captureWrites(streamA));
        verifyNeverWrite(streamB);
        assertEquals(600, captureWrites(streamC));
        assertEquals(700, captureWrites(streamD));
    }

Domain

Subdomains

Frequently Asked Questions

What does writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() do?
writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() is a function in the netty codebase, defined in codec-http2/src/test/java/io/netty/handler/codec/http2/WeightedFairQueueByteDistributorTest.java.
Where is writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() defined?
writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() is defined in codec-http2/src/test/java/io/netty/handler/codec/http2/WeightedFairQueueByteDistributorTest.java at line 97.
What does writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() call?
writeWithNonActiveStreamShouldNotDobuleAddToPriorityQueue() calls 3 function(s): captureWrites, verifyNeverWrite, write.

Analyze Your Own Codebase

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

Try Supermodel Free