in src/transport/xqc_conn.c [6326:6342]
void xqc_conn_check_app_limit(xqc_connection_t *conn)
{
xqc_path_ctx_t *path = NULL;
xqc_list_head_t *pos, *next;
xqc_list_for_each_safe(pos, next, &conn->conn_paths_list) {
path = xqc_list_entry(pos, xqc_path_ctx_t, path_list);
if (path->path_state != XQC_PATH_STATE_ACTIVE) {
continue;
}
if (xqc_sample_check_app_limited(&path->path_send_ctl->sampler,
path->path_send_ctl, conn->conn_send_queue))
{
xqc_pacing_on_app_limit(&path->path_send_ctl->ctl_pacing);
}
}
}