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

mustCallResumeTrustedOnSessionResumption() — netty Function Reference

Architecture documentation for the mustCallResumeTrustedOnSessionResumption() function in SSLEngineTest.java from the netty codebase.

Function java Buffer Allocators calls 7

Entity Profile

Dependency Diagram

graph TD
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0["mustCallResumeTrustedOnSessionResumption()"]
  9150c92a_2afc_b83a_c3bf_86dfac6e9d9b["SSLEngineTest"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|defined in| 9150c92a_2afc_b83a_c3bf_86dfac6e9d9b
  3fb9b745_261d_4391_c31f_a44d5deeb05a["SessionValueSettingTrustManager()"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|calls| 3fb9b745_261d_4391_c31f_a44d5deeb05a
  3d8a44de_993f_2a06_4ab4_7636ad7d89eb["buildClientSslContextForMTLS()"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|calls| 3d8a44de_993f_2a06_4ab4_7636ad7d89eb
  144a17f3_53a5_cd5c_ad3d_a22c4a90f0e3["buildServerSslContextForMTLS()"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|calls| 144a17f3_53a5_cd5c_ad3d_a22c4a90f0e3
  a4c6f3c6_7c1f_4410_d6f3_c118e7483035["messageReceived()"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|calls| a4c6f3c6_7c1f_4410_d6f3_c118e7483035
  c1ea24b4_912a_5bc9_eb9f_d097c21e00d3["setupServer()"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|calls| c1ea24b4_912a_5bc9_eb9f_d097c21e00d3
  13aca077_a788_4333_9f8b_2b1437653846["delegate()"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|calls| 13aca077_a788_4333_9f8b_2b1437653846
  5b1d05e1_aa74_d249_3836_8b69b42f579f["setupClient()"]
  36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 -->|calls| 5b1d05e1_aa74_d249_3836_8b69b42f579f
  style 36e8a3de_0260_c1f5_21e4_67bbf63cb1f0 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ssl/SSLEngineTest.java lines 3885–3943

    @Timeout(value = 60, threadMode = Timeout.ThreadMode.SEPARATE_THREAD)
    @MethodSource("newTestParams")
    @ParameterizedTest
    public void mustCallResumeTrustedOnSessionResumption(SSLEngineTestParam param) throws Exception {
        SelfSignedCertificate ssc = CachedSelfSignedCertificate.getCachedCertificate();
        SessionValueSettingTrustManager clientTm = new SessionValueSettingTrustManager("key", "client");
        SessionValueSettingTrustManager serverTm = new SessionValueSettingTrustManager("key", "server");
        buildClientSslContextForMTLS(param, ssc, clientTm);
        buildServerSslContextForMTLS(param, ssc, serverTm);
        final BlockingQueue<String> clientSessionValues = new LinkedBlockingQueue<String>();
        final BlockingQueue<String> serverSessionValues = new LinkedBlockingQueue<String>();
        OnNextMessage checkClient = new OnNextMessage() {
            @Override
            public void messageReceived(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
                msg.release();
                SslHandler sslHandler = ctx.pipeline().get(SslHandler.class);
                SSLEngine engine = sslHandler.engine();
                logger.debug("Client message received: {} ({}) {} {}",
                        engine.getSession(), engine.getHandshakeStatus(), isSessionReused(engine),
                        Arrays.toString(engine.getSession().getValueNames()));
                Object value = engine.getSession().getValue("key");
                clientSessionValues.put((String) value);
            }
        };
        OnNextMessage checkServer = new OnNextMessage() {
            @Override
            public void messageReceived(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
                SslHandler sslHandler = ctx.pipeline().get(SslHandler.class);
                SSLEngine engine = sslHandler.engine();
                logger.debug("Server message received: {} ({}) {} {}",
                        engine.getSession(), engine.getHandshakeStatus(), isSessionReused(engine),
                        Arrays.toString(engine.getSession().getValueNames()));
                Object value = engine.getSession().getValue("key");
                serverSessionValues.put((String) value);
                ctx.writeAndFlush(msg).addListener(ChannelFutureListener.CLOSE);
            }
        };

        setupServer(param.type(), param.delegate());
        InetSocketAddress addr = (InetSocketAddress) serverChannel.localAddress();
        setupClient(param.type(), param.delegate(), "a.netty.io", addr.getPort());
        for (int i = 0; i < 10; i++) {
            clientReceiver.onNextMessages.offer(checkClient);
            serverReceiver.onNextMessages.offer(checkServer);

            ChannelFuture ccf = cb.connect(addr);
            assertTrue(ccf.syncUninterruptibly().isSuccess());
            clientChannel = ccf.channel();

            clientChannel.writeAndFlush(clientChannel.alloc().buffer().writeInt(42)).sync();
            assertEquals("client", clientSessionValues.take());
            assertEquals("server", serverSessionValues.take());
            clientChannel.closeFuture().sync();
        }
        assertTrue(clientReceiver.onNextMessages.isEmpty());
        assertTrue(serverReceiver.onNextMessages.isEmpty());
        assertTrue(clientSessionValues.isEmpty());
        assertTrue(serverSessionValues.isEmpty());
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does mustCallResumeTrustedOnSessionResumption() do?
mustCallResumeTrustedOnSessionResumption() is a function in the netty codebase, defined in handler/src/test/java/io/netty/handler/ssl/SSLEngineTest.java.
Where is mustCallResumeTrustedOnSessionResumption() defined?
mustCallResumeTrustedOnSessionResumption() is defined in handler/src/test/java/io/netty/handler/ssl/SSLEngineTest.java at line 3885.
What does mustCallResumeTrustedOnSessionResumption() call?
mustCallResumeTrustedOnSessionResumption() calls 7 function(s): SessionValueSettingTrustManager, buildClientSslContextForMTLS, buildServerSslContextForMTLS, delegate, messageReceived, setupClient, setupServer.

Analyze Your Own Codebase

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

Try Supermodel Free