testReleaseInbound() — netty Function Reference

Architecture documentation for the testReleaseInbound() function in EmbeddedChannelTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testReleaseInbound() — netty Function Reference

Dependency Diagram

graph TD
  8a40af8a_5895_8492_1ccd_9874d2f12c59["testReleaseInbound()"]
  300cabef_b042_697f_5623_37ce249f504d["EmbeddedChannelTest"]
  8a40af8a_5895_8492_1ccd_9874d2f12c59 -->|defined in| 300cabef_b042_697f_5623_37ce249f504d
  17f7b672_524d_b9ed_a14b_29a7376a7ef2["release()"]
  8a40af8a_5895_8492_1ccd_9874d2f12c59 -->|calls| 17f7b672_524d_b9ed_a14b_29a7376a7ef2
  style 8a40af8a_5895_8492_1ccd_9874d2f12c59 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/embedded/EmbeddedChannelTest.java lines 325–352

    @Test
    public void testReleaseInbound() {
        ByteBuf in = Unpooled.buffer();
        ByteBuf out = Unpooled.buffer();
        try {
            EmbeddedChannel channel = new EmbeddedChannel();
            assertTrue(channel.writeInbound(in));
            assertEquals(1, in.refCnt());

            assertTrue(channel.writeOutbound(out));
            assertEquals(1, out.refCnt());

            assertTrue(channel.releaseInbound());
            assertEquals(0, in.refCnt());
            assertEquals(1, out.refCnt());

            assertTrue(channel.finish());
            assertNull(channel.readInbound());

            ByteBuf buffer = channel.readOutbound();
            assertSame(out, buffer);
            buffer.release();

            assertNull(channel.readOutbound());
        } finally {
            release(in, out);
        }
    }