Home | History | Annotate | Download | only in quic

Lines Matching refs:qs

260     QUIC_STREAM *qs;
262     qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch),
264     if (qs == NULL) {
282     if (qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ
283         || !ossl_quic_stream_has_recv_buffer(qs))
286     if (!ossl_quic_rstream_read(qs->rstream, buf, buf_len,
301         if (!ossl_quic_rxfc_on_retire(&qs->rxfc, *bytes_read,
308             qs);
311         ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs);
318     QUIC_STREAM *qs;
323     qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch),
326     if (qs == NULL)
329     if (qs->recv_state == QUIC_RSTREAM_STATE_DATA_READ)
332     if (!ossl_quic_stream_has_recv_buffer(qs))
341     if (!ossl_quic_rstream_peek(qs->rstream, buf, sizeof(buf),
348         if (!ossl_quic_rstream_read(qs->rstream, buf, sizeof(buf),
353         assert(qs->recv_state == QUIC_RSTREAM_STATE_DATA_RECVD);
356             qs);
357         ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs);
370     QUIC_STREAM *qs;
375     qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch),
377     if (qs == NULL || !ossl_quic_stream_has_send_buffer(qs))
380     if (!ossl_quic_sstream_append(qs->sstream,
389         ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs);
398     QUIC_STREAM *qs;
403     qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch),
405     if (qs == NULL || !ossl_quic_stream_has_send_buffer(qs))
408     if (!ossl_quic_sstream_get_final_size(qs->sstream, NULL)) {
409         ossl_quic_sstream_fin(qs->sstream);
410         ossl_quic_stream_map_update_state(ossl_quic_channel_get_qsm(srv->ch), qs);
421     QUIC_STREAM *qs;
426     if ((qs = ossl_quic_channel_new_stream_local(srv->ch, is_uni)) == NULL)
429     *stream_id = qs->id;
447     QUIC_STREAM *qs;
449     qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch),
451     if (qs == NULL)
454     if (qs->peer_stop_sending && app_error_code != NULL)
455         *app_error_code = qs->peer_stop_sending_aec;
457     return qs->peer_stop_sending;
464     QUIC_STREAM *qs;
466     qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch),
468     if (qs == NULL)
471     if (ossl_quic_stream_recv_is_reset(qs) && app_error_code != NULL)
472         *app_error_code = qs->peer_reset_stream_aec;
474     return ossl_quic_stream_recv_is_reset(qs);
487     QUIC_STREAM *qs = ossl_quic_stream_map_peek_accept_queue(qsm);
489     if (qs == NULL)
492     ossl_quic_stream_map_remove_from_accept_queue(qsm, qs, ossl_time_zero());
494     return qs->id;
500     QUIC_STREAM *qs;
502     qs = ossl_quic_stream_map_get_by_id(ossl_quic_channel_get_qsm(srv->ch),
504     if (qs == NULL)
507     return ossl_quic_sstream_is_totally_acked(qs->sstream);