channelRead() — netty Function Reference

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

Function java Buffer Search calls 1 called by 2

Entity Profile

Buffer→ Search→ channelRead() — netty Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java lines 423–439

        @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 out = ctx.alloc().buffer(4);
            int m = ((Integer) msg).intValue();
            int expected = inCnt ++;
            assertEquals(expected, m);
            out.writeInt(m);

            ctx.fireChannelRead(out);
        }