resumeTransfer() — netty Function Reference

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

Function java Buffer Search calls 1 called by 1

Entity Profile

Buffer→ Search→ resumeTransfer() — netty Function Reference

Dependency Diagram

graph TD
  45bb37e1_092c_fe4b_5902_ebc8bbf2c033["resumeTransfer()"]
  1e2ef44e_6c44_8584_e44f_ddda636afcfc["ChunkedWriteHandler"]
  45bb37e1_092c_fe4b_5902_ebc8bbf2c033 -->|defined in| 1e2ef44e_6c44_8584_e44f_ddda636afcfc
  71234431_8f6b_489e_5bcd_2f90a680e153["handleFuture()"]
  71234431_8f6b_489e_5bcd_2f90a680e153 -->|calls| 45bb37e1_092c_fe4b_5902_ebc8bbf2c033
  046072d4_e093_33e5_660c_bf415febf6ae["resumeTransfer0()"]
  45bb37e1_092c_fe4b_5902_ebc8bbf2c033 -->|calls| 046072d4_e093_33e5_660c_bf415febf6ae
  style 45bb37e1_092c_fe4b_5902_ebc8bbf2c033 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java lines 107–124

    public void resumeTransfer() {
        final ChannelHandlerContext ctx = this.ctx;
        if (ctx == null) {
            return;
        }
        if (ctx.executor().inEventLoop()) {
            resumeTransfer0(ctx);
        } else {
            // let the transfer resume on the next event loop round
            ctx.executor().execute(new Runnable() {

                @Override
                public void run() {
                    resumeTransfer0(ctx);
                }
            });
        }
    }