testLateRegisterSuccess() — netty Function Reference

Architecture documentation for the testLateRegisterSuccess() function in BootstrapTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testLateRegisterSuccess() — netty Function Reference

Dependency Diagram

graph TD
  61506973_ddc4_9462_a467_6079be419119["testLateRegisterSuccess()"]
  7a7606db_8d2a_bfe0_9993_4aaa8e0a6e42["BootstrapTest"]
  61506973_ddc4_9462_a467_6079be419119 -->|defined in| 7a7606db_8d2a_bfe0_9993_4aaa8e0a6e42
  be3f678c_5460_042e_17d7_4c0d5f273e01["TestEventLoopGroup()"]
  61506973_ddc4_9462_a467_6079be419119 -->|calls| be3f678c_5460_042e_17d7_4c0d5f273e01
  style 61506973_ddc4_9462_a467_6079be419119 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/bootstrap/BootstrapTest.java lines 231–257

    @Test
    public void testLateRegisterSuccess() throws Exception {
        TestEventLoopGroup group = new TestEventLoopGroup();
        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(group);
            bootstrap.channel(LocalServerChannel.class);
            bootstrap.childHandler(new DummyHandler());
            bootstrap.localAddress(new LocalAddress("1"));
            ChannelFuture future = bootstrap.bind();
            assertFalse(future.isDone());
            group.promise.setSuccess();
            final BlockingQueue<Boolean> queue = new LinkedBlockingQueue<Boolean>();
            future.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture future) throws Exception {
                    queue.add(future.channel().eventLoop().inEventLoop(Thread.currentThread()));
                    queue.add(future.isSuccess());
                }
            });
            assertTrue(queue.take());
            assertTrue(queue.take());
        } finally {
            group.shutdownGracefully();
            group.terminationFuture().sync();
        }
    }