testReleaseAfterClosePool() — netty Function Reference

Source Code

transport/src/test/java/io/netty/channel/pool/FixedChannelPoolTest.java lines 222–250

    @Test
    public void testReleaseAfterClosePool() throws Exception {
        Tuple t = bootstrap();

        // Start server
        Channel sc = t.sb.bind(t.address).syncUninterruptibly().channel();

        final FixedChannelPool pool = new FixedChannelPool(t.cb, new TestChannelPoolHandler(), 2);
        final Future<Channel> acquire = pool.acquire();
        final Channel channel = acquire.get();
        pool.close();
        group.submit(new Runnable() {
            @Override
            public void run() {
                // NOOP
            }
        }).syncUninterruptibly();
        assertThrows(IllegalStateException.class, new Executable() {
            @Override
            public void execute() throws Throwable {
                pool.release(channel).syncUninterruptibly();
            }
        });
        // Since the pool is closed, the Channel should have been closed as well.
        channel.closeFuture().syncUninterruptibly();
        assertFalse(channel.isOpen());
        sc.close().syncUninterruptibly();
        pool.close();
    }