Lines Matching refs:qs
256 QUIC_STREAM *qs; in ossl_quic_tserver_read() local
258 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_read()
260 if (qs == NULL) { in ossl_quic_tserver_read()
278 if (qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ in ossl_quic_tserver_read()
279 || !ossl_quic_stream_has_recv_buffer(qs)) in ossl_quic_tserver_read()
282 if (!ossl_quic_rstream_read(qs->rstream, buf, buf_len, in ossl_quic_tserver_read()
297 if (!ossl_quic_rxfc_on_retire(&qs->rxfc, *bytes_read, in ossl_quic_tserver_read()
304 qs); in ossl_quic_tserver_read()
307 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_read()
314 QUIC_STREAM *qs; in ossl_quic_tserver_has_read_ended() local
319 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_has_read_ended()
322 if (qs == NULL) in ossl_quic_tserver_has_read_ended()
325 if (qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ) in ossl_quic_tserver_has_read_ended()
328 if (!ossl_quic_stream_has_recv_buffer(qs)) in ossl_quic_tserver_has_read_ended()
337 if (!ossl_quic_rstream_peek(qs->rstream, buf, sizeof(buf), in ossl_quic_tserver_has_read_ended()
344 if (!ossl_quic_rstream_read(qs->rstream, buf, sizeof(buf), in ossl_quic_tserver_has_read_ended()
349 assert(qs->recv_state == QUIC_RSTREAM_STATE_DATA_RECVD); in ossl_quic_tserver_has_read_ended()
352 qs); in ossl_quic_tserver_has_read_ended()
353 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_has_read_ended()
366 QUIC_STREAM *qs; in ossl_quic_tserver_write() local
371 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_write()
373 if (qs == NULL || !ossl_quic_stream_has_send_buffer(qs)) in ossl_quic_tserver_write()
376 if (!ossl_quic_sstream_append(qs->sstream, in ossl_quic_tserver_write()
385 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_write()
394 QUIC_STREAM *qs; in ossl_quic_tserver_conclude() local
399 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_conclude()
401 if (qs == NULL || !ossl_quic_stream_has_send_buffer(qs)) in ossl_quic_tserver_conclude()
404 if (!ossl_quic_sstream_get_final_size(qs->sstream, NULL)) { in ossl_quic_tserver_conclude()
405 ossl_quic_sstream_fin(qs->sstream); in ossl_quic_tserver_conclude()
406 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_conclude()
417 QUIC_STREAM *qs; in ossl_quic_tserver_stream_new() local
422 if ((qs = ossl_quic_channel_new_stream_local(srv->ch, is_uni)) == NULL) in ossl_quic_tserver_stream_new()
425 *stream_id = qs->id; in ossl_quic_tserver_stream_new()
443 QUIC_STREAM *qs; in ossl_quic_tserver_stream_has_peer_stop_sending() local
445 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_stream_has_peer_stop_sending()
447 if (qs == NULL) in ossl_quic_tserver_stream_has_peer_stop_sending()
450 if (qs->peer_stop_sending && app_error_code != NULL) in ossl_quic_tserver_stream_has_peer_stop_sending()
451 *app_error_code = qs->peer_stop_sending_aec; in ossl_quic_tserver_stream_has_peer_stop_sending()
453 return qs->peer_stop_sending; in ossl_quic_tserver_stream_has_peer_stop_sending()
460 QUIC_STREAM *qs; in ossl_quic_tserver_stream_has_peer_reset_stream() local
462 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_stream_has_peer_reset_stream()
464 if (qs == NULL) in ossl_quic_tserver_stream_has_peer_reset_stream()
467 if (ossl_quic_stream_recv_is_reset(qs) && app_error_code != NULL) in ossl_quic_tserver_stream_has_peer_reset_stream()
468 *app_error_code = qs->peer_reset_stream_aec; in ossl_quic_tserver_stream_has_peer_reset_stream()
470 return ossl_quic_stream_recv_is_reset(qs); in ossl_quic_tserver_stream_has_peer_reset_stream()
483 QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm); in ossl_quic_tserver_pop_incoming_stream() local
485 if (qs == NULL) in ossl_quic_tserver_pop_incoming_stream()
488 ossl_quic_stream_map_remove_from_accept_queue(qsm, qs, ossl_time_zero()); in ossl_quic_tserver_pop_incoming_stream()
490 return qs->id; in ossl_quic_tserver_pop_incoming_stream()
496 QUIC_STREAM *qs; in ossl_quic_tserver_is_stream_totally_acked() local
498 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_is_stream_totally_acked()
500 if (qs == NULL) in ossl_quic_tserver_is_stream_totally_acked()
503 return ossl_quic_sstream_is_totally_acked(qs->sstream); in ossl_quic_tserver_is_stream_totally_acked()
