testReleaseAndFailAll() — netty Function Reference

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

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ testReleaseAndFailAll() — netty Function Reference

Dependency Diagram

graph TD
  36f6f2b2_aa0e_bfb6_2300_393325050da8["testReleaseAndFailAll()"]
  ccc522b2_7fa1_bc1b_d4b4_2b255b9936f9["CoalescingBufferQueueTest"]
  36f6f2b2_aa0e_bfb6_2300_393325050da8 -->|defined in| ccc522b2_7fa1_bc1b_d4b4_2b255b9936f9
  f9a9510c_fde3_46f3_be9a_be659d967b32["assertQueueSize()"]
  36f6f2b2_aa0e_bfb6_2300_393325050da8 -->|calls| f9a9510c_fde3_46f3_be9a_be659d967b32
  style 36f6f2b2_aa0e_bfb6_2300_393325050da8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/CoalescingBufferQueueTest.java lines 202–215

    @Test
    public void testReleaseAndFailAll() {
        writeQueue.add(cat, catPromise);
        writeQueue.add(mouse, mouseListener);
        RuntimeException cause = new RuntimeException("ooops");
        writeQueue.releaseAndFailAll(cause);
        ChannelPromise aggregatePromise = newPromise();
        assertQueueSize(0, true);
        assertEquals(0, cat.refCnt());
        assertEquals(0, mouse.refCnt());
        assertSame(cause, catPromise.cause());
        assertEquals("", dequeue(Integer.MAX_VALUE, aggregatePromise));
        assertQueueSize(0, true);
    }