error() — netty Function Reference

Architecture documentation for the error() function in DefaultHttp2ConnectionEncoder.java from the netty codebase.

Function java Buffer Allocators calls 3 called by 3

Entity Profile

Buffer→ Allocators→ error() — netty Function Reference

Dependency Diagram

graph TD
  477efeff_1ae4_5595_d4ec_eae3cb151ba9["error()"]
  3f967aaa_cd4e_4486_0912_7a9f57cfa847["FlowControlledData"]
  477efeff_1ae4_5595_d4ec_eae3cb151ba9 -->|defined in| 3f967aaa_cd4e_4486_0912_7a9f57cfa847
  68ae7f94_6431_c8f3_425c_0abbb5fa9c40["error()"]
  68ae7f94_6431_c8f3_425c_0abbb5fa9c40 -->|calls| 477efeff_1ae4_5595_d4ec_eae3cb151ba9
  00bd83d0_dcec_5387_7a17_1c0f317ff485["write()"]
  00bd83d0_dcec_5387_7a17_1c0f317ff485 -->|calls| 477efeff_1ae4_5595_d4ec_eae3cb151ba9
  9fe992cb_c48d_71ef_fb5a_5f309c368f12["operationComplete()"]
  9fe992cb_c48d_71ef_fb5a_5f309c368f12 -->|calls| 477efeff_1ae4_5595_d4ec_eae3cb151ba9
  68ae7f94_6431_c8f3_425c_0abbb5fa9c40["error()"]
  477efeff_1ae4_5595_d4ec_eae3cb151ba9 -->|calls| 68ae7f94_6431_c8f3_425c_0abbb5fa9c40
  056b4816_0b1f_9d07_6136_4efe950e0c59["size()"]
  477efeff_1ae4_5595_d4ec_eae3cb151ba9 -->|calls| 056b4816_0b1f_9d07_6136_4efe950e0c59
  00bd83d0_dcec_5387_7a17_1c0f317ff485["write()"]
  477efeff_1ae4_5595_d4ec_eae3cb151ba9 -->|calls| 00bd83d0_dcec_5387_7a17_1c0f317ff485
  style 477efeff_1ae4_5595_d4ec_eae3cb151ba9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/DefaultHttp2ConnectionEncoder.java lines 457–466

        @Override
        public void error(ChannelHandlerContext ctx, Throwable cause) {
            queue.releaseAndFailAll(cause);
            // Don't update dataSize because we need to ensure the size() method returns a consistent size even after
            // error so we don't invalidate flow control when returning bytes to flow control.
            //
            // That said we will set dataSize and padding to 0 in the write(...) method if we cleared the queue
            // because of an error.
            lifecycleManager.onError(ctx, true, cause);
        }