Lines Matching full:qs
30 static QUIC_XSO *create_xso_from_stream(QUIC_CONNECTION *qc, QUIC_STREAM *qs);
2088 QUIC_STREAM *qs; member
2104 args->qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(args->qc->ch), in quic_wait_for_stream()
2106 if (args->qs == NULL) in quic_wait_for_stream()
2107 args->qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(args->qc->ch), in quic_wait_for_stream()
2110 if (args->qs != NULL) in quic_wait_for_stream()
2122 QUIC_STREAM *qs; in qc_wait_for_default_xso_for_read() local
2145 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(qc->ch), in qc_wait_for_default_xso_for_read()
2147 if (qs == NULL) in qc_wait_for_default_xso_for_read()
2148 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(qc->ch), in qc_wait_for_default_xso_for_read()
2151 if (qs == NULL) { in qc_wait_for_default_xso_for_read()
2154 qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(qc->ch), in qc_wait_for_default_xso_for_read()
2158 if (qs == NULL) { in qc_wait_for_default_xso_for_read()
2171 wargs.qs = NULL; in qc_wait_for_default_xso_for_read()
2178 else if (res < 0 || wargs.qs == NULL) in qc_wait_for_default_xso_for_read()
2182 qs = wargs.qs; in qc_wait_for_default_xso_for_read()
2186 * We now have qs != NULL. Remove it from the incoming stream queue so that in qc_wait_for_default_xso_for_read()
2191 qs, rtt_info.smoothed_rtt); in qc_wait_for_default_xso_for_read()
2194 * Now make qs the default stream, creating the necessary XSO. in qc_wait_for_default_xso_for_read()
2196 qc_set_default_xso(qc, create_xso_from_stream(qc, qs), /*touch=*/0); in qc_wait_for_default_xso_for_read()
2205 static QUIC_XSO *create_xso_from_stream(QUIC_CONNECTION *qc, QUIC_STREAM *qs) in create_xso_from_stream() argument
2232 xso->stream = qs; in create_xso_from_stream()
2268 QUIC_STREAM *qs = NULL; in quic_conn_stream_new() local
2308 qs = ossl_quic_channel_new_stream_local(qc->ch, is_uni); in quic_conn_stream_new()
2309 if (qs == NULL) { in quic_conn_stream_new()
2314 xso = create_xso_from_stream(qc, qs); in quic_conn_stream_new()
2326 ossl_quic_stream_map_release(ossl_quic_channel_get_qsm(qc->ch), qs); in quic_conn_stream_new()
3198 QUIC_STREAM *qs; in ossl_quic_conn_stream_conclude() local
3205 qs = ctx.xso->stream; in ossl_quic_conn_stream_conclude()
3219 if (ossl_quic_sstream_get_final_size(qs->sstream, NULL)) { in ossl_quic_conn_stream_conclude()
3224 ossl_quic_sstream_fin(qs->sstream); in ossl_quic_conn_stream_conclude()
3855 QUIC_STREAM *qs; member
3871 args->qs = ossl_quic_stream_map_peek_accept_queue(qsm); in wait_for_incoming_stream()
3872 if (args->qs != NULL) in wait_for_incoming_stream()
3885 QUIC_STREAM *qs; in ossl_quic_accept_stream() local
3902 qs = ossl_quic_stream_map_peek_accept_queue(qsm); in ossl_quic_accept_stream()
3903 if (qs == NULL) { in ossl_quic_accept_stream()
3909 args.qs = NULL; in ossl_quic_accept_stream()
3915 } else if (ret < 0 || args.qs == NULL) { in ossl_quic_accept_stream()
3919 qs = args.qs; in ossl_quic_accept_stream()
3925 xso = create_xso_from_stream(ctx.qc, qs); in ossl_quic_accept_stream()
3930 ossl_quic_stream_map_remove_from_accept_queue(qsm, qs, in ossl_quic_accept_stream()
3973 QUIC_STREAM *qs; in ossl_quic_stream_reset() local
3981 qs = ctx.xso->stream; in ossl_quic_stream_reset()
3989 ok = ossl_quic_stream_map_reset_stream_send_part(qsm, qs, error_code); in ossl_quic_stream_reset()
4003 QUIC_STREAM *qs, in quic_classify_stream() argument
4011 local_init = (ossl_quic_stream_is_server_init(qs) == qc->as_server); in quic_classify_stream()
4018 if (!ossl_quic_stream_is_bidi(qs) && local_init != is_write) { in quic_classify_stream()
4027 } else if (!is_write && qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ) { in quic_classify_stream()
4030 } else if ((!is_write && qs->stop_sending) in quic_classify_stream()
4031 || (is_write && ossl_quic_stream_send_is_reset(qs))) { in quic_classify_stream()
4039 ? qs->stop_sending_aec in quic_classify_stream()
4040 : qs->reset_stream_aec; in quic_classify_stream()
4041 } else if ((!is_write && ossl_quic_stream_recv_is_reset(qs)) in quic_classify_stream()
4042 || (is_write && qs->peer_stop_sending)) { in quic_classify_stream()
4047 ? qs->peer_reset_stream_aec in quic_classify_stream()
4048 : qs->peer_stop_sending_aec; in quic_classify_stream()
4049 } else if (is_write && ossl_quic_sstream_get_final_size(qs->sstream, in quic_classify_stream()