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

flowControlledWriteThrowsAnException() — netty Function Reference

Architecture documentation for the flowControlledWriteThrowsAnException() function in DefaultHttp2RemoteFlowControllerTest.java from the netty codebase.

Function java Buffer Allocators calls 5

Entity Profile

Dependency Diagram

graph TD
  c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011["flowControlledWriteThrowsAnException()"]
  f8fd7697_92d4_6455_4dd8_09a33ac81a6f["DefaultHttp2RemoteFlowControllerTest"]
  c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011 -->|defined in| f8fd7697_92d4_6455_4dd8_09a33ac81a6f
  8a4c41bb_e902_5338_7f69_db8f445233a4["mockedFlowControlledThatThrowsOnWrite()"]
  c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011 -->|calls| 8a4c41bb_e902_5338_7f69_db8f445233a4
  46be14d4_2ad4_2dfe_fa3e_2212c0d8e50e["error()"]
  c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011 -->|calls| 46be14d4_2ad4_2dfe_fa3e_2212c0d8e50e
  72f6527f_6737_5bc4_f643_b308fe4de273["window()"]
  c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011 -->|calls| 72f6527f_6737_5bc4_f643_b308fe4de273
  abf1bc09_403f_110e_0b96_d73f451a8f8b["write()"]
  c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011 -->|calls| abf1bc09_403f_110e_0b96_d73f451a8f8b
  5af4576c_23ff_8e3b_df41_9d71757029eb["writeComplete()"]
  c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011 -->|calls| 5af4576c_23ff_8e3b_df41_9d71757029eb
  style c54d2ec1_4be3_d9d9_eaa8_c424d2a7d011 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/test/java/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowControllerTest.java lines 691–721

    @Test
    public void flowControlledWriteThrowsAnException() throws Exception {
        final Http2RemoteFlowController.FlowControlled flowControlled = mockedFlowControlledThatThrowsOnWrite();
        final Http2Stream stream = stream(STREAM_A);
        doAnswer(new Answer<Void>() {
            @Override
            public Void answer(InvocationOnMock invocationOnMock) {
                stream.closeLocalSide();
                return null;
            }
        }).when(flowControlled).error(any(ChannelHandlerContext.class), any(Throwable.class));

        int windowBefore = window(STREAM_A);

        controller.addFlowControlled(stream, flowControlled);
        controller.writePendingBytes();

        verify(flowControlled, atLeastOnce()).write(any(ChannelHandlerContext.class), anyInt());
        verify(flowControlled).error(any(ChannelHandlerContext.class), any(Throwable.class));
        verify(flowControlled, never()).writeComplete();

        assertEquals(90, windowBefore - window(STREAM_A));
        verify(listener, times(1)).writabilityChanged(stream(STREAM_A));
        verify(listener, never()).writabilityChanged(stream(STREAM_B));
        verify(listener, never()).writabilityChanged(stream(STREAM_C));
        verify(listener, never()).writabilityChanged(stream(STREAM_D));
        assertFalse(controller.isWritable(stream(STREAM_A)));
        assertTrue(controller.isWritable(stream(STREAM_B)));
        assertTrue(controller.isWritable(stream(STREAM_C)));
        assertTrue(controller.isWritable(stream(STREAM_D)));
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does flowControlledWriteThrowsAnException() do?
flowControlledWriteThrowsAnException() is a function in the netty codebase, defined in codec-http2/src/test/java/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowControllerTest.java.
Where is flowControlledWriteThrowsAnException() defined?
flowControlledWriteThrowsAnException() is defined in codec-http2/src/test/java/io/netty/handler/codec/http2/DefaultHttp2RemoteFlowControllerTest.java at line 691.
What does flowControlledWriteThrowsAnException() call?
flowControlledWriteThrowsAnException() calls 5 function(s): error, mockedFlowControlledThatThrowsOnWrite, window, write, writeComplete.

Analyze Your Own Codebase

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

Try Supermodel Free