init() — netty Function Reference

Architecture documentation for the init() function in AbstractChannelHandlerContext.java from the netty codebase.

Function java Buffer Search called by 1

Entity Profile

Buffer→ Search→ init() — netty Function Reference

Dependency Diagram

graph TD
  f49a7f61_b55c_10d0_a9f5_691a2c5eae69["init()"]
  5e541a04_978d_cf2e_cfd4_e2add246c7cf["WriteTask"]
  f49a7f61_b55c_10d0_a9f5_691a2c5eae69 -->|defined in| 5e541a04_978d_cf2e_cfd4_e2add246c7cf
  6c3e4aa6_2bb5_0dfe_9566_1e5707467753["WriteTask()"]
  6c3e4aa6_2bb5_0dfe_9566_1e5707467753 -->|calls| f49a7f61_b55c_10d0_a9f5_691a2c5eae69
  style f49a7f61_b55c_10d0_a9f5_691a2c5eae69 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/AbstractChannelHandlerContext.java lines 1105–1120

        static void init(WriteTask task, AbstractChannelHandlerContext ctx,
                                   Object msg, ChannelPromise promise, boolean flush) {
            task.ctx = ctx;
            task.msg = msg;
            task.promise = promise;

            if (ESTIMATE_TASK_SIZE_ON_SUBMIT) {
                task.size = ctx.pipeline.estimatorHandle().size(msg) + WRITE_TASK_OVERHEAD;
                ctx.pipeline.incrementPendingOutboundBytes(task.size);
            } else {
                task.size = 0;
            }
            if (flush) {
                task.size |= Integer.MIN_VALUE;
            }
        }