Lines Matching refs:args
52 OSSL_QUIC_TX_PACKETISER_ARGS args; member
454 OSSL_QUIC_TX_PACKETISER *ossl_quic_tx_packetiser_new(const OSSL_QUIC_TX_PACKETISER_ARGS *args) in ossl_quic_tx_packetiser_new() argument
458 if (args == NULL in ossl_quic_tx_packetiser_new()
459 || args->qtx == NULL in ossl_quic_tx_packetiser_new()
460 || args->txpim == NULL in ossl_quic_tx_packetiser_new()
461 || args->cfq == NULL in ossl_quic_tx_packetiser_new()
462 || args->ackm == NULL in ossl_quic_tx_packetiser_new()
463 || args->qsm == NULL in ossl_quic_tx_packetiser_new()
464 || args->conn_txfc == NULL in ossl_quic_tx_packetiser_new()
465 || args->conn_rxfc == NULL in ossl_quic_tx_packetiser_new()
466 || args->max_streams_bidi_rxfc == NULL in ossl_quic_tx_packetiser_new()
467 || args->max_streams_uni_rxfc == NULL) { in ossl_quic_tx_packetiser_new()
476 txp->args = *args; in ossl_quic_tx_packetiser_new()
480 txp->args.cfq, txp->args.ackm, txp->args.txpim, in ossl_quic_tx_packetiser_new()
485 args->get_qlog_cb, in ossl_quic_tx_packetiser_new()
486 args->get_qlog_cb_arg)) { in ossl_quic_tx_packetiser_new()
591 txp->args.cur_dcid = *dcid; in ossl_quic_tx_packetiser_set_cur_dcid()
603 txp->args.cur_scid = *scid; in ossl_quic_tx_packetiser_set_cur_scid()
612 BIO_ADDR_clear(&txp->args.peer); in ossl_quic_tx_packetiser_set_peer()
616 txp->args.peer = *peer; in ossl_quic_tx_packetiser_set_peer()
647 txp->args.crypto[ossl_quic_enc_level_to_pn_space(enc_level)] = NULL; in ossl_quic_tx_packetiser_discard_enc_level()
772 uint64_t cc_limit = txp->args.cc_method->get_tx_allowance(txp->args.cc_data); in ossl_quic_tx_packetiser_generate()
786 ossl_qtx_finish_dgram(txp->args.qtx); in ossl_quic_tx_packetiser_generate()
927 ossl_qtx_finish_dgram(txp->args.qtx); in ossl_quic_tx_packetiser_generate()
1228 phdr->dst_conn_id = txp->args.cur_dcid; in txp_determine_geometry()
1229 phdr->src_conn_id = txp->args.cur_scid; in txp_determine_geometry()
1293 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_determine_archetype()
1334 if (!ossl_qtx_is_enc_level_provisioned(txp->args.qtx, enc_level)) in txp_should_try_staging()
1380 = ossl_ackm_get0_probe_request(txp->args.ackm); 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()
1406 || ossl_quic_rxfc_has_cwm_changed(txp->args.conn_rxfc, 0))) in txp_should_try_staging()
1412 || ossl_quic_rxfc_has_cwm_changed(txp->args.max_streams_bidi_rxfc, in txp_should_try_staging()
1415 || ossl_quic_rxfc_has_cwm_changed(txp->args.max_streams_uni_rxfc, 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()
1477 ossl_quic_stream_iter_init(&it, txp->args.qsm, 0); in txp_should_try_staging()
1512 if (!ossl_qtx_calculate_plaintext_payload_len(txp->args.qtx, enc_level, in txp_determine_ppl_from_pl()
1522 return ossl_qtx_get_mdpl(txp->args.qtx); in txp_get_mdpl()
1532 return txp->args.crypto[pn_space]; in get_sstream_by_id()
1534 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in get_sstream_by_id()
1565 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
1571 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_regen_notify()
1577 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
1582 ossl_quic_stream_map_schedule_stop_sending(txp->args.qsm, s); in on_regen_notify()
1588 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_regen_notify()
1594 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_regen_notify()
1647 ossl_quic_txpim_pkt_release(txp->args.txpim, pkt->tpkt); in txp_pkt_cleanup()
1680 if (!ossl_qtx_calculate_ciphertext_payload_len(txp->args.qtx, pkt->h.enc_level, in txp_pkt_postgen_update_pkt_overhead()
1703 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_confirm_notify()
1709 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_confirm_notify()
1715 = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_confirm_notify()
1724 ossl_quic_stream_map_notify_reset_stream_acked(txp->args.qsm, s); in on_confirm_notify()
1725 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_confirm_notify()
1771 s = ossl_quic_stream_map_get_by_id(txp->args.qsm, stream_id); in on_sstream_updated()
1775 ossl_quic_stream_map_update_state(txp->args.qsm, s); in on_sstream_updated()
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()
1850 txp->args.ack_delay_exponent, in txp_generate_pre_token()
2060 if (!ossl_quic_sstream_get_stream_frame(txp->args.crypto[pn_space], in txp_generate_crypto_frames()
2411 for (ossl_quic_stream_iter_init(&it, txp->args.qsm, 1); in txp_generate_stream_related()
2594 if ((pkt->tpkt = tpkt = ossl_quic_txpim_pkt_alloc(txp->args.txpim)) == NULL) in txp_generate_for_el()
2628 || ossl_quic_rxfc_has_cwm_changed(txp->args.conn_rxfc, 0)) in txp_generate_for_el()
2631 uint64_t cwm = ossl_quic_rxfc_get_cwm(txp->args.conn_rxfc); in txp_generate_for_el()
2652 || ossl_quic_rxfc_has_cwm_changed(txp->args.max_streams_bidi_rxfc, 0)) in txp_generate_for_el()
2656 = ossl_quic_rxfc_get_cwm(txp->args.max_streams_bidi_rxfc); in txp_generate_for_el()
2678 || ossl_quic_rxfc_has_cwm_changed(txp->args.max_streams_uni_rxfc, 0)) in txp_generate_for_el()
2682 = ossl_quic_rxfc_get_cwm(txp->args.max_streams_uni_rxfc); 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()
2833 tpkt->ackm_pkt.time = txp->args.now(txp->args.now_arg); in txp_generate_for_el()
2846 ossl_quic_txpim_pkt_release(txp->args.txpim, tpkt); in txp_generate_for_el()
2910 txpkt.peer = BIO_ADDR_family(&txp->args.peer) == AF_UNSPEC in txp_pkt_commit()
2911 ? NULL : &txp->args.peer; in txp_pkt_commit()
2950 if (!ossl_qtx_write_pkt(txp->args.qtx, &txpkt)) in txp_pkt_commit()
2988 ossl_quic_stream_map_update_state(txp->args.qsm, stream); in txp_pkt_commit()
2997 ossl_quic_stream_map_notify_all_data_sent(txp->args.qsm, stream); in txp_pkt_commit()
3009 ossl_quic_rxfc_has_cwm_changed(txp->args.conn_rxfc, 1); in txp_pkt_commit()
3014 ossl_quic_rxfc_has_cwm_changed(txp->args.max_streams_bidi_rxfc, 1); in txp_pkt_commit()
3019 ossl_quic_rxfc_has_cwm_changed(txp->args.max_streams_uni_rxfc, 1); in txp_pkt_commit()
3034 = ossl_ackm_get0_probe_request(txp->args.ackm); in txp_pkt_commit()
3143 if (ossl_qtx_is_enc_level_provisioned(txp->args.qtx, 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()
3150 if (txp->args.cc_method->get_tx_allowance(txp->args.cc_data) == 0) in ossl_quic_tx_packetiser_get_deadline()
3152 txp->args.cc_method->get_wakeup_deadline(txp->args.cc_data)); in ossl_quic_tx_packetiser_get_deadline()
