testNioBuffersMaxCount() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ testNioBuffersMaxCount() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ChannelOutboundBufferTest.java lines 168–191

    @Test
    public void testNioBuffersMaxCount() {
        TestChannel channel = new TestChannel();

        ChannelOutboundBuffer buffer = new ChannelOutboundBuffer(channel);

        CompositeByteBuf comp = compositeBuffer(256);
        ByteBuf buf = directBuffer().writeBytes("buf1".getBytes(CharsetUtil.US_ASCII));
        for (int i = 0; i < 65; i++) {
            comp.addComponent(true, buf.copy());
        }
        assertEquals(65, comp.nioBufferCount());
        buffer.addMessage(comp, comp.readableBytes(), channel.voidPromise());
        assertEquals(0, buffer.nioBufferCount(), "Should still be 0 as not flushed yet");
        buffer.addFlush();
        final int maxCount = 10;    // less than comp.nioBufferCount()
        ByteBuffer[] buffers = buffer.nioBuffers(maxCount, Integer.MAX_VALUE);
        assertTrue(buffer.nioBufferCount() <= maxCount, "Should not be greater than maxCount");
        for (int i = 0;  i < buffer.nioBufferCount(); i++) {
            assertEquals(buffers[i], buf.internalNioBuffer(buf.readerIndex(), buf.readableBytes()));
        }
        release(buffer);
        buf.release();
    }