Lines Matching refs:stream
146 QUIC_STREAM *stream = NULL; in depack_do_frame_reset_stream() local
159 &stream)) in depack_do_frame_reset_stream()
162 if (stream == NULL) in depack_do_frame_reset_stream()
165 if (!ossl_quic_stream_has_recv(stream)) { in depack_do_frame_reset_stream()
184 if (!ossl_quic_rxfc_on_rx_stream_frame(&stream->rxfc, in depack_do_frame_reset_stream()
194 fce = ossl_quic_rxfc_get_error(&stream->rxfc, 0); in depack_do_frame_reset_stream()
209 ossl_quic_stream_map_notify_reset_recv_part(&ch->qsm, stream, in depack_do_frame_reset_stream()
213 ossl_quic_stream_map_update_state(&ch->qsm, stream); in depack_do_frame_reset_stream()
222 QUIC_STREAM *stream = NULL; in depack_do_frame_stop_sending() local
234 &stream)) in depack_do_frame_stop_sending()
237 if (stream == NULL) in depack_do_frame_stop_sending()
240 if (!ossl_quic_stream_has_send(stream)) { in depack_do_frame_stop_sending()
249 stream->peer_stop_sending = 1; in depack_do_frame_stop_sending()
250 stream->peer_stop_sending_aec = frame_data.app_error_code; in depack_do_frame_stop_sending()
257 ossl_quic_stream_map_reset_stream_send_part(&ch->qsm, stream, in depack_do_frame_stop_sending()
368 QUIC_STREAM *stream; in depack_do_implicit_stream_create() local
374 stream = ossl_quic_stream_map_get_by_id(&ch->qsm, stream_id); in depack_do_implicit_stream_create()
375 if (stream != NULL) { in depack_do_implicit_stream_create()
376 *result = stream; in depack_do_implicit_stream_create()
450 stream = ossl_quic_channel_new_stream_remote(ch, cur_stream_id); in depack_do_implicit_stream_create()
451 if (stream == NULL) { in depack_do_implicit_stream_create()
462 *result = stream; in depack_do_implicit_stream_create()
501 QUIC_STREAM *stream; in depack_do_frame_stream() local
517 frame_type, &stream)) in depack_do_frame_stream()
520 if (stream == NULL) in depack_do_frame_stream()
527 if (!ossl_quic_stream_has_recv(stream)) { in depack_do_frame_stream()
537 if (!ossl_quic_rxfc_on_rx_stream_frame(&stream->rxfc, in depack_do_frame_stream()
548 fce = ossl_quic_rxfc_get_error(&stream->rxfc, 0); in depack_do_frame_stream()
557 switch (stream->recv_state) { in depack_do_frame_stream()
580 && !ossl_quic_stream_recv_get_final_size(stream, NULL)) { in depack_do_frame_stream()
583 ossl_quic_stream_map_notify_size_known_recv_part(&ch->qsm, stream, in depack_do_frame_stream()
593 if (stream->stop_sending) in depack_do_frame_stream()
607 && !ossl_quic_rstream_queue_data(stream->rstream, parent_pkt, in depack_do_frame_stream()
625 if (stream->recv_state == QUIC_RSTREAM_STATE_SIZE_KNOWN in depack_do_frame_stream()
626 && !ossl_quic_rstream_available(stream->rstream, &rs_avail, &rs_fin)) { in depack_do_frame_stream()
635 ossl_quic_stream_map_notify_totally_received(&ch->qsm, stream); in depack_do_frame_stream()
693 QUIC_STREAM *stream; in depack_do_frame_max_stream_data() local
706 &stream)) in depack_do_frame_max_stream_data()
709 if (stream == NULL) in depack_do_frame_max_stream_data()
712 if (!ossl_quic_stream_has_send(stream)) { in depack_do_frame_max_stream_data()
721 ossl_quic_txfc_bump_cwm(&stream->txfc, max_stream_data); in depack_do_frame_max_stream_data()
722 ossl_quic_stream_map_update_state(&ch->qsm, stream); in depack_do_frame_max_stream_data()
799 QUIC_STREAM *stream; in depack_do_frame_stream_data_blocked() local
816 &stream)) in depack_do_frame_stream_data_blocked()
819 if (stream == NULL) in depack_do_frame_stream_data_blocked()
822 if (!ossl_quic_stream_has_recv(stream)) { in depack_do_frame_stream_data_blocked()
