Lines Matching full:qs
259 QUIC_STREAM *qs; in ossl_quic_tserver_read() local
261 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_read()
263 if (qs == NULL) { in ossl_quic_tserver_read()
281 if (qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ in ossl_quic_tserver_read()
282 || !ossl_quic_stream_has_recv_buffer(qs)) in ossl_quic_tserver_read()
285 if (!ossl_quic_rstream_read(qs->rstream, buf, buf_len, in ossl_quic_tserver_read()
300 if (!ossl_quic_rxfc_on_retire(&qs->rxfc, *bytes_read, in ossl_quic_tserver_read()
307 qs); in ossl_quic_tserver_read()
310 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_read()
317 QUIC_STREAM *qs; in ossl_quic_tserver_has_read_ended() local
322 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_has_read_ended()
325 if (qs == NULL) in ossl_quic_tserver_has_read_ended()
328 if (qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ) in ossl_quic_tserver_has_read_ended()
331 if (!ossl_quic_stream_has_recv_buffer(qs)) in ossl_quic_tserver_has_read_ended()
340 if (!ossl_quic_rstream_peek(qs->rstream, buf, sizeof(buf), in ossl_quic_tserver_has_read_ended()
347 if (!ossl_quic_rstream_read(qs->rstream, buf, sizeof(buf), in ossl_quic_tserver_has_read_ended()
352 assert(qs->recv_state == QUIC_RSTREAM_STATE_DATA_RECVD); in ossl_quic_tserver_has_read_ended()
355 qs); in ossl_quic_tserver_has_read_ended()
356 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_has_read_ended()
369 QUIC_STREAM *qs; in ossl_quic_tserver_write() local
374 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_write()
376 if (qs == NULL || !ossl_quic_stream_has_send_buffer(qs)) in ossl_quic_tserver_write()
379 if (!ossl_quic_sstream_append(qs->sstream, in ossl_quic_tserver_write()
388 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_write()
397 QUIC_STREAM *qs; in ossl_quic_tserver_conclude() local
402 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_conclude()
404 if (qs == NULL || !ossl_quic_stream_has_send_buffer(qs)) in ossl_quic_tserver_conclude()
407 if (!ossl_quic_sstream_get_final_size(qs->sstream, NULL)) { in ossl_quic_tserver_conclude()
408 ossl_quic_sstream_fin(qs->sstream); in ossl_quic_tserver_conclude()
409 ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs); in ossl_quic_tserver_conclude()
420 QUIC_STREAM *qs; in ossl_quic_tserver_stream_new() local
425 if ((qs = ossl_quic_channel_new_stream_local(srv->ch, is_uni)) == NULL) in ossl_quic_tserver_stream_new()
428 *stream_id = qs->id; in ossl_quic_tserver_stream_new()
446 QUIC_STREAM *qs; in ossl_quic_tserver_stream_has_peer_stop_sending() local
448 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_stream_has_peer_stop_sending()
450 if (qs == NULL) in ossl_quic_tserver_stream_has_peer_stop_sending()
453 if (qs->peer_stop_sending && app_error_code != NULL) in ossl_quic_tserver_stream_has_peer_stop_sending()
454 *app_error_code = qs->peer_stop_sending_aec; in ossl_quic_tserver_stream_has_peer_stop_sending()
456 return qs->peer_stop_sending; in ossl_quic_tserver_stream_has_peer_stop_sending()
463 QUIC_STREAM *qs; in ossl_quic_tserver_stream_has_peer_reset_stream() local
465 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_stream_has_peer_reset_stream()
467 if (qs == NULL) in ossl_quic_tserver_stream_has_peer_reset_stream()
470 if (ossl_quic_stream_recv_is_reset(qs) && app_error_code != NULL) in ossl_quic_tserver_stream_has_peer_reset_stream()
471 *app_error_code = qs->peer_reset_stream_aec; in ossl_quic_tserver_stream_has_peer_reset_stream()
473 return ossl_quic_stream_recv_is_reset(qs); in ossl_quic_tserver_stream_has_peer_reset_stream()
486 QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm); in ossl_quic_tserver_pop_incoming_stream() local
488 if (qs == NULL) in ossl_quic_tserver_pop_incoming_stream()
491 ossl_quic_stream_map_remove_from_accept_queue(qsm, qs, ossl_time_zero()); in ossl_quic_tserver_pop_incoming_stream()
493 return qs->id; in ossl_quic_tserver_pop_incoming_stream()
499 QUIC_STREAM *qs; in ossl_quic_tserver_is_stream_totally_acked() local
501 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch), in ossl_quic_tserver_is_stream_totally_acked()
503 if (qs == NULL) in ossl_quic_tserver_is_stream_totally_acked()
506 return ossl_quic_sstream_is_totally_acked(qs->sstream); in ossl_quic_tserver_is_stream_totally_acked()