testQLog() — netty Function Reference

Architecture documentation for the testQLog() function in QuicChannelConnectTest.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 2

Entity Profile

Buffer→ Allocators→ testQLog() — netty Function Reference

Dependency Diagram

graph TD
  92194a28_1ade_17eb_5f02_fdef14ac04b3["testQLog()"]
  1e1bc485_1969_4537_ef9b_f28971b2f663["QuicChannelConnectTest"]
  92194a28_1ade_17eb_5f02_fdef14ac04b3 -->|defined in| 1e1bc485_1969_4537_ef9b_f28971b2f663
  e6bfbc8d_0670_3c4f_1514_4e3e947982d5["testConnectAndQLog()"]
  e6bfbc8d_0670_3c4f_1514_4e3e947982d5 -->|calls| 92194a28_1ade_17eb_5f02_fdef14ac04b3
  424558b6_f0ce_b090_4624_476469454a57["testConnectAndQLogDir()"]
  424558b6_f0ce_b090_4624_476469454a57 -->|calls| 92194a28_1ade_17eb_5f02_fdef14ac04b3
  5f0fc68a_3438_a865_1307_d0a3144b2c00["assertState()"]
  92194a28_1ade_17eb_5f02_fdef14ac04b3 -->|calls| 5f0fc68a_3438_a865_1307_d0a3144b2c00
  style 92194a28_1ade_17eb_5f02_fdef14ac04b3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-native-quic/src/test/java/io/netty/handler/codec/quic/QuicChannelConnectTest.java lines 139–173

    private void testQLog(Executor executor, Path path, Consumer<Path> consumer) throws Throwable {
        QuicChannelValidationHandler serverValidationHandler = new QuicChannelValidationHandler();
        QuicChannelValidationHandler clientValidationHandler = new QuicChannelValidationHandler();
        Channel server = QuicTestUtils.newServer(executor, serverValidationHandler,
                new ChannelInboundHandlerAdapter());
        InetSocketAddress address = (InetSocketAddress) server.localAddress();
        Channel channel = QuicTestUtils.newClient(executor);
        try {
            QuicChannel quicChannel = QuicTestUtils.newQuicChannelBootstrap(channel)
                    .handler(clientValidationHandler)
                    .option(QuicChannelOption.QLOG,
                            new QLogConfiguration(path.toString(), "testTitle", "test"))
                    .streamHandler(new ChannelInboundHandlerAdapter())
                    .remoteAddress(address)
                    .connect()
                    .get();
            QuicStreamChannel stream = quicChannel.createStream(QuicStreamType.BIDIRECTIONAL,
                    new ChannelInboundHandlerAdapter()).get();

            stream.writeAndFlush(Unpooled.directBuffer().writeZero(10)).sync();
            stream.close().sync();
            quicChannel.close().sync();
            quicChannel.closeFuture().sync();
            consumer.accept(path);

            serverValidationHandler.assertState();
            clientValidationHandler.assertState();
        } finally {
            server.close().sync();
            // Close the parent Datagram channel as well.
            channel.close().sync();

            shutdown(executor);
        }
    }