Lines Matching refs:pn_space
114 uint32_t pn_space,
418 static QUIC_SSTREAM *get_sstream_by_id(uint64_t stream_id, uint32_t pn_space,
622 uint32_t pn_space, in ossl_quic_tx_packetiser_set_ack_tx_cb() argument
663 uint32_t pn_space) in ossl_quic_tx_packetiser_schedule_ack_eliciting() argument
665 txp->force_ack_eliciting |= (1UL << pn_space); in ossl_quic_tx_packetiser_schedule_ack_eliciting()
669 uint32_t pn_space) in ossl_quic_tx_packetiser_schedule_ack() argument
671 txp->want_ack |= (1UL << pn_space); in ossl_quic_tx_packetiser_schedule_ack()
1294 uint32_t pn_space; in txp_determine_archetype() local
1306 for (pn_space = QUIC_PN_SPACE_INITIAL; in txp_determine_archetype()
1307 pn_space < QUIC_PN_SPACE_NUM; in txp_determine_archetype()
1308 ++pn_space) in txp_determine_archetype()
1309 if (probe_info->pto[pn_space] > 0) in txp_determine_archetype()
1331 uint32_t pn_space = ossl_quic_enc_level_to_pn_space(enc_level); in txp_should_try_staging() local
1386 || probe_info->pto[pn_space] > 0) in txp_should_try_staging()
1391 if (a.allow_crypto && sstream_is_pending(txp->args.crypto[pn_space])) in txp_should_try_staging()
1395 if (a.allow_ack && (ossl_ackm_is_ack_desired(txp->args.ackm, pn_space) in txp_should_try_staging()
1396 || (txp->want_ack & (1UL << pn_space)) != 0)) in txp_should_try_staging()
1401 && (txp->force_ack_eliciting & (1UL << pn_space)) != 0) in txp_should_try_staging()
1436 for (cfq_item = ossl_quic_cfq_get_priority_head(txp->args.cfq, pn_space); in txp_should_try_staging()
1438 cfq_item = ossl_quic_cfq_item_get_priority_next(cfq_item, pn_space)) { in txp_should_try_staging()
1525 static QUIC_SSTREAM *get_sstream_by_id(uint64_t stream_id, uint32_t pn_space, in get_sstream_by_id() argument
1532 return txp->args.crypto[pn_space]; in get_sstream_by_id()
1604 uint32_t pn_space, in txp_need_ping() argument
1609 || (txp->force_ack_eliciting & (1UL << pn_space)) != 0); in txp_need_ping()
1616 uint32_t pn_space = ossl_quic_enc_level_to_pn_space(enc_level); in txp_pkt_init() local
1628 txp_need_ping(txp, pn_space, &pkt->geom.adata) ? 1 : 0)) in txp_pkt_init()
1825 const uint32_t pn_space = ossl_quic_enc_level_to_pn_space(enc_level); in txp_generate_pre_token() local
1837 && (((txp->want_ack & (1UL << pn_space)) != 0) in txp_generate_pre_token()
1838 || ossl_ackm_is_ack_desired(txp->args.ackm, pn_space)) in txp_generate_pre_token()
1839 && (ack = ossl_ackm_get_ack_frame(txp->args.ackm, pn_space)) != NULL) { in txp_generate_pre_token()
1861 txp->ack_tx_cb(&ack2, pn_space, txp->ack_tx_cb_arg); in txp_generate_pre_token()
1892 if (pn_space != QUIC_PN_SPACE_APP && pf->is_app) { in txp_generate_pre_token()
2040 const uint32_t pn_space = ossl_quic_enc_level_to_pn_space(enc_level); in txp_generate_crypto_frames() local
2060 if (!ossl_quic_sstream_get_stream_frame(txp->args.crypto[pn_space], in txp_generate_crypto_frames()
2571 const uint32_t pn_space = ossl_quic_enc_level_to_pn_space(enc_level); in txp_generate_for_el() local
2588 if (!ossl_quic_pn_valid(txp->next_pn[pn_space])) in txp_generate_for_el()
2702 for (cfq_item = ossl_quic_cfq_get_priority_head(txp->args.cfq, pn_space); in txp_generate_for_el()
2704 cfq_item = ossl_quic_cfq_item_get_priority_next(cfq_item, pn_space)) { in txp_generate_for_el()
2796 if (!have_ack_eliciting && txp_need_ping(txp, pn_space, &a)) { in txp_generate_for_el()
2826 tpkt->ackm_pkt.pkt_num = txp->next_pn[pn_space]; in txp_generate_for_el()
2828 tpkt->ackm_pkt.pkt_space = pn_space; in txp_generate_for_el()
2890 uint32_t pn_space = ossl_quic_enc_level_to_pn_space(enc_level); in txp_pkt_commit() local
2912 txpkt.pn = txp->next_pn[pn_space]; in txp_pkt_commit()
2946 ++txp->next_pn[pn_space]; in txp_pkt_commit()
3002 txp->force_ack_eliciting &= ~(1UL << pn_space); in txp_pkt_commit()
3023 txp->want_ack &= ~(1UL << pn_space); in txp_pkt_commit()
3045 && probe_info->pto[pn_space] > 0) in txp_pkt_commit()
3046 --probe_info->pto[pn_space]; in txp_pkt_commit()
3116 uint32_t pn_space) in ossl_quic_tx_packetiser_get_next_pn() argument
3118 if (pn_space >= QUIC_PN_SPACE_NUM) in ossl_quic_tx_packetiser_get_next_pn()
3121 return txp->next_pn[pn_space]; in ossl_quic_tx_packetiser_get_next_pn()
3132 uint32_t enc_level, pn_space; in ossl_quic_tx_packetiser_get_deadline() local
3144 pn_space = ossl_quic_enc_level_to_pn_space(enc_level); in ossl_quic_tx_packetiser_get_deadline()
3146 ossl_ackm_get_ack_deadline(txp->args.ackm, pn_space)); in ossl_quic_tx_packetiser_get_deadline()
