testUserDefinedWritability() — netty Function Reference

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

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ testUserDefinedWritability() — netty Function Reference

Dependency Diagram

graph TD
  734d61ff_70b3_1069_3892_4d534531ae0a["testUserDefinedWritability()"]
  06eb8f18_da0c_40bf_fb14_47e2c94a6923["ChannelOutboundBufferTest"]
  734d61ff_70b3_1069_3892_4d534531ae0a -->|defined in| 06eb8f18_da0c_40bf_fb14_47e2c94a6923
  00d35efd_91f9_9891_6cdb_8a43498309e6["safeClose()"]
  734d61ff_70b3_1069_3892_4d534531ae0a -->|calls| 00d35efd_91f9_9891_6cdb_8a43498309e6
  style 734d61ff_70b3_1069_3892_4d534531ae0a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/ChannelOutboundBufferTest.java lines 317–349

    @Test
    public void testUserDefinedWritability() {
        final StringBuilder buf = new StringBuilder();
        EmbeddedChannel ch = new EmbeddedChannel(new ChannelInboundHandlerAdapter() {
            @Override
            public void channelWritabilityChanged(ChannelHandlerContext ctx) {
                buf.append(ctx.channel().isWritable());
                buf.append(' ');
            }
        });

        ch.config().setWriteBufferLowWaterMark(128);
        ch.config().setWriteBufferHighWaterMark(256);

        ChannelOutboundBuffer cob = ch.unsafe().outboundBuffer();

        // Ensure that the default value of a user-defined writability flag is true.
        for (int i = 1; i <= 30; i ++) {
            assertTrue(cob.getUserDefinedWritability(i));
        }

        // Ensure that setting a user-defined writability flag to false affects channel.isWritable();
        cob.setUserDefinedWritability(1, false);
        ch.runPendingTasks();
        assertEquals("false ", buf.toString());

        // Ensure that setting a user-defined writability flag to true affects channel.isWritable();
        cob.setUserDefinedWritability(1, true);
        ch.runPendingTasks();
        assertEquals("false true ", buf.toString());

        safeClose(ch);
    }