channelRead() — netty Function Reference

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

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ channelRead() — netty Function Reference

Dependency Diagram

graph TD
  b4b40aa7_37e1_09d9_4fa6_f666164fe98d["channelRead()"]
  2593916d_2b0e_6fcc_eac7_86416a14767c["QuicheQuicCodec"]
  b4b40aa7_37e1_09d9_4fa6_f666164fe98d -->|defined in| 2593916d_2b0e_6fcc_eac7_86416a14767c
  ff90365d_5709_977b_5a5e_bdd13a1e7dd8["handleQuicPacket()"]
  b4b40aa7_37e1_09d9_4fa6_f666164fe98d -->|calls| ff90365d_5709_977b_5a5e_bdd13a1e7dd8
  style b4b40aa7_37e1_09d9_4fa6_f666164fe98d fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/QuicheQuicCodec.java lines 175–196

    @Override
    public final void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        DatagramPacket packet = (DatagramPacket) msg;
        try {
            ByteBuf buffer = ((DatagramPacket) msg).content();
            if (!buffer.isDirect()) {
                // We need a direct buffer as otherwise we can not access the memoryAddress.
                // Let's do a copy to direct memory.
                ByteBuf direct = ctx.alloc().directBuffer(buffer.readableBytes());
                try {
                    direct.writeBytes(buffer, buffer.readerIndex(), buffer.readableBytes());
                    handleQuicPacket(packet.sender(), packet.recipient(), direct);
                } finally {
                    direct.release();
                }
            } else {
                handleQuicPacket(packet.sender(), packet.recipient(), buffer);
            }
        } finally {
            packet.release();
        }
    }