Lines Matching refs:chunk
2049 QUIC_TXPIM_CHUNK chunk = {0}; in txp_generate_crypto_frames() local
2113 chunk.stream_id = UINT64_MAX; /* crypto stream */ in txp_generate_crypto_frames()
2114 chunk.start = chdr.offset; in txp_generate_crypto_frames()
2115 chunk.end = chdr.offset + chdr.len - 1; in txp_generate_crypto_frames()
2116 chunk.has_fin = 0; /* Crypto stream never ends */ in txp_generate_crypto_frames()
2117 if (!ossl_quic_txpim_pkt_append_chunk(tpkt, &chunk)) in txp_generate_crypto_frames()
2135 struct chunk_info *chunk, in txp_plan_stream_chunk() argument
2140 chunk->num_stream_iovec = OSSL_NELEM(chunk->iov); in txp_plan_stream_chunk()
2141 chunk->valid = ossl_quic_sstream_get_stream_frame(sstream, skip, in txp_plan_stream_chunk()
2142 &chunk->shdr, in txp_plan_stream_chunk()
2143 chunk->iov, in txp_plan_stream_chunk()
2144 &chunk->num_stream_iovec); in txp_plan_stream_chunk()
2145 if (!chunk->valid) in txp_plan_stream_chunk()
2148 if (!ossl_assert(chunk->shdr.len > 0 || chunk->shdr.is_fin)) in txp_plan_stream_chunk()
2152 chunk->orig_len = chunk->shdr.len; in txp_plan_stream_chunk()
2159 if (chunk->shdr.len > 0 && chunk->shdr.offset + chunk->shdr.len > fc_limit) { in txp_plan_stream_chunk()
2160 chunk->shdr.len = (fc_limit <= chunk->shdr.offset) in txp_plan_stream_chunk()
2161 ? 0 : fc_limit - chunk->shdr.offset; in txp_plan_stream_chunk()
2162 chunk->shdr.is_fin = 0; in txp_plan_stream_chunk()
2165 if (chunk->shdr.len == 0 && !chunk->shdr.is_fin) { in txp_plan_stream_chunk()
2171 chunk->valid = 0; in txp_plan_stream_chunk()
2201 QUIC_TXPIM_CHUNK chunk; in txp_generate_stream_frames() local
2369 chunk.stream_id = shdr->stream_id; in txp_generate_stream_frames()
2370 chunk.start = shdr->offset; in txp_generate_stream_frames()
2371 chunk.end = shdr->offset + shdr->len - 1; in txp_generate_stream_frames()
2372 chunk.has_fin = shdr->is_fin; in txp_generate_stream_frames()
2373 chunk.has_stop_sending = 0; in txp_generate_stream_frames()
2374 chunk.has_reset_stream = 0; in txp_generate_stream_frames()
2375 if (!ossl_quic_txpim_pkt_append_chunk(tpkt, &chunk)) in txp_generate_stream_frames()
2919 QUIC_TXPIM_CHUNK chunk; in txp_pkt_commit() local
2921 chunk.stream_id = stream->id; in txp_pkt_commit()
2922 chunk.start = UINT64_MAX; in txp_pkt_commit()
2923 chunk.end = 0; in txp_pkt_commit()
2924 chunk.has_fin = 0; in txp_pkt_commit()
2925 chunk.has_stop_sending = stream->txp_sent_stop_sending; in txp_pkt_commit()
2926 chunk.has_reset_stream = stream->txp_sent_reset_stream; in txp_pkt_commit()
2927 if (!ossl_quic_txpim_pkt_append_chunk(tpkt, &chunk)) in txp_pkt_commit()
