init() — netty Function Reference

Architecture documentation for the init() function in LocalTransportThreadModelTest3.java from the netty codebase.

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ init() — netty Function Reference

Dependency Diagram

graph TD
  1ba35c45_4481_a9ea_7bb4_b9df8a73305d["init()"]
  f86ec9f6_ad3f_1246_2bcb_3e0c74480849["LocalTransportThreadModelTest3"]
  1ba35c45_4481_a9ea_7bb4_b9df8a73305d -->|defined in| f86ec9f6_ad3f_1246_2bcb_3e0c74480849
  3aa7e318_86e5_29de_2c94_f8dd8a483e94["channelRead()"]
  1ba35c45_4481_a9ea_7bb4_b9df8a73305d -->|calls| 3aa7e318_86e5_29de_2c94_f8dd8a483e94
  style 1ba35c45_4481_a9ea_7bb4_b9df8a73305d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest3.java lines 67–88

    @BeforeAll
    public static void init() {
        // Configure a test server
        group = new MultiThreadIoEventLoopGroup(LocalIoHandler.newFactory());
        ServerBootstrap sb = new ServerBootstrap();
        sb.group(group)
                .channel(LocalServerChannel.class)
                .childHandler(new ChannelInitializer<LocalChannel>() {
                    @Override
                    public void initChannel(LocalChannel ch) throws Exception {
                        ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
                            @Override
                            public void channelRead(ChannelHandlerContext ctx, Object msg) {
                                // Discard
                                ReferenceCountUtil.release(msg);
                            }
                        });
                    }
                });

        localAddr = (LocalAddress) sb.bind(LocalAddress.ANY).syncUninterruptibly().channel().localAddress();
    }