setUp() — netty Function Reference

Architecture documentation for the setUp() function in Http3PushStreamTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ setUp() — netty Function Reference

Dependency Diagram

graph TD
  73e4df66_8362_81ed_8adc_d0918302d077["setUp()"]
  c9142e7f_8050_3c0d_eeaf_c4c0175b89af["Http3PushStreamTest"]
  73e4df66_8362_81ed_8adc_d0918302d077 -->|defined in| c9142e7f_8050_3c0d_eeaf_c4c0175b89af
  cc1c317d_899e_e137_25d9_7446a1048d17["sendMaxPushId()"]
  73e4df66_8362_81ed_8adc_d0918302d077 -->|calls| cc1c317d_899e_e137_25d9_7446a1048d17
  style 73e4df66_8362_81ed_8adc_d0918302d077 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http3/src/test/java/io/netty/handler/codec/http3/Http3PushStreamTest.java lines 53–75

    @BeforeEach
    public void setUp() throws Exception {
        serverConnectionHandler = new Http3ServerConnectionHandler(new ChannelDuplexHandler(), null, null, null, true);
        serverChannel = new EmbeddedQuicChannel(true, serverConnectionHandler);
        serverLocalControlStream = (EmbeddedQuicStreamChannel) Http3.getLocalControlStream(serverChannel);
        assertNotNull(serverLocalControlStream);
        serverControlStreamHandlerCtx = mock(ChannelHandlerContext.class);
        when(serverControlStreamHandlerCtx.channel()).thenReturn(serverLocalControlStream);

        serverConnectionHandler.localControlStreamHandler.channelRead(serverControlStreamHandlerCtx,
                new DefaultHttp3SettingsFrame());
        pushStreamManager = new Http3ServerPushStreamManager(serverChannel);

        clientConnectionHandler = new Http3ClientConnectionHandler(null, null, null, null, true);
        clientChannel = new EmbeddedQuicChannel(false, clientConnectionHandler);
        clientLocalControlStream = (EmbeddedQuicStreamChannel) Http3.getLocalControlStream(clientChannel);
        assertNotNull(clientLocalControlStream);

        assertTrue(serverLocalControlStream.releaseOutbound());
        assertTrue(clientLocalControlStream.releaseOutbound());
        maxPushId = 0; // allow 1 push
        sendMaxPushId(maxPushId);
    }