flush() — netty Function Reference

Architecture documentation for the flush() function in Http2ConnectionHandler.java from the netty codebase.

Function java Buffer Allocators calls 1 called by 5

Entity Profile

Buffer→ Allocators→ flush() — netty Function Reference

Dependency Diagram

graph TD
  fcfd6790_7b31_2514_7e7e_6ee61c0daff9["flush()"]
  a9ab361d_2417_0366_d9d0_ae1adb2145dc["Http2ConnectionHandler"]
  fcfd6790_7b31_2514_7e7e_6ee61c0daff9 -->|defined in| a9ab361d_2417_0366_d9d0_ae1adb2145dc
  a211866a_e0ad_b29c_796d_0e206d3e3f14["channelWritabilityChanged()"]
  a211866a_e0ad_b29c_796d_0e206d3e3f14 -->|calls| fcfd6790_7b31_2514_7e7e_6ee61c0daff9
  859f94fe_ed5e_1249_ef66_7ee4bcad0137["close()"]
  859f94fe_ed5e_1249_ef66_7ee4bcad0137 -->|calls| fcfd6790_7b31_2514_7e7e_6ee61c0daff9
  aae0aa7f_2029_08c9_f24d_05375655c19d["channelReadComplete()"]
  aae0aa7f_2029_08c9_f24d_05375655c19d -->|calls| fcfd6790_7b31_2514_7e7e_6ee61c0daff9
  c019b218_592f_da69_100d_79381ffa0e04["onError()"]
  c019b218_592f_da69_100d_79381ffa0e04 -->|calls| fcfd6790_7b31_2514_7e7e_6ee61c0daff9
  f123ca8d_4393_d5af_4aa4_bd6bee27eb0e["channelActive()"]
  f123ca8d_4393_d5af_4aa4_bd6bee27eb0e -->|calls| fcfd6790_7b31_2514_7e7e_6ee61c0daff9
  c019b218_592f_da69_100d_79381ffa0e04["onError()"]
  fcfd6790_7b31_2514_7e7e_6ee61c0daff9 -->|calls| c019b218_592f_da69_100d_79381ffa0e04
  style fcfd6790_7b31_2514_7e7e_6ee61c0daff9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-http2/src/main/java/io/netty/handler/codec/http2/Http2ConnectionHandler.java lines 190–201

    @Override
    public void flush(ChannelHandlerContext ctx) {
        try {
            // Trigger pending writes in the remote flow controller.
            encoder.flowController().writePendingBytes();
            ctx.flush();
        } catch (Http2Exception e) {
            onError(ctx, true, e);
        } catch (Throwable cause) {
            onError(ctx, true, connectionError(INTERNAL_ERROR, cause, "Error flushing"));
        }
    }