channelRead() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  0e711db4_2323_9b60_83ee_b0667227d32f["channelRead()"]
  550dceea_3958_0e89_1405_ee683da73397["QuicCodecDispatcher"]
  0e711db4_2323_9b60_83ee_b0667227d32f -->|defined in| 550dceea_3958_0e89_1405_ee683da73397
  899a505d_01d9_8f4d_237d_520e0f5fbaef["decodeIndex()"]
  0e711db4_2323_9b60_83ee_b0667227d32f -->|calls| 899a505d_01d9_8f4d_237d_520e0f5fbaef
  68ed6307_0f73_86c8_0e40_fa33ea7b52d6["fireChannelRead()"]
  0e711db4_2323_9b60_83ee_b0667227d32f -->|calls| 68ed6307_0f73_86c8_0e40_fa33ea7b52d6
  style 0e711db4_2323_9b60_83ee_b0667227d32f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/QuicCodecDispatcher.java lines 117–134

    @Override
    public final void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        DatagramPacket packet = (DatagramPacket) msg;
        ByteBuf connectionId = getDestinationConnectionId(packet.content(), localConnectionIdLength);
        if (connectionId != null) {
            int idx = decodeIndex(connectionId);
            if (contextList.size() > idx) {
                ChannelHandlerContextDispatcher selectedCtx = contextList.get(idx);
                if (selectedCtx != null) {
                    selectedCtx.fireChannelRead(msg);
                    return;
                }
            }
        }
        // We were not be-able to dispatch to a specific ChannelHandlerContext, just forward and let the
        // Quic*Codec handle it directly.
        ctx.fireChannelRead(msg);
    }