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

testRemoveAndFailAllReentrantWrite() — netty Function Reference

Architecture documentation for the testRemoveAndFailAllReentrantWrite() function in PendingWriteQueueTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Dependency Diagram

graph TD
  c7f7fbd1_ee3f_0f7c_a38f_0ff5dfe48ad7["testRemoveAndFailAllReentrantWrite()"]
  b4bff24e_be13_7693_4ece_a0ed5ee1a982["PendingWriteQueueTest"]
  c7f7fbd1_ee3f_0f7c_a38f_0ff5dfe48ad7 -->|defined in| b4bff24e_be13_7693_4ece_a0ed5ee1a982
  style c7f7fbd1_ee3f_0f7c_a38f_0ff5dfe48ad7 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java lines 277–306

    @Test
    public void testRemoveAndFailAllReentrantWrite() {
        final List<Integer> failOrder = Collections.synchronizedList(new ArrayList<Integer>());
        EmbeddedChannel channel = newChannel();
        final PendingWriteQueue queue = new PendingWriteQueue(channel.pipeline().firstContext());

        ChannelPromise promise = channel.newPromise();
        final ChannelPromise promise3 = channel.newPromise();
        promise3.addListener(future -> failOrder.add(3));
        promise.addListener(future -> {
            failOrder.add(1);
            queue.add(3L, promise3);
        });
        queue.add(1L, promise);

        ChannelPromise promise2 = channel.newPromise();
        promise2.addListener(future -> failOrder.add(2));
        queue.add(2L, promise2);
        queue.removeAndFailAll(new Exception());
        assertTrue(promise.isDone());
        assertFalse(promise.isSuccess());
        assertTrue(promise2.isDone());
        assertFalse(promise2.isSuccess());
        assertTrue(promise3.isDone());
        assertFalse(promise3.isSuccess());
        assertFalse(channel.finish());
        assertEquals(1, (int) failOrder.get(0));
        assertEquals(2, (int) failOrder.get(1));
        assertEquals(3, (int) failOrder.get(2));
    }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does testRemoveAndFailAllReentrantWrite() do?
testRemoveAndFailAllReentrantWrite() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java.
Where is testRemoveAndFailAllReentrantWrite() defined?
testRemoveAndFailAllReentrantWrite() is defined in transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java at line 277.

Analyze Your Own Codebase

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

Try Supermodel Free