Lines Matching full:txp
289 ch->txp = ossl_quic_tx_packetiser_new(&txp_args); in ch_init()
290 if (ch->txp == NULL) in ch_init()
295 ossl_quic_tx_packetiser_set_validated(ch->txp); in ch_init()
297 ossl_quic_tx_packetiser_set_ack_tx_cb(ch->txp, ch_on_txp_ack_tx, ch); in ch_init()
403 ossl_quic_tx_packetiser_free(ch->txp); in ch_cleanup()
738 = ossl_quic_tx_packetiser_get_next_pn(ch->txp, QUIC_PN_SPACE_APP); in ch_trigger_txku()
923 ossl_quic_tx_packetiser_schedule_ack(ch->txp, QUIC_PN_SPACE_APP); in rxku_detected()
953 * Defer clearing rxku_pending_confirm until TXP generate call returns in ch_on_txp_ack_tx()
1148 ossl_quic_tx_packetiser_set_validated(ch->txp); in ch_on_handshake_complete()
1168 /* Tell TXP the handshake is complete. */ in ch_on_handshake_complete()
1169 ossl_quic_tx_packetiser_notify_handshake_complete(ch->txp); in ch_on_handshake_complete()
1196 ossl_quic_tx_packetiser_schedule_handshake_done(ch->txp); in ch_on_handshake_complete()
2099 * ACKM ACK generation deadline is polled by TXP, so we don't need to in ossl_quic_channel_subtick()
2124 /* If a ping is due, inform TXP. */ in ossl_quic_channel_subtick()
2128 ossl_quic_tx_packetiser_schedule_ack_eliciting(ch->txp, pn_space); in ossl_quic_channel_subtick()
2244 ch->txp, ch->qrx_pkt->hdr->len); in ch_rx()
2333 ossl_quic_tx_packetiser_set_cur_dcid(ch->txp, &ch->init_scid); in ch_rx_handle_packet()
2443 ossl_quic_tx_packetiser_set_protocol_version(ch->txp, QUIC_VERSION_1); in ch_rx_handle_packet()
2679 * from the peer. Once we tell the TXP to generate CONN_CLOSE, all in ch_tx()
2701 * Send packet, if we need to. Best effort. The TXP consults the CC and in ch_tx()
2704 * Best effort. In particular if TXP fails for some reason we should in ch_tx()
2707 res = ossl_quic_tx_packetiser_generate(ch->txp, &status); in ch_tx()
2738 * One case where TXP can fail is if we reach a TX PN of 2**62 - 1. in ch_tx()
2751 "internal error (txp generate)"); in ch_tx()
2813 /* Apply TXP wakeup deadline. */ in ch_determine_next_tick_deadline()
2815 ossl_quic_tx_packetiser_get_deadline(ch->txp)); in ch_determine_next_tick_deadline()
2876 if (!ossl_quic_tx_packetiser_set_peer(ch->txp, &ch->cur_peer_addr)) in ossl_quic_channel_start()
2886 && !ossl_quic_tx_packetiser_set_initial_token(ch->txp, token->token, in ossl_quic_channel_start()
2982 if (!ossl_quic_tx_packetiser_set_cur_dcid(ch->txp, retry_scid)) in ch_retry()
2992 if (!ossl_quic_tx_packetiser_set_initial_token(ch->txp, buf, in ch_retry()
3055 ossl_quic_tx_packetiser_discard_enc_level(ch->txp, enc_level); in ch_discard_el()
3225 ossl_quic_tx_packetiser_schedule_conn_close(ch->txp, &f); in ch_start_terminating()
3415 ossl_quic_tx_packetiser_set_cur_dcid(ch->txp, &ch->cur_remote_dcid); in ossl_quic_channel_on_new_conn_id()
3700 if (!ossl_quic_tx_packetiser_set_peer(ch->txp, &ch->cur_peer_addr)) in ch_on_new_conn_common()
3703 /* Inform TXP of desired CIDs. */ in ch_on_new_conn_common()
3704 if (!ossl_quic_tx_packetiser_set_cur_dcid(ch->txp, &ch->cur_remote_dcid)) in ch_on_new_conn_common()
3707 if (!ossl_quic_tx_packetiser_set_cur_scid(ch->txp, &ch->cur_local_cid)) in ch_on_new_conn_common()
3712 ossl_quic_tx_packetiser_set_qlog_cb(ch->txp, ch_get_qlog_cb, ch); in ch_on_new_conn_common()
4011 /* Replace local connection ID in TXP and DEMUX for testing purposes. */
4019 /* Set in the TXP, used only for long header packets. */ in ossl_quic_channel_replace_local_cid()
4020 if (!ossl_quic_tx_packetiser_set_cur_scid(ch->txp, &ch->cur_local_cid)) in ossl_quic_channel_replace_local_cid()
4036 ossl_quic_tx_packetiser_set_msg_callback(ch->txp, msg_callback, in ossl_quic_channel_set_msg_callback()
4051 ossl_quic_tx_packetiser_set_msg_callback_arg(ch->txp, msg_callback_arg); in ossl_quic_channel_set_msg_callback_arg()
4091 ossl_quic_tx_packetiser_schedule_ack_eliciting(ch->txp, pn_space); in ossl_quic_channel_ping()