testHandlerAddedFailedButHandlerStillRemoved0() — netty Function Reference

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 2134–2164

    private static void testHandlerAddedFailedButHandlerStillRemoved0(boolean lateRegister)
            throws InterruptedException {
        EventExecutorGroup executorGroup = new DefaultEventExecutorGroup(16);
        final int numHandlers = 32;
        try {
            Channel channel = new LocalChannel();
            channel.config().setOption(ChannelOption.SINGLE_EVENTEXECUTOR_PER_GROUP, false);
            if (!lateRegister) {
                group.register(channel).sync();
            }
            channel.pipeline().addFirst(newHandler());

            List<CountDownLatch> latchList = new ArrayList<CountDownLatch>(numHandlers);
            for (int i = 0; i < numHandlers; i++) {
                CountDownLatch latch = new CountDownLatch(1);
                channel.pipeline().addFirst(executorGroup, "h" + i, new BadChannelHandler(latch));
                latchList.add(latch);
            }
            if (lateRegister) {
                group.register(channel).sync();
            }

            for (int i = 0; i < numHandlers; i++) {
                // Wait until the latch was countDown which means handlerRemoved(...) was called.
                latchList.get(i).await();
                assertNull(channel.pipeline().get("h" + i));
            }
        } finally {
            executorGroup.shutdownGracefully();
        }
    }