readInbound() — netty Function Reference

Architecture documentation for the readInbound() function in LocalServerChannel.java from the netty codebase.

Function java Buffer Telemetry called by 2

Entity Profile

Buffer→ Telemetry→ readInbound() — netty Function Reference

Dependency Diagram

graph TD
  ba3d7bea_4e73_6fe6_7d58_6e4d2f32a3bb["readInbound()"]
  1a58c560_dde9_7403_e4d4_f9cf37a89c81["LocalServerChannel"]
  ba3d7bea_4e73_6fe6_7d58_6e4d2f32a3bb -->|defined in| 1a58c560_dde9_7403_e4d4_f9cf37a89c81
  ac807b6d_7c14_ae81_c681_496ac42f3bcf["doBeginRead()"]
  ac807b6d_7c14_ae81_c681_496ac42f3bcf -->|calls| ba3d7bea_4e73_6fe6_7d58_6e4d2f32a3bb
  4cc6f81f_3b42_da30_571e_52baf4663bcb["serve0()"]
  4cc6f81f_3b42_da30_571e_52baf4663bcb -->|calls| ba3d7bea_4e73_6fe6_7d58_6e4d2f32a3bb
  style ba3d7bea_4e73_6fe6_7d58_6e4d2f32a3bb fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/local/LocalServerChannel.java lines 186–199

    private void readInbound() {
        RecvByteBufAllocator.Handle handle = unsafe().recvBufAllocHandle();
        handle.reset(config());
        ChannelPipeline pipeline = pipeline();
        do {
            Object m = inboundBuffer.poll();
            if (m == null) {
                break;
            }
            pipeline.fireChannelRead(m);
        } while (handle.continueReading());
        handle.readComplete();
        pipeline.fireChannelReadComplete();
    }