assertProxyHandlers() — netty Function Reference

Architecture documentation for the assertProxyHandlers() function in ProxyHandlerTest.java from the netty codebase.

Function java Buffer Allocators called by 3

Entity Profile

Buffer→ Allocators→ assertProxyHandlers() — netty Function Reference

Dependency Diagram

graph TD
  60a5ed94_0116_766a_e8f8_176d65208647["assertProxyHandlers()"]
  ddab9b69_f230_b68f_75d1_54ea8024ab73["TestItem"]
  60a5ed94_0116_766a_e8f8_176d65208647 -->|defined in| ddab9b69_f230_b68f_75d1_54ea8024ab73
  26b74f53_a3a5_ba00_86af_2d89e23a79a9["test()"]
  26b74f53_a3a5_ba00_86af_2d89e23a79a9 -->|calls| 60a5ed94_0116_766a_e8f8_176d65208647
  4609bb4d_01b0_70fc_f5ab_b05a46b48346["test()"]
  4609bb4d_01b0_70fc_f5ab_b05a46b48346 -->|calls| 60a5ed94_0116_766a_e8f8_176d65208647
  52cef724_ddde_b832_a1de_156cd947f698["test()"]
  52cef724_ddde_b832_a1de_156cd947f698 -->|calls| 60a5ed94_0116_766a_e8f8_176d65208647
  style 60a5ed94_0116_766a_e8f8_176d65208647 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler-proxy/src/test/java/io/netty/handler/proxy/ProxyHandlerTest.java lines 621–652

        protected void assertProxyHandlers(boolean success) {
            for (ChannelHandler h: clientHandlers) {
                if (h instanceof ProxyHandler) {
                    ProxyHandler ph = (ProxyHandler) h;
                    String type = StringUtil.simpleClassName(ph);
                    Future<Channel> f = ph.connectFuture();
                    if (!f.isDone()) {
                        logger.warn("{}: not done", type);
                    } else if (f.isSuccess()) {
                        if (success) {
                            logger.debug("{}: success", type);
                        } else {
                            logger.warn("{}: success", type);
                        }
                    } else {
                        if (success) {
                            logger.warn("{}: failure", type, f.cause());
                        } else {
                            logger.debug("{}: failure", type, f.cause());
                        }
                    }
                }
            }

            for (ChannelHandler h: clientHandlers) {
                if (h instanceof ProxyHandler) {
                    ProxyHandler ph = (ProxyHandler) h;
                    assertTrue(ph.connectFuture().isDone());
                    assertEquals(ph.connectFuture().isSuccess(), success);
                }
            }
        }