recv() — netty Function Reference

Architecture documentation for the recv() function in QuicheQuicChannel.java from the netty codebase.

Function java Buffer Allocators calls 4 called by 1

Entity Profile

Buffer→ Allocators→ recv() — netty Function Reference

Dependency Diagram

graph TD
  0e1ca299_ed3d_8a6d_bf55_50ab173c29d7["recv()"]
  981bac79_4fa5_9e57_50c8_e12d0b35f6d4["QuicChannelUnsafe"]
  0e1ca299_ed3d_8a6d_bf55_50ab173c29d7 -->|defined in| 981bac79_4fa5_9e57_50c8_e12d0b35f6d4
  8694896e_30ff_0192_2de2_f7fc29767efb["recv()"]
  8694896e_30ff_0192_2de2_f7fc29767efb -->|calls| 0e1ca299_ed3d_8a6d_bf55_50ab173c29d7
  8694896e_30ff_0192_2de2_f7fc29767efb["recv()"]
  0e1ca299_ed3d_8a6d_bf55_50ab173c29d7 -->|calls| 8694896e_30ff_0192_2de2_f7fc29767efb
  7ed04228_8203_18ea_57b2_766b3ee23bb7["recvDatagram()"]
  0e1ca299_ed3d_8a6d_bf55_50ab173c29d7 -->|calls| 7ed04228_8203_18ea_57b2_766b3ee23bb7
  4c5c4c1a_01ba_f361_2baa_f00270cfb942["recvStream()"]
  0e1ca299_ed3d_8a6d_bf55_50ab173c29d7 -->|calls| 4c5c4c1a_01ba_f361_2baa_f00270cfb942
  3dcfc37a_37ed_432a_46ba_dfae500fd8f0["fireChannelReadCompleteIfNeeded()"]
  0e1ca299_ed3d_8a6d_bf55_50ab173c29d7 -->|calls| 3dcfc37a_37ed_432a_46ba_dfae500fd8f0
  style 0e1ca299_ed3d_8a6d_bf55_50ab173c29d7 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-classes-quic/src/main/java/io/netty/handler/codec/quic/QuicheQuicChannel.java lines 1800–1821

        void recv() {
            QuicheQuicConnection conn = connection;
            if ((reantranceGuard & IN_RECV) != 0 || conn.isFreed()) {
                return;
            }

            long connAddr = conn.address();
            // Check if we can read anything yet.
            if (!Quiche.quiche_conn_is_established(connAddr) &&
                    !Quiche.quiche_conn_is_in_early_data(connAddr)) {
                return;
            }

            reantranceGuard |= IN_RECV;
            try {
                recvDatagram(conn);
                recvStream(conn);
            } finally {
                fireChannelReadCompleteIfNeeded();
                reantranceGuard &= ~IN_RECV;
            }
        }