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
  85f17597_0918_a0c8_297d_c8f56617c6be["channelRead()"]
  5d9bf869_26ee_1468_df42_d7b387c194da["MessageForwarder3"]
  85f17597_0918_a0c8_297d_c8f56617c6be -->|defined in| 5d9bf869_26ee_1468_df42_d7b387c194da
  5ea4e278_c514_a36b_6c1c_694d3d15be6d["channelRead()"]
  5ea4e278_c514_a36b_6c1c_694d3d15be6d -->|calls| 85f17597_0918_a0c8_297d_c8f56617c6be
  6348c4c7_af5b_1906_cb20_8d15cf666108["channelRead()"]
  6348c4c7_af5b_1906_cb20_8d15cf666108 -->|calls| 85f17597_0918_a0c8_297d_c8f56617c6be
  21df8cff_661b_dc5c_d5ca_b938b93a4e5c["channelRead()"]
  85f17597_0918_a0c8_297d_c8f56617c6be -->|calls| 21df8cff_661b_dc5c_d5ca_b938b93a4e5c
  style 85f17597_0918_a0c8_297d_c8f56617c6be fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java lines 533–547

        @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());
            }

            int actual = (Integer) msg;
            int expected = inCnt ++;
            assertEquals(expected, actual);

            ctx.fireChannelRead(msg);
        }