channelRead() — netty Function Reference

Architecture documentation for the channelRead() function in FlowControlHandler.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  ab1fcb76_21ea_cee4_50e0_0d3247fda36a["channelRead()"]
  a378d3b4_7977_a8fc_c1dd_b695ec779172["FlowControlHandler"]
  ab1fcb76_21ea_cee4_50e0_0d3247fda36a -->|defined in| a378d3b4_7977_a8fc_c1dd_b695ec779172
  f4d16c7c_e26b_f445_c529_6abbac58ed56["read()"]
  ab1fcb76_21ea_cee4_50e0_0d3247fda36a -->|calls| f4d16c7c_e26b_f445_c529_6abbac58ed56
  231cc677_f63d_f911_377d_62f5edbedf36["dequeue()"]
  ab1fcb76_21ea_cee4_50e0_0d3247fda36a -->|calls| 231cc677_f63d_f911_377d_62f5edbedf36
  style ab1fcb76_21ea_cee4_50e0_0d3247fda36a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/flow/FlowControlHandler.java lines 149–164

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (queue == null) {
            queue = RecyclableArrayDeque.newInstance();
        }

        queue.offer(msg);

        // We just received one message. Do we need to relay it regardless
        // of the auto reading configuration? The answer is yes if this
        // method was called as a result of a prior read() call.
        int minConsume = shouldConsume ? 1 : 0;
        shouldConsume = false;

        dequeue(ctx, minConsume);
    }