testReleaseDifferentPool() — netty Function Reference

Architecture documentation for the testReleaseDifferentPool() function in FixedChannelPoolTest.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ testReleaseDifferentPool() — netty Function Reference

Dependency Diagram

graph TD
  1b444c67_fffc_d292_f06b_0f7e7d1d9c5d["testReleaseDifferentPool()"]
  92761f16_3144_6791_29c9_00f65a091a8f["FixedChannelPoolTest"]
  1b444c67_fffc_d292_f06b_0f7e7d1d9c5d -->|defined in| 92761f16_3144_6791_29c9_00f65a091a8f
  style 1b444c67_fffc_d292_f06b_0f7e7d1d9c5d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/pool/FixedChannelPoolTest.java lines 198–220

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

        // Start server
        Channel sc = t.sb.bind(t.address).syncUninterruptibly().channel();
        ChannelPoolHandler handler = new TestChannelPoolHandler();
        ChannelPool pool = new FixedChannelPool(t.cb, handler, 1, 1);
        final ChannelPool pool2 = new FixedChannelPool(t.cb, handler, 1, 1);

        final Channel channel = pool.acquire().syncUninterruptibly().getNow();

        assertThrows(IllegalArgumentException.class, new Executable() {
            @Override
            public void execute() throws Throwable {
                pool2.release(channel).syncUninterruptibly();
            }
        });
        sc.close().syncUninterruptibly();
        channel.close().syncUninterruptibly();
        pool.close();
        pool2.close();
    }