assertWriteFails() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 2

Entity Profile

Buffer→ Telemetry→ assertWriteFails() — netty Function Reference

Dependency Diagram

graph TD
  a15cb8aa_da0e_04bd_0ac5_a8d7aa185f5d["assertWriteFails()"]
  b4bff24e_be13_7693_4ece_a0ed5ee1a982["PendingWriteQueueTest"]
  a15cb8aa_da0e_04bd_0ac5_a8d7aa185f5d -->|defined in| b4bff24e_be13_7693_4ece_a0ed5ee1a982
  da6d76e6_7544_937d_2e9e_ee10dfd26fc8["testRemoveAndFail()"]
  da6d76e6_7544_937d_2e9e_ee10dfd26fc8 -->|calls| a15cb8aa_da0e_04bd_0ac5_a8d7aa185f5d
  72fc6ad4_24b4_e4a8_af5e_0dafe04e828a["testRemoveAndFailAll()"]
  72fc6ad4_24b4_e4a8_af5e_0dafe04e828a -->|calls| a15cb8aa_da0e_04bd_0ac5_a8d7aa185f5d
  21f29e3d_6bf2_8663_b27c_0cf9f480f48f["EmbeddedChannel()"]
  a15cb8aa_da0e_04bd_0ac5_a8d7aa185f5d -->|calls| 21f29e3d_6bf2_8663_b27c_0cf9f480f48f
  style a15cb8aa_da0e_04bd_0ac5_a8d7aa185f5d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java lines 177–195

    private static void assertWriteFails(ChannelHandler handler, int count) {
        final ByteBuf buffer = Unpooled.copiedBuffer("Test", CharsetUtil.US_ASCII);
        final EmbeddedChannel channel = new EmbeddedChannel(handler);
        ByteBuf[] buffers = new ByteBuf[count];
        for (int i = 0; i < buffers.length; i++) {
            buffers[i] = buffer.retainedDuplicate();
        }
        try {
            assertFalse(channel.writeOutbound(buffers));
            fail();
        } catch (Exception e) {
            assertTrue(e instanceof TestException);
        }
        assertFalse(channel.finish());
        channel.closeFuture().syncUninterruptibly();

        buffer.release();
        assertNull(channel.readOutbound());
    }