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

testWritabilityChanged0() — netty Function Reference

Architecture documentation for the testWritabilityChanged0() function in CoalescingBufferQueueTest.java from the netty codebase.

Function java Buffer Search called by 2

Entity Profile

Dependency Diagram

graph TD
  63747abb_90a2_0593_6636_67f1c3b683a7["testWritabilityChanged0()"]
  ccc522b2_7fa1_bc1b_d4b4_2b255b9936f9["CoalescingBufferQueueTest"]
  63747abb_90a2_0593_6636_67f1c3b683a7 -->|defined in| ccc522b2_7fa1_bc1b_d4b4_2b255b9936f9
  83aae1ae_1e79_00cb_2d8d_4f0d13afee14["testWritabilityChanged()"]
  83aae1ae_1e79_00cb_2d8d_4f0d13afee14 -->|calls| 63747abb_90a2_0593_6636_67f1c3b683a7
  e88b19a0_d8c9_94a5_1347_b2483d749556["testWritabilityChangedFailAll()"]
  e88b19a0_d8c9_94a5_1347_b2483d749556 -->|calls| 63747abb_90a2_0593_6636_67f1c3b683a7
  style 63747abb_90a2_0593_6636_67f1c3b683a7 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/CoalescingBufferQueueTest.java lines 265–294

    private void testWritabilityChanged0(boolean fail) {
        channel.config().setWriteBufferWaterMark(new WriteBufferWaterMark(3, 4));
        assertTrue(channel.isWritable());
        writeQueue.add(Unpooled.wrappedBuffer(new byte[] {1 , 2, 3}));
        assertTrue(channel.isWritable());
        writeQueue.add(Unpooled.wrappedBuffer(new byte[] {4, 5}));
        assertFalse(channel.isWritable());
        assertEquals(5, writeQueue.readableBytes());

        if (fail) {
            writeQueue.releaseAndFailAll(new IllegalStateException());
        } else {
            ByteBuf buffer = writeQueue.removeFirst(voidPromise);
            assertEquals(1, buffer.readByte());
            assertEquals(2, buffer.readByte());
            assertEquals(3, buffer.readByte());
            assertFalse(buffer.isReadable());
            buffer.release();
            assertTrue(channel.isWritable());

            buffer = writeQueue.removeFirst(voidPromise);
            assertEquals(4, buffer.readByte());
            assertEquals(5, buffer.readByte());
            assertFalse(buffer.isReadable());
            buffer.release();
        }

        assertTrue(channel.isWritable());
        assertTrue(writeQueue.isEmpty());
    }

Domain

Subdomains

Defined In

Called By

Source

Frequently Asked Questions

What does testWritabilityChanged0() do?
testWritabilityChanged0() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/CoalescingBufferQueueTest.java.
Where is testWritabilityChanged0() defined?
testWritabilityChanged0() is defined in transport/src/test/java/io/netty/channel/CoalescingBufferQueueTest.java at line 265.
What calls testWritabilityChanged0()?
testWritabilityChanged0() is called by 2 function(s): testWritabilityChanged, testWritabilityChangedFailAll.

Analyze Your Own Codebase

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

Try Supermodel Free