process() — netty Function Reference

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

Function java Buffer Allocators calls 3

Entity Profile

Buffer→ Allocators→ process() — netty Function Reference

Dependency Diagram

graph TD
  4824392d_a198_0181_954d_ca040d8a34a2["process()"]
  eeed1a5a_1d35_83c8_45ce_8c475562fe14["QuicCodecHeaderProcessor"]
  4824392d_a198_0181_954d_ca040d8a34a2 -->|defined in| eeed1a5a_1d35_83c8_45ce_8c475562fe14
  eb356f3e_b5bc_e7dc_c521_bdfa562a6d05["channelReadComplete()"]
  4824392d_a198_0181_954d_ca040d8a34a2 -->|calls| eb356f3e_b5bc_e7dc_c521_bdfa562a6d05
  966b653b_5a97_7901_954c_a7dc1583b98b["removeMapping()"]
  4824392d_a198_0181_954d_ca040d8a34a2 -->|calls| 966b653b_5a97_7901_954c_a7dc1583b98b
  9e15dc20_3de4_1ecb_b005_4375cfcd303e["addMapping()"]
  4824392d_a198_0181_954d_ca040d8a34a2 -->|calls| 9e15dc20_3de4_1ecb_b005_4375cfcd303e
  style 4824392d_a198_0181_954d_ca040d8a34a2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/QuicheQuicCodec.java lines 358–378

        @Override
        public void process(InetSocketAddress sender, InetSocketAddress recipient, ByteBuf buffer, QuicPacketType type,
                            long version, ByteBuf scid, ByteBuf dcid, ByteBuf token) throws Exception {
            QuicheQuicChannel channel = quicPacketRead(ctx, sender, recipient,
                    type, version, scid,
                    dcid, token, senderSockaddrMemory, recipientSockaddrMemory, freeTask, localConnIdLength, config);
            if (channel != null) {
                // Add to queue first, we might be able to safe some flushes and consolidate them
                // in channelReadComplete(...) this way.
                if (channel.markInFireChannelReadCompleteQueue()) {
                    needsFireChannelReadComplete.add(channel);
                }
                channel.recv(sender, recipient, buffer);
                for (ByteBuffer retiredSourceConnectionId : channel.retiredSourceConnectionId()) {
                    removeMapping(channel, retiredSourceConnectionId);
                }
                for (ByteBuffer newSourceConnectionId : channel.newSourceConnectionIds()) {
                    addMapping(channel, newSourceConnectionId);
                }
            }
        }