netty Architecture Docs
Home / Function/ testNioBuffersCancelledRemoveBytes() — netty Function Reference

testNioBuffersCancelledRemoveBytes() — netty Function Reference

Architecture documentation for the testNioBuffersCancelledRemoveBytes() function in ChannelOutboundBufferTest.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Dependency Diagram

graph TD
  9ec9e4c1_de8e_8c05_3ca4_80d9dab213f3["testNioBuffersCancelledRemoveBytes()"]
  06eb8f18_da0c_40bf_fb14_47e2c94a6923["ChannelOutboundBufferTest"]
  9ec9e4c1_de8e_8c05_3ca4_80d9dab213f3 -->|defined in| 06eb8f18_da0c_40bf_fb14_47e2c94a6923
  31b49bd0_4c82_f6fd_3697_c6d8205d4cfe["TestChannel()"]
  9ec9e4c1_de8e_8c05_3ca4_80d9dab213f3 -->|calls| 31b49bd0_4c82_f6fd_3697_c6d8205d4cfe
  4bdec6f8_3c15_b5ee_d1a3_716048f52c5a["release()"]
  9ec9e4c1_de8e_8c05_3ca4_80d9dab213f3 -->|calls| 4bdec6f8_3c15_b5ee_d1a3_716048f52c5a
  style 9ec9e4c1_de8e_8c05_3ca4_80d9dab213f3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ChannelOutboundBufferTest.java lines 58–92

    @Test
    public void testNioBuffersCancelledRemoveBytes() {
        TestChannel channel = new TestChannel();
        ChannelOutboundBuffer buffer = new ChannelOutboundBuffer(channel);
        ByteBuf b1 = wrappedBuffer(new byte[] { 0 });
        int r1 = b1.readableBytes();
        ChannelPromise p1 = channel.newPromise();
        buffer.addMessage(b1, r1, p1);

        ByteBuf b2 = wrappedBuffer(new byte[] { 0, 1 });
        int r2 = b2.readableBytes();
        ChannelPromise p2 = channel.newPromise();
        buffer.addMessage(b2, r2, p2);
        p2.cancel(false);

        ByteBuf b3 = wrappedBuffer(new byte[] { 0 });
        int r3 = b3.readableBytes();
        ChannelPromise p3 = channel.newPromise();
        buffer.addMessage(b3, r3, p3);
        buffer.addFlush();

        ByteBuffer[] buffers = buffer.nioBuffers();
        assertEquals(2, buffer.nioBufferCount());
        assertNotNull(buffers);
        assertEquals(r1, buffers[0].remaining());
        assertEquals(r3, buffers[1].remaining());

        buffer.removeBytes(r1 + r3);
        assertEquals(0, b1.refCnt());
        assertEquals(0, b2.refCnt());
        assertEquals(0, b3.refCnt());

        assertTrue(buffer.isEmpty());
        release(buffer);
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does testNioBuffersCancelledRemoveBytes() do?
testNioBuffersCancelledRemoveBytes() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/ChannelOutboundBufferTest.java.
Where is testNioBuffersCancelledRemoveBytes() defined?
testNioBuffersCancelledRemoveBytes() is defined in transport/src/test/java/io/netty/channel/ChannelOutboundBufferTest.java at line 58.
What does testNioBuffersCancelledRemoveBytes() call?
testNioBuffersCancelledRemoveBytes() calls 2 function(s): TestChannel, release.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free