Lines Matching refs:qs
3389 static int ch_init_new_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs, in ch_init_new_stream() argument
3393 int server_init = ossl_quic_stream_is_server_init(qs); in ch_init_new_stream()
3395 int is_uni = !ossl_quic_stream_is_bidi(qs); in ch_init_new_stream()
3398 if ((qs->sstream = ossl_quic_sstream_new(INIT_APP_BUF_LEN)) == NULL) in ch_init_new_stream()
3402 if ((qs->rstream = ossl_quic_rstream_new(NULL, NULL, 0)) == NULL) in ch_init_new_stream()
3406 if (!ossl_quic_txfc_init(&qs->txfc, &ch->conn_txfc)) in ch_init_new_stream()
3425 ossl_quic_txfc_bump_cwm(&qs->txfc, cwm); in ch_init_new_stream()
3439 if (!ossl_quic_rxfc_init(&qs->rxfc, &ch->conn_rxfc, in ch_init_new_stream()
3448 ossl_quic_sstream_free(qs->sstream); in ch_init_new_stream()
3449 qs->sstream = NULL; in ch_init_new_stream()
3450 ossl_quic_rstream_free(qs->rstream); in ch_init_new_stream()
3451 qs->rstream = NULL; in ch_init_new_stream()
3506 QUIC_STREAM *qs; in ossl_quic_channel_new_stream_local() local
3526 if ((qs = ossl_quic_stream_map_alloc(&ch->qsm, stream_id, type)) == NULL) in ossl_quic_channel_new_stream_local()
3530 if (!ch_init_new_stream(ch, qs, /*can_send=*/1, /*can_recv=*/!is_uni)) in ossl_quic_channel_new_stream_local()
3534 return qs; in ossl_quic_channel_new_stream_local()
3537 ossl_quic_stream_map_release(&ch->qsm, qs); in ossl_quic_channel_new_stream_local()
3546 QUIC_STREAM *qs; in ossl_quic_channel_new_stream_remote() local
3557 qs = ossl_quic_stream_map_alloc(&ch->qsm, stream_id, in ossl_quic_channel_new_stream_remote()
3560 if (qs == NULL) in ossl_quic_channel_new_stream_remote()
3563 if (!ch_init_new_stream(ch, qs, /*can_send=*/!is_uni, /*can_recv=*/1)) in ossl_quic_channel_new_stream_remote()
3567 ossl_quic_channel_reject_stream(ch, qs); in ossl_quic_channel_new_stream_remote()
3569 ossl_quic_stream_map_push_accept_queue(&ch->qsm, qs); in ossl_quic_channel_new_stream_remote()
3571 return qs; in ossl_quic_channel_new_stream_remote()
3574 ossl_quic_stream_map_release(&ch->qsm, qs); in ossl_quic_channel_new_stream_remote()
3586 void ossl_quic_channel_reject_stream(QUIC_CHANNEL *ch, QUIC_STREAM *qs) in ossl_quic_channel_reject_stream() argument
3588 ossl_quic_stream_map_stop_sending_recv_part(&ch->qsm, qs, in ossl_quic_channel_reject_stream()
3591 ossl_quic_stream_map_reset_stream_send_part(&ch->qsm, qs, in ossl_quic_channel_reject_stream()
3593 qs->deleted = 1; in ossl_quic_channel_reject_stream()
3595 ossl_quic_stream_map_update_state(&ch->qsm, qs); in ossl_quic_channel_reject_stream()
