write() — netty Function Reference

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

Function java Buffer Search calls 3 called by 1

Entity Profile

Buffer→ Search→ write() — netty Function Reference

Dependency Diagram

graph TD
  8772a3c8_0f59_0a18_cfc7_49c932daeefd["write()"]
  1e2ef44e_6c44_8584_e44f_ddda636afcfc["ChunkedWriteHandler"]
  8772a3c8_0f59_0a18_cfc7_49c932daeefd -->|defined in| 1e2ef44e_6c44_8584_e44f_ddda636afcfc
  fea31415_af69_2ea8_b80b_97ecc8e7b566["doFlush()"]
  fea31415_af69_2ea8_b80b_97ecc8e7b566 -->|calls| 8772a3c8_0f59_0a18_cfc7_49c932daeefd
  59e2cd7c_239b_2a62_529d_0c2d9e0ea412["queueIsEmpty()"]
  8772a3c8_0f59_0a18_cfc7_49c932daeefd -->|calls| 59e2cd7c_239b_2a62_529d_0c2d9e0ea412
  efa9902f_a95f_6452_f3cd_2cf326c0b0dd["allocateQueue()"]
  8772a3c8_0f59_0a18_cfc7_49c932daeefd -->|calls| efa9902f_a95f_6452_f3cd_2cf326c0b0dd
  96086933_1722_67e7_ad82_bd96edd4e5fd["PendingWrite()"]
  8772a3c8_0f59_0a18_cfc7_49c932daeefd -->|calls| 96086933_1722_67e7_ad82_bd96edd4e5fd
  style 8772a3c8_0f59_0a18_cfc7_49c932daeefd fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java lines 134–142

    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        if (!queueIsEmpty() || msg instanceof ChunkedInput) {
            allocateQueue();
            queue.add(new PendingWrite(msg, promise));
        } else {
            ctx.write(msg, promise);
        }
    }