channelActive() — netty Function Reference

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

Function java Buffer Allocators calls 1 called by 1

Entity Profile

Buffer→ Allocators→ channelActive() — netty Function Reference

Dependency Diagram

graph TD
  d11956a8_ed24_1fe8_fe14_61d9359b2318["channelActive()"]
  4666128d_bb10_bddf_1e70_e3216c05611a["FailureTestHandler"]
  d11956a8_ed24_1fe8_fe14_61d9359b2318 -->|defined in| 4666128d_bb10_bddf_1e70_e3216c05611a
  6318373a_af7a_d643_7bf6_992e96d0d650["channelActive()"]
  6318373a_af7a_d643_7bf6_992e96d0d650 -->|calls| d11956a8_ed24_1fe8_fe14_61d9359b2318
  6318373a_af7a_d643_7bf6_992e96d0d650["channelActive()"]
  d11956a8_ed24_1fe8_fe14_61d9359b2318 -->|calls| 6318373a_af7a_d643_7bf6_992e96d0d650
  style d11956a8_ed24_1fe8_fe14_61d9359b2318 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler-proxy/src/test/java/io/netty/handler/proxy/ProxyHandlerTest.java lines 572–582

        @Override
        public void channelActive(ChannelHandlerContext ctx) throws Exception {
            ctx.writeAndFlush(Unpooled.copiedBuffer("A\n", CharsetUtil.US_ASCII)).addListener(
                    future -> {
                        latch.countDown();
                        if (!(future.cause() instanceof ProxyConnectException)) {
                            exceptions.add(new AssertionError(
                                    "Unexpected failure cause for initial write: " + future.cause()));
                        }
                    });
        }