handleFuture() — netty Function Reference

Architecture documentation for the handleFuture() function in ChunkedWriteHandler.java from the netty codebase.

Function java Buffer Search calls 4 called by 1

Entity Profile

Buffer→ Search→ handleFuture() — netty Function Reference

Dependency Diagram

graph TD
  71234431_8f6b_489e_5bcd_2f90a680e153["handleFuture()"]
  1e2ef44e_6c44_8584_e44f_ddda636afcfc["ChunkedWriteHandler"]
  71234431_8f6b_489e_5bcd_2f90a680e153 -->|defined in| 1e2ef44e_6c44_8584_e44f_ddda636afcfc
  fea31415_af69_2ea8_b80b_97ecc8e7b566["doFlush()"]
  fea31415_af69_2ea8_b80b_97ecc8e7b566 -->|calls| 71234431_8f6b_489e_5bcd_2f90a680e153
  53f15a4d_7833_59bc_0644_b2f3ba06936e["closeInput()"]
  71234431_8f6b_489e_5bcd_2f90a680e153 -->|calls| 53f15a4d_7833_59bc_0644_b2f3ba06936e
  570121a6_3ee2_7394_cad2_8834a8f7c228["fail()"]
  71234431_8f6b_489e_5bcd_2f90a680e153 -->|calls| 570121a6_3ee2_7394_cad2_8834a8f7c228
  464c9d74_679e_a677_e746_4716bb059494["progress()"]
  71234431_8f6b_489e_5bcd_2f90a680e153 -->|calls| 464c9d74_679e_a677_e746_4716bb059494
  45bb37e1_092c_fe4b_5902_ebc8bbf2c033["resumeTransfer()"]
  71234431_8f6b_489e_5bcd_2f90a680e153 -->|calls| 45bb37e1_092c_fe4b_5902_ebc8bbf2c033
  style 71234431_8f6b_489e_5bcd_2f90a680e153 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java lines 344–354

    private void handleFuture(ChannelFuture future, ChunkedInput<?> input, PendingWrite currentWrite, boolean resume) {
        if (!future.isSuccess()) {
            closeInput(input);
            currentWrite.fail(future.cause());
        } else {
            currentWrite.progress(input.progress(), input.length());
            if (resume && future.channel().isWritable()) {
                resumeTransfer();
            }
        }
    }