channelRead() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 1

Entity Profile

Buffer→ Telemetry→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  2a2ccd44_c11c_349c_5ccf_54de69e96fa2["channelRead()"]
  c6804a8c_0e01_672c_fdc2_bb603d65f827["MessageForwarder2"]
  2a2ccd44_c11c_349c_5ccf_54de69e96fa2 -->|defined in| c6804a8c_0e01_672c_fdc2_bb603d65f827
  21df8cff_661b_dc5c_d5ca_b938b93a4e5c["channelRead()"]
  21df8cff_661b_dc5c_d5ca_b938b93a4e5c -->|calls| 2a2ccd44_c11c_349c_5ccf_54de69e96fa2
  21df8cff_661b_dc5c_d5ca_b938b93a4e5c["channelRead()"]
  2a2ccd44_c11c_349c_5ccf_54de69e96fa2 -->|calls| 21df8cff_661b_dc5c_d5ca_b938b93a4e5c
  style 2a2ccd44_c11c_349c_5ccf_54de69e96fa2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java lines 481–499

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            Thread t = this.t;
            if (t == null) {
                this.t = Thread.currentThread();
            } else {
                assertSame(t, Thread.currentThread());
            }

            ByteBuf m = (ByteBuf) msg;
            int count = m.readableBytes() / 4;
            for (int j = 0; j < count; j ++) {
                int actual = m.readInt();
                int expected = inCnt ++;
                assertEquals(expected, actual);
                ctx.fireChannelRead(actual);
            }
            m.release();
        }