Lines Matching refs:stream
1478 if (it.stream != NULL) in txp_should_try_staging()
2393 static void txp_enlink_tmp(QUIC_STREAM **tmp_head, QUIC_STREAM *stream) in txp_enlink_tmp() argument
2395 stream->txp_next = *tmp_head; in txp_enlink_tmp()
2396 *tmp_head = stream; in txp_enlink_tmp()
2407 QUIC_STREAM *stream, *snext; in txp_generate_stream_related() local
2412 it.stream != NULL;) { in txp_generate_stream_related()
2414 stream = it.stream; in txp_generate_stream_related()
2416 snext = it.stream; in txp_generate_stream_related()
2418 stream->txp_sent_fc = 0; in txp_generate_stream_related()
2419 stream->txp_sent_stop_sending = 0; in txp_generate_stream_related()
2420 stream->txp_sent_reset_stream = 0; in txp_generate_stream_related()
2421 stream->txp_blocked = 0; in txp_generate_stream_related()
2422 stream->txp_txfc_new_credit_consumed = 0; in txp_generate_stream_related()
2425 if (stream->want_stop_sending) { in txp_generate_stream_related()
2432 f.stream_id = stream->id; in txp_generate_stream_related()
2433 f.app_error_code = stream->stop_sending_aec; in txp_generate_stream_related()
2436 txp_enlink_tmp(tmp_head, stream); in txp_generate_stream_related()
2445 stream->txp_sent_stop_sending = 1; in txp_generate_stream_related()
2448 if (stream->want_reset_stream) { in txp_generate_stream_related()
2451 if (!ossl_assert(stream->send_state == QUIC_SSTREAM_STATE_RESET_SENT)) in txp_generate_stream_related()
2458 f.stream_id = stream->id; in txp_generate_stream_related()
2459 f.app_error_code = stream->reset_stream_aec; in txp_generate_stream_related()
2460 if (!ossl_quic_stream_send_get_final_size(stream, &f.final_size)) in txp_generate_stream_related()
2465 txp_enlink_tmp(tmp_head, stream); in txp_generate_stream_related()
2474 stream->txp_sent_reset_stream = 1; in txp_generate_stream_related()
2482 if (!ossl_assert(f.final_size <= ossl_quic_txfc_get_swm(&stream->txfc))) in txp_generate_stream_related()
2485 stream->txp_txfc_new_credit_consumed in txp_generate_stream_related()
2486 = f.final_size - ossl_quic_txfc_get_swm(&stream->txfc); in txp_generate_stream_related()
2497 if (stream->recv_state == QUIC_RSTREAM_STATE_RECV in txp_generate_stream_related()
2498 && (stream->want_max_stream_data in txp_generate_stream_related()
2499 || ossl_quic_rxfc_has_cwm_changed(&stream->rxfc, 0))) { in txp_generate_stream_related()
2505 cwm = ossl_quic_rxfc_get_cwm(&stream->rxfc); in txp_generate_stream_related()
2507 if (!ossl_quic_wire_encode_frame_max_stream_data(wpkt, stream->id, in txp_generate_stream_related()
2510 txp_enlink_tmp(tmp_head, stream); in txp_generate_stream_related()
2519 stream->txp_sent_fc = 1; in txp_generate_stream_related()
2532 if (ossl_quic_stream_has_send_buffer(stream) in txp_generate_stream_related()
2533 && !ossl_quic_stream_send_is_reset(stream)) { in txp_generate_stream_related()
2536 if (!ossl_assert(!stream->want_reset_stream)) in txp_generate_stream_related()
2540 stream->id, stream->sstream, in txp_generate_stream_related()
2541 &stream->txfc, in txp_generate_stream_related()
2545 &stream->txp_txfc_new_credit_consumed, in txp_generate_stream_related()
2548 txp_enlink_tmp(tmp_head, stream); in txp_generate_stream_related()
2551 conn_consumed += stream->txp_txfc_new_credit_consumed; in txp_generate_stream_related()
2554 txp_enlink_tmp(tmp_head, stream); in txp_generate_stream_related()
2559 txp_enlink_tmp(tmp_head, stream); in txp_generate_stream_related()
2892 QUIC_STREAM *stream; in txp_pkt_commit() local
2916 for (stream = pkt->stream_head; stream != NULL; stream = stream->txp_next) in txp_pkt_commit()
2917 if (stream->txp_sent_stop_sending || stream->txp_sent_reset_stream) { in txp_pkt_commit()
2921 chunk.stream_id = stream->id; 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()
2957 for (stream = pkt->stream_head; stream != NULL; stream = stream->txp_next) { in txp_pkt_commit()
2958 if (stream->txp_sent_fc) { in txp_pkt_commit()
2959 stream->want_max_stream_data = 0; in txp_pkt_commit()
2960 ossl_quic_rxfc_has_cwm_changed(&stream->rxfc, 1); in txp_pkt_commit()
2963 if (stream->txp_sent_stop_sending) in txp_pkt_commit()
2964 stream->want_stop_sending = 0; in txp_pkt_commit()
2966 if (stream->txp_sent_reset_stream) in txp_pkt_commit()
2967 stream->want_reset_stream = 0; in txp_pkt_commit()
2969 if (stream->txp_txfc_new_credit_consumed > 0) { in txp_pkt_commit()
2970 if (!ossl_assert(ossl_quic_txfc_consume_credit(&stream->txfc, in txp_pkt_commit()
2971 stream->txp_txfc_new_credit_consumed))) in txp_pkt_commit()
2979 stream->txp_txfc_new_credit_consumed = 0; in txp_pkt_commit()
2988 ossl_quic_stream_map_update_state(txp->args.qsm, stream); in txp_pkt_commit()
2990 if (ossl_quic_stream_has_send_buffer(stream) in txp_pkt_commit()
2991 && !ossl_quic_sstream_has_pending(stream->sstream) in txp_pkt_commit()
2992 && ossl_quic_sstream_get_final_size(stream->sstream, NULL)) in txp_pkt_commit()
2997 ossl_quic_stream_map_notify_all_data_sent(txp->args.qsm, stream); in txp_pkt_commit()
