gam_terms/analytic_penalties/isometry.rs
1use super::*;
2pub use gam_problem::WeightField;
3
4// ---------------------------------------------------------------------------
5// Isometry penalty
6// ---------------------------------------------------------------------------
7
8/// Choice of reference Riemannian metric `g^ref(t)` on the latent manifold.
9///
10/// `Euclidean` is the natural default: the reference metric is `I_d`, so the
11/// penalty pulls the decoder toward locally-isometric (length-preserving)
12/// behavior. `UserSupplied` lets the caller hand in a `(n_obs, d, d)` jet of
13/// per-row reference metrics (useful for warm-starting from a chart of a
14/// pre-fit GP-LVM).
15#[derive(Clone)]
16pub enum IsometryReference {
17 Euclidean,
18 UserSupplied(Arc<Array2<f64>>), // (n_obs, d*d) row-major flattened
19}
20
21impl std::fmt::Debug for IsometryReference {
22 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
23 match self {
24 IsometryReference::Euclidean => f.write_str("Euclidean"),
25 IsometryReference::UserSupplied(a) => f
26 .debug_tuple("UserSupplied")
27 .field(&format_args!("{}×{}", a.nrows(), a.ncols()))
28 .finish(),
29 }
30 }
31}
32
33/// Radial Duchon decoder metadata used to materialize
34/// `∂J_n[i, a] / ∂t_{n, c}` from `φ'(r)` and `φ''(r)` on demand.
35///
36/// `radial_coefficients[k, i]` is the decoder coefficient that maps radial
37/// basis column `k` into output channel `i`. Polynomial-tail columns are not
38/// represented here; callers whose decoder contains a non-linear polynomial
39/// tail should provide `jacobian_second_cache` directly.
40#[derive(Debug, Clone)]
41pub struct IsometryDuchonRadialSource {
42 pub centers: Arc<Array2<f64>>,
43 pub radial_coefficients: Arc<Array2<f64>>,
44 pub length_scale: Option<f64>,
45 pub nullspace_order: DuchonNullspaceOrder,
46 /// Forward hybrid spectral order `s = spec.power`. The Cartesian
47 /// derivative engine must resolve the same `(p, s, κ)` the forward
48 /// `build_duchon_basis` used, so it differentiates the exact resolved
49 /// hybrid Green's function `φ_{p,s,κ}` rather than a hard-coded `s = 0`
50 /// surrogate (issue #440).
51 pub power: usize,
52}
53
54/// Isometry-to-reference penalty (canonical-coordinate gauge term).
55///
56/// Lives on ext-coords: the target slice is a row of the `LatentCoordValues` flat
57/// vector (row-major `n_obs × d`). Owns one ρ-axis (`log μ_iso`).
58///
59/// Penalizes `½ μ Σ_n ‖g_n(t) − g^ref(t_n)‖²_F`, where the pullback metric
60/// at row `n` is
61///
62/// ```text
63/// g_n = J_n^T W_n J_n, J_n ∈ ℝ^{p × d}
64/// ```
65///
66/// and `W_n` is a per-row low-rank PSD behavioral metric stored as
67/// `W_n = U_n U_n^T` with `U_n ∈ ℝ^{p × r}`. The canonical-coordinate
68/// statement is "one unit of motion in `t` ↦ one unit of behavioral change",
69/// so the `W_n` weighting is load-bearing.
70///
71/// In the SAE objective this is the extension-coordinate gauge fix: it prevents
72/// the latent chart from absorbing arbitrary smooth reparameterizations of the
73/// decoder manifold. ARD, sparsity, or rank penalties can then select axes or
74/// structure in a chart whose metric scale is pinned.
75///
76/// **Contraction order invariant.** Every place this struct touches `W_n`,
77/// the contraction is `(J^T U_n)(U_n^T J)` — never `J^T W_n J` with `W_n`
78/// materialized as `p × p`. Concretely we form `M_n = U_n^T J_n ∈ ℝ^{r × d}`
79/// once and then `g_n = M_n^T M_n` (`d × d`). Cost per row:
80/// `O(p · r · d + r · d²)`, independent of `p²`.
81///
82/// **When to use.** Whenever a `LatentCoord` block is in play without an
83/// auxiliary variable (`AuxPrior`) to break the diffeomorphism gauge. Fixes
84/// the audit finding that ARD is not a standalone gauge fix. With a Euclidean
85/// reference, the penalty pulls the decoder toward a local isometry, which is
86/// enough to make the inner Hessian on `t` full-rank and the IFT well-defined.
87///
88/// **Math.** Let `J_n ∈ ℝ^{p × d}` be the local decoder Jacobian. Then
89/// `g_n = J_n^T W_n J_n` and the penalty is
90/// `½ μ Σ_n ‖J_n^T W_n J_n − g^ref_n‖²_F`. Analytic gradient w.r.t. `t_n`:
91///
92/// ```text
93/// ∂P/∂t_{n,c}
94/// = μ Σ_{a,b} (g_n − g^ref_n)_{ab}
95/// [ H_{n,:,a,c}^T W_n J_{n,:,b}
96/// + J_{n,:,a}^T W_n H_{n,:,b,c} ],
97/// H_{n,i,a,c} = ∂J_{n,i,a}/∂t_{n,c}.
98/// ```
99///
100/// Gotchas:
101///
102/// * The value path returns the configured missing-cache default when the
103/// first-jet cache is absent; gradient/HVP paths need the first and second
104/// decoder jets and return zeros when the analytic jet source is unavailable.
105/// * The exact Hessian includes a residual-curvature term requiring the third
106/// decoder jet. REML/PIRLS curvature should prefer the Gauss-Newton PSD
107/// majorizer when a positive curvature block is required.
108/// * `W_n` is a metric weight, not a scalar confidence. Changing it changes the
109/// canonical units of latent motion.
110///
111/// The per-row Jacobian `J_n` is exactly the radial-derivative jet
112/// `design_gradient_wrt_t` already computes for `LatentCoordValues`; the
113/// second derivative `∂J/∂t` is built by the shared
114/// `crate::basis::radial_basis_cartesian_derivative` engine from the
115/// radial Hessian identity. A finite-difference oracle for the docstring is
116/// to central-difference `value(t ± h e_j)` against `grad_target(t)[j]`;
117/// the analytic value follows the oracle until finite-difference
118/// cancellation dominates. No autograd needed.
119///
120/// `μ = exp(ρ_iso)` is REML-selectable as one extra ρ axis.
121///
122/// `jacobian_cache_slot` and `jacobian_second_cache_slot` are interior-mutable
123/// (`RwLock<Option<Arc<…>>>`) so the SAE outer loop can refresh them in place
124/// each step without needing `&mut self` on the registry-held penalty (see
125/// `refresh_caches` and `crate::terms::sae::manifold::refresh_isometry_caches_from_atom`).
126/// Readers go through the [`Self::jacobian_cache`] / [`Self::jacobian_second_cache`]
127/// accessors, which take the read lock briefly and clone the inner `Arc`
128/// (refcount bump — no payload copy). Writers go through [`Self::refresh_caches`].
129#[derive(Debug)]
130pub struct IsometryPenalty {
131 pub target: PsiSlice,
132 pub reference: IsometryReference,
133 /// Index of this penalty's strength `log μ_iso` inside the *local* rho
134 /// view this penalty receives. Always `0` for now (single owned axis).
135 pub rho_index: usize,
136 /// Cached Jacobian `J ∈ ℝ^{n_obs × p × d}`, flattened row-major
137 /// `(n_obs, p*d)`. The owning driver refreshes this each IFT outer step
138 /// before invoking `value` / `grad_target`; in operator-only call sites
139 /// (Hessian-vector products) the cache must be live. Access through
140 /// [`Self::jacobian_cache`] / [`Self::set_jacobian_cache`].
141 pub jacobian_cache_slot: RwLock<Option<Arc<Array2<f64>>>>,
142 /// Optional cached per-row Jacobian *second derivative*
143 /// `H_n ∈ ℝ^{p × d × d}`, flattened row-major as `(n_obs, p*d*d)`.
144 /// `H_n[i, a, c] = ∂J_n[i, a] / ∂t_{n, c}`. Either this cache or
145 /// `duchon_radial_source` must be present for exact isometry
146 /// gradient/HVP calls. Access through [`Self::jacobian_second_cache`] /
147 /// [`Self::set_jacobian_second_cache`].
148 pub jacobian_second_cache_slot: RwLock<Option<Arc<Array2<f64>>>>,
149 /// Optional radial-Duchon source used to build `jacobian_second_cache`
150 /// analytically from `φ'(r)` and the public `φ''(r)` jet helper. This is
151 /// the exact chain-rule path for callers that do not pre-cache `∂J/∂t`.
152 pub duchon_radial_source: Option<Arc<IsometryDuchonRadialSource>>,
153 /// Optional cached per-row Jacobian *third derivative*
154 /// `K_n ∈ ℝ^{p × d × d × d}`, stored as an `Array3` with shape
155 /// `(n_obs, p, d * d * d)` where the third axis packs `(a, c, d)` in
156 /// row-major order `((a * d) + c) * d + dd`. `hvp` uses the full
157 /// residual-curvature Hessian (proposal §4(b)):
158 /// B_{ab,cd} = K_{a,cd}^T W J_b + H_{a,c}^T W H_{b,d}
159 /// + H_{a,d}^T W H_{b,c} + J_a^T W K_{b,cd}.
160 /// Either this cache or `duchon_radial_source` must be present for
161 /// analytic `hvp` calls. Interior-mutable (mirrors
162 /// `jacobian_second_cache_slot`) so the SAE outer loop can refresh `K` in
163 /// place each step. Access through [`Self::third_decoder_derivative`] /
164 /// [`Self::set_third_decoder_derivative`].
165 pub third_decoder_derivative_slot: RwLock<Option<Arc<ndarray::Array3<f64>>>>,
166 /// Output dimensionality `p` (column count of each per-row Jacobian).
167 pub p_out: usize,
168 /// Per-row behavioral metric in low-rank factored form. Defaults to
169 /// `Identity` (the unweighted `J^T J` pullback). When `Factored`, all
170 /// `g_n` contractions are done via `M_n = U_n^T J_n` (`r × d`), keeping
171 /// memory and FLOPs scaling at `O(p · r · d)` per row instead of
172 /// `O(p²)` per row.
173 pub weight: WeightField,
174 pub scalar_weight: f64,
175 pub weight_schedule: Option<ScalarWeightSchedule>,
176}
177
178pub(crate) struct IsometryHvpState<'a> {
179 d: usize,
180 n_obs: usize,
181 p: usize,
182 jac2: CowArray<'a, f64, Ix2>,
183 jac3: CowArray<'a, f64, Ix3>,
184 metric: IsometryMetricState,
185 wj_rows: Vec<Array2<f64>>,
186}
187
188#[derive(Debug, Clone)]
189struct IsometryMetricState {
190 g: Array2<f64>,
191 residual: Array2<f64>,
192 metric_grad: Array2<f64>,
193 normalizer: f64,
194 trace_denominator: f64,
195 residual_dot_g: f64,
196}
197
198impl IsometryMetricState {
199 fn residual_direction(&self, delta_g: ArrayView2<'_, f64>, d: usize) -> (Array2<f64>, f64) {
200 let n_obs = self.g.nrows();
201 let dd = d * d;
202 let mut delta_trace_sum = 0.0;
203 for n in 0..n_obs {
204 for a in 0..d {
205 delta_trace_sum += delta_g[[n, a * d + a]];
206 }
207 }
208 let delta_normalizer = delta_trace_sum / self.trace_denominator;
209 let inv_norm = 1.0 / self.normalizer;
210 let inv_norm_sq = inv_norm * inv_norm;
211 let mut delta_residual = Array2::<f64>::zeros((n_obs, dd));
212 for n in 0..n_obs {
213 for k in 0..dd {
214 delta_residual[[n, k]] =
215 delta_g[[n, k]] * inv_norm - self.g[[n, k]] * delta_normalizer * inv_norm_sq;
216 }
217 }
218 (delta_residual, delta_normalizer)
219 }
220
221 fn metric_grad_direction(&self, delta_g: ArrayView2<'_, f64>, d: usize) -> Array2<f64> {
222 let n_obs = self.g.nrows();
223 let dd = d * d;
224 let (delta_residual, delta_normalizer) = self.residual_direction(delta_g, d);
225 let mut delta_residual_dot_g = 0.0;
226 for n in 0..n_obs {
227 for k in 0..dd {
228 delta_residual_dot_g += delta_residual[[n, k]] * self.g[[n, k]];
229 delta_residual_dot_g += self.residual[[n, k]] * delta_g[[n, k]];
230 }
231 }
232 let inv_norm = 1.0 / self.normalizer;
233 let inv_norm_sq = inv_norm * inv_norm;
234 let delta_trace_coeff = delta_residual_dot_g * inv_norm_sq / self.trace_denominator
235 - 2.0 * self.residual_dot_g * delta_normalizer * inv_norm_sq * inv_norm
236 / self.trace_denominator;
237 let mut out = Array2::<f64>::zeros((n_obs, dd));
238 for n in 0..n_obs {
239 for a in 0..d {
240 for b in 0..d {
241 let k = a * d + b;
242 let mut value = delta_residual[[n, k]] * inv_norm
243 - self.residual[[n, k]] * delta_normalizer * inv_norm_sq;
244 if a == b {
245 value -= delta_trace_coeff;
246 }
247 out[[n, k]] = value;
248 }
249 }
250 }
251 out
252 }
253}
254
255/// Average trace per latent dimension `(1 / (N d)) Σ_n tr(m_n)` of a flattened
256/// `(n_obs, d*d)` row-major metric field. Shared by the decoder normalizer
257/// `gbar` and the reference normalizer `gref_bar`, so a decoder metric that is
258/// exactly proportional to a reference of arbitrary scale gives a zero residual.
259fn average_trace_per_dim(m: ArrayView2<'_, f64>, n_obs: usize, d: usize) -> f64 {
260 let denom = (n_obs * d) as f64;
261 let mut trace_sum = 0.0;
262 for n in 0..n_obs {
263 for a in 0..d {
264 trace_sum += m[[n, a * d + a]];
265 }
266 }
267 trace_sum / denom
268}
269
270fn isometry_dg_entry(
271 jac2: ArrayView2<'_, f64>,
272 wj: ArrayView2<'_, f64>,
273 n: usize,
274 d: usize,
275 p: usize,
276 a: usize,
277 b: usize,
278 c: usize,
279) -> f64 {
280 let mut s = 0.0;
281 for i in 0..p {
282 s += jac2[[n, (i * d + a) * d + c]] * wj[[i, b]];
283 s += wj[[i, a]] * jac2[[n, (i * d + b) * d + c]];
284 }
285 s
286}
287
288fn isometry_row_delta_g(
289 jac2: ArrayView2<'_, f64>,
290 wj: ArrayView2<'_, f64>,
291 v: ArrayView1<'_, f64>,
292 n: usize,
293 d: usize,
294 p: usize,
295) -> Array2<f64> {
296 let mut delta_g = Array2::<f64>::zeros((d, d));
297 for a in 0..d {
298 for b in 0..d {
299 let mut s = 0.0;
300 for c in 0..d {
301 s += isometry_dg_entry(jac2, wj, n, d, p, a, b, c) * v[n * d + c];
302 }
303 delta_g[[a, b]] = s;
304 }
305 }
306 delta_g
307}
308
309impl IsometryPenalty {
310 pub const DEFAULT_VALUE_ON_MISSING_CACHE: f64 = 0.0;
311
312 #[must_use]
313 pub fn new_euclidean(target: PsiSlice, p_out: usize) -> Self {
314 Self {
315 target,
316 reference: IsometryReference::Euclidean,
317 rho_index: 0,
318 jacobian_cache_slot: RwLock::new(None),
319 jacobian_second_cache_slot: RwLock::new(None),
320 duchon_radial_source: None,
321 third_decoder_derivative_slot: RwLock::new(None),
322 p_out,
323 weight: WeightField::Identity,
324 scalar_weight: 1.0,
325 weight_schedule: None,
326 }
327 }
328
329 /// Read-side accessor: takes the read lock briefly and clones the inner
330 /// `Arc` (refcount bump only; no payload copy). Returns `None` when the
331 /// cache has not been refreshed yet. Internally panics on poisoned lock
332 /// — the lock only wraps an `Option<Arc<…>>`, so the write side cannot
333 /// leave it in an invariant-violating state.
334 #[must_use]
335 pub fn jacobian_cache(&self) -> Option<Arc<Array2<f64>>> {
336 self.jacobian_cache_slot
337 .read()
338 .expect("IsometryPenalty::jacobian_cache_slot poisoned")
339 .clone()
340 }
341
342 /// Read the Jacobian cache under the *dimensional identity*
343 /// `(latent_dim, p_out)` of the atom currently being evaluated.
344 ///
345 /// The cache is interior-mutable and refreshed **per atom** (see
346 /// [`Self::refresh_caches`] and
347 /// `sae::manifold::refresh_isometry_caches_from_atom`). In a heterogeneous
348 /// SAE whose atoms have *mixed* latent dimensions (e.g. the standard zoo
349 /// `dims = [1,1,2,2,2,2,2,1]`) the slot can transiently hold a Jacobian
350 /// built for a **different** atom's `latent_dim` — its column count is
351 /// `p_out · d'` for that atom's `d'`, not this atom's `d`. Reshaping such a
352 /// cache at the wrong `d` would silently corrupt every downstream `J`
353 /// contraction (`projected_jacobian_row` / `weighted_jacobian_row`) or trip
354 /// the [`Self::pullback_metric`] shape invariant (`assert_eq!(jac.ncols(),
355 /// p·d)`) with a hard panic (issue #2294).
356 ///
357 /// The cache's built-for `latent_dim` is recoverable from its own shape:
358 /// with `p_out` fixed on the penalty, `ncols() == p_out · d_cache`. We
359 /// Per-atom SAE evaluation clones the registry descriptor, retargets it,
360 /// and refreshes that clone before any read, so a mismatched live cache is
361 /// an ownership/refresh invariant violation, not missing optional data.
362 /// Silently converting it to `None` would disable the isometry penalty and
363 /// change the fitted objective. Keep the mismatch hard: every caller sees
364 /// either no cache at all or a cache with the exact requested identity.
365 fn dimensioned_jacobian_cache(
366 &self,
367 method: &str,
368 latent_dim: usize,
369 ) -> Option<Arc<Array2<f64>>> {
370 let Some(jac) = self.jacobian_cache() else {
371 self.missing_cache_default(method, "jacobian_cache is None");
372 return None;
373 };
374 let expected = self
375 .p_out
376 .checked_mul(latent_dim)
377 .expect("IsometryPenalty Jacobian dimensional identity overflow");
378 assert_eq!(
379 jac.ncols(),
380 expected,
381 "IsometryPenalty::{method} stale cross-atom Jacobian cache: cache has {} columns, \
382 but this per-atom evaluation requires p_out {} × latent_dim {} = {}; the owner \
383 must clone, retarget, and refresh the penalty before evaluation",
384 jac.ncols(),
385 self.p_out,
386 latent_dim,
387 expected,
388 );
389 Some(jac)
390 }
391
392 /// Read-side accessor for the per-row Jacobian second derivative.
393 /// Mirrors [`Self::jacobian_cache`].
394 #[must_use]
395 pub fn jacobian_second_cache(&self) -> Option<Arc<Array2<f64>>> {
396 self.jacobian_second_cache_slot
397 .read()
398 .expect("IsometryPenalty::jacobian_second_cache_slot poisoned")
399 .clone()
400 }
401
402 /// Per-step refresh entry point. Takes `&self` (no `&mut`) so the SAE
403 /// outer loop can install fresh caches on an `Arc<IsometryPenalty>` held
404 /// in the analytic-penalty registry without disturbing the surrounding
405 /// dispatcher. Pass `None` for either argument to clear that cache (the
406 /// dispatcher will then either fall back to the Duchon radial source if
407 /// available, or return the zero safe default).
408 pub fn refresh_caches(&self, jac: Option<Arc<Array2<f64>>>, jac2: Option<Arc<Array2<f64>>>) {
409 *self
410 .jacobian_cache_slot
411 .write()
412 .expect("IsometryPenalty::jacobian_cache_slot poisoned") = jac;
413 *self
414 .jacobian_second_cache_slot
415 .write()
416 .expect("IsometryPenalty::jacobian_second_cache_slot poisoned") = jac2;
417 }
418
419 /// In-place writer for just the Jacobian cache (used by callers that
420 /// already own the radial Duchon source and only want to refresh `J`).
421 pub fn set_jacobian_cache(&self, jac: Option<Arc<Array2<f64>>>) {
422 *self
423 .jacobian_cache_slot
424 .write()
425 .expect("IsometryPenalty::jacobian_cache_slot poisoned") = jac;
426 }
427
428 /// In-place writer for just the Jacobian second-derivative cache.
429 pub fn set_jacobian_second_cache(&self, jac2: Option<Arc<Array2<f64>>>) {
430 *self
431 .jacobian_second_cache_slot
432 .write()
433 .expect("IsometryPenalty::jacobian_second_cache_slot poisoned") = jac2;
434 }
435
436 /// Read-side accessor for the per-row Jacobian third derivative `K`.
437 /// Mirrors [`Self::jacobian_second_cache`].
438 #[must_use]
439 pub fn third_decoder_derivative(&self) -> Option<Arc<ndarray::Array3<f64>>> {
440 self.third_decoder_derivative_slot
441 .read()
442 .expect("IsometryPenalty::third_decoder_derivative_slot poisoned")
443 .clone()
444 }
445
446 /// In-place writer for just the Jacobian third-derivative cache `K`.
447 pub fn set_third_decoder_derivative(&self, jac3: Option<Arc<ndarray::Array3<f64>>>) {
448 *self
449 .third_decoder_derivative_slot
450 .write()
451 .expect("IsometryPenalty::third_decoder_derivative_slot poisoned") = jac3;
452 }
453}
454
455impl Clone for IsometryPenalty {
456 fn clone(&self) -> Self {
457 Self {
458 target: self.target.clone(),
459 reference: self.reference.clone(),
460 rho_index: self.rho_index,
461 jacobian_cache_slot: RwLock::new(self.jacobian_cache()),
462 jacobian_second_cache_slot: RwLock::new(self.jacobian_second_cache()),
463 duchon_radial_source: self.duchon_radial_source.clone(),
464 third_decoder_derivative_slot: RwLock::new(self.third_decoder_derivative()),
465 p_out: self.p_out,
466 weight: self.weight.clone(),
467 scalar_weight: self.scalar_weight,
468 weight_schedule: self.weight_schedule.clone(),
469 }
470 }
471}
472
473impl IsometryPenalty {
474
475 #[must_use]
476 pub fn with_jacobian_cache(self, j: Arc<Array2<f64>>) -> Self {
477 self.set_jacobian_cache(Some(j));
478 self
479 }
480
481 #[must_use]
482 pub fn with_jacobian_second_cache(self, h: Arc<Array2<f64>>) -> Self {
483 self.set_jacobian_second_cache(Some(h));
484 self
485 }
486
487 impl_with_weight_schedule!(scalar_weight);
488
489 fn missing_cache_default(&self, method: &str, detail: &str) {
490 log::warn!(
491 "IsometryPenalty::{method} missing required derivative state: {detail}; \
492 returning the zero safe default"
493 );
494 }
495
496 fn has_jacobian_cache(&self, method: &str) -> bool {
497 if self.jacobian_cache().is_some() {
498 true
499 } else {
500 self.missing_cache_default(method, "jacobian_cache is None");
501 false
502 }
503 }
504
505 fn has_jacobian_second_source(&self, method: &str) -> bool {
506 if self.jacobian_second_cache().is_some() || self.duchon_radial_source.is_some() {
507 true
508 } else {
509 self.missing_cache_default(
510 method,
511 "both jacobian_second_cache and duchon_radial_source are None",
512 );
513 false
514 }
515 }
516
517 fn has_jacobian_third_source(&self, method: &str) -> bool {
518 if self.third_decoder_derivative().is_some() || self.duchon_radial_source.is_some() {
519 true
520 } else {
521 self.missing_cache_default(
522 method,
523 "both third_decoder_derivative cache and duchon_radial_source are None",
524 );
525 false
526 }
527 }
528
529 /// Build `M_n = U_n^T J_n ∈ ℝ^{r_n × d}` for row `n`. For
530 /// `WeightField::Identity`, `r_n = p` and `M_n = J_n`.
531 ///
532 /// This is the single contraction site where `W_n` (or its `U_n` factor)
533 /// is consumed. Every value/grad/hvp path funnels through here, so the
534 /// `(J^T U)(U^T J)` ordering invariant cannot be violated by accident.
535 fn projected_jacobian_row(&self, n: usize, d: usize) -> Option<Array2<f64>> {
536 let jac = self.dimensioned_jacobian_cache("projected_jacobian_row", d)?;
537 let jac_row = jac.row(n);
538 let jac_slice = jac_row
539 .as_slice()
540 .expect("jacobian cache must be in standard row-major layout");
541 match &self.weight {
542 WeightField::Identity => {
543 let p = self.p_out;
544 let mut m = Array2::<f64>::zeros((p, d));
545 for i in 0..p {
546 for a in 0..d {
547 m[[i, a]] = jac_slice[i * d + a];
548 }
549 }
550 Some(m)
551 }
552 WeightField::Factored { u, rank, p_out } => {
553 let u_row = u.row(n);
554 let u_slice = u_row
555 .as_slice()
556 .expect("weight factor U must be in standard row-major layout");
557 Some(WeightField::project_jac_row_with_u(
558 u_slice, jac_slice, *p_out, *rank, d,
559 ))
560 }
561 }
562 }
563
564 /// Form `W_n J_n` without materializing `W_n`.
565 fn weighted_jacobian_row(&self, n: usize, d: usize) -> Option<Array2<f64>> {
566 let jac = self.dimensioned_jacobian_cache("weighted_jacobian_row", d)?;
567 let p = self.p_out;
568 match &self.weight {
569 WeightField::Identity => {
570 let mut out = Array2::<f64>::zeros((p, d));
571 for i in 0..p {
572 for a in 0..d {
573 out[[i, a]] = jac[[n, i * d + a]];
574 }
575 }
576 Some(out)
577 }
578 WeightField::Factored { u, rank, p_out } => {
579 assert_eq!(p, *p_out);
580 let r = *rank;
581 let m_n = self.projected_jacobian_row(n, d)?;
582 let mut out = Array2::<f64>::zeros((p, d));
583 for i in 0..p {
584 for a in 0..d {
585 let mut s = 0.0;
586 for k in 0..r {
587 s += u[[n, i * r + k]] * m_n[[k, a]];
588 }
589 out[[i, a]] = s;
590 }
591 }
592 Some(out)
593 }
594 }
595 }
596
597 fn weighted_dot_decoder_vectors<F, G>(&self, n: usize, p: usize, x: F, y: G) -> f64
598 where
599 F: Fn(usize) -> f64,
600 G: Fn(usize) -> f64,
601 {
602 match &self.weight {
603 WeightField::Identity => {
604 let mut s = 0.0;
605 for i in 0..p {
606 s += x(i) * y(i);
607 }
608 s
609 }
610 WeightField::Factored { u, rank, p_out } => {
611 assert_eq!(p, *p_out);
612 let r = *rank;
613 let mut s = 0.0;
614 for k in 0..r {
615 let mut ux = 0.0;
616 let mut uy = 0.0;
617 for i in 0..p {
618 let uik = u[[n, i * r + k]];
619 ux += uik * x(i);
620 uy += uik * y(i);
621 }
622 s += ux * uy;
623 }
624 s
625 }
626 }
627 }
628
629 fn target_matrix(target: ArrayView1<'_, f64>, n_obs: usize, d: usize) -> Array2<f64> {
630 let mut out = Array2::<f64>::zeros((n_obs, d));
631 for n in 0..n_obs {
632 for a in 0..d {
633 out[[n, a]] = target[n * d + a];
634 }
635 }
636 out
637 }
638
639 /// Second-order input-location derivative tensor of the Duchon decoder,
640 /// flattened to `(n_obs, p_out · d²)` with column layout
641 /// `i·d² + (a·d + c)`.
642 ///
643 /// Thin adapter over the shared [`radial_basis_cartesian_derivative`]
644 /// engine: it owns the radial-jet evaluation and the radial→Cartesian map;
645 /// here we only forward the source geometry.
646 fn duchon_radial_jacobian_second(
647 &self,
648 target: ArrayView1<'_, f64>,
649 n_obs: usize,
650 d: usize,
651 source: &IsometryDuchonRadialSource,
652 ) -> Result<Array2<f64>, BasisError> {
653 assert_eq!(source.centers.ncols(), d);
654 assert_eq!(source.radial_coefficients.nrows(), source.centers.nrows());
655 assert_eq!(source.radial_coefficients.ncols(), self.p_out);
656 let t = Self::target_matrix(target, n_obs, d);
657 radial_basis_cartesian_derivative(
658 2,
659 t.view(),
660 source.centers.view(),
661 source.radial_coefficients.view(),
662 source.length_scale,
663 source.nullspace_order,
664 source.power,
665 )
666 }
667
668 /// Third-order input-location derivative tensor of the Duchon decoder,
669 /// shaped `(n_obs, p_out, d³)` with last-axis layout `(a·d + c)·d + e`.
670 ///
671 /// Thin adapter over the shared [`radial_basis_cartesian_derivative`]
672 /// engine; the flat `(n_obs, p_out · d³)` result is reshaped to the
673 /// `Array3` consumed by the HVP path (row-major flatten of `(p_out, d³)`
674 /// is exactly `i·d³ + idx`).
675 fn duchon_radial_jacobian_third(
676 &self,
677 target: ArrayView1<'_, f64>,
678 n_obs: usize,
679 d: usize,
680 source: &IsometryDuchonRadialSource,
681 ) -> Result<ndarray::Array3<f64>, BasisError> {
682 assert_eq!(source.centers.ncols(), d);
683 assert_eq!(source.radial_coefficients.nrows(), source.centers.nrows());
684 assert_eq!(source.radial_coefficients.ncols(), self.p_out);
685 let t = Self::target_matrix(target, n_obs, d);
686 let flat = radial_basis_cartesian_derivative(
687 3,
688 t.view(),
689 source.centers.view(),
690 source.radial_coefficients.view(),
691 source.length_scale,
692 source.nullspace_order,
693 source.power,
694 )?;
695 Ok(flat
696 .into_shape_with_order((n_obs, self.p_out, d * d * d))
697 .expect("radial_basis_cartesian_derivative order-3 output reshapes to (n_obs, p, d³)"))
698 }
699
700 fn jacobian_second<'a>(
701 &'a self,
702 target: ArrayView1<'_, f64>,
703 n_obs: usize,
704 d: usize,
705 ) -> Option<CowArray<'a, f64, Ix2>> {
706 if let Some(jac2) = self.jacobian_second_cache() {
707 // Clone the underlying Array2 to detach from the Arc — the
708 // CowArray needs to outlive the temporary Arc returned by the
709 // accessor. The clone is `n_obs × p·d²` floats, paid once per
710 // grad_target / hvp_state invocation; same per-step cost as the
711 // pre-refactor code path which also took ownership via
712 // `jac2.view().to_owned()` semantics implicitly.
713 return Some(CowArray::from((*jac2).clone()));
714 }
715 let source = self.duchon_radial_source.as_ref()?;
716 match self.duchon_radial_jacobian_second(target, n_obs, d, source) {
717 Ok(jac2) => Some(CowArray::from(jac2)),
718 Err(err) => {
719 self.missing_cache_default(
720 "jacobian_second",
721 &format!("failed to materialize Duchon radial second derivative: {err}"),
722 );
723 None
724 }
725 }
726 }
727
728 fn jacobian_third<'a>(
729 &'a self,
730 target: ArrayView1<'_, f64>,
731 n_obs: usize,
732 d: usize,
733 ) -> Option<CowArray<'a, f64, Ix3>> {
734 if let Some(jac3) = self.third_decoder_derivative() {
735 return Some(CowArray::from(jac3.as_ref().clone()));
736 }
737 let source = self.duchon_radial_source.as_ref()?;
738 match self.duchon_radial_jacobian_third(target, n_obs, d, source) {
739 Ok(jac3) => Some(CowArray::from(jac3)),
740 Err(err) => {
741 self.missing_cache_default(
742 "jacobian_third",
743 &format!("failed to materialize Duchon radial third derivative: {err}"),
744 );
745 None
746 }
747 }
748 }
749
750 pub(crate) fn hvp_state<'a>(
751 &'a self,
752 target: ArrayView1<'_, f64>,
753 ) -> Option<IsometryHvpState<'a>> {
754 let d = self
755 .target
756 .latent_dim
757 .expect("IsometryPenalty requires latent_dim on its PsiSlice");
758 let n_obs = target.len() / d;
759 if !self.has_jacobian_cache("hvp")
760 || !self.has_jacobian_second_source("hvp")
761 || !self.has_jacobian_third_source("hvp")
762 {
763 return None;
764 }
765 let p = self.p_out;
766 let jac2 = self.jacobian_second(target.view(), n_obs, d)?;
767 let jac3 = self.jacobian_third(target.view(), n_obs, d)?;
768 let g = self.pullback_metric(d)?;
769 let metric = self.normalized_metric_state(g, n_obs, d)?;
770 let mut wj_rows = Vec::with_capacity(n_obs);
771 for n in 0..n_obs {
772 wj_rows.push(self.weighted_jacobian_row(n, d)?);
773 }
774 Some(IsometryHvpState {
775 d,
776 n_obs,
777 p,
778 jac2,
779 jac3,
780 metric,
781 wj_rows,
782 })
783 }
784
785 pub(crate) fn hvp_with_precomputed_state(
786 &self,
787 state: &IsometryHvpState<'_>,
788 rho: ArrayView1<'_, f64>,
789 v: ArrayView1<'_, f64>,
790 ) -> Array1<f64> {
791 let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
792 let d = state.d;
793 let n_obs = state.n_obs;
794 let p = state.p;
795 let jac2 = &state.jac2;
796 let jac3 = &state.jac3;
797 let metric = &state.metric;
798 let mut out = Array1::<f64>::zeros(v.len());
799 let mut delta_g = Array2::<f64>::zeros((n_obs, d * d));
800 for n in 0..n_obs {
801 let wj = &state.wj_rows[n];
802 let row_delta = isometry_row_delta_g(jac2.view(), wj.view(), v, n, d, p);
803 for a in 0..d {
804 for b in 0..d {
805 delta_g[[n, a * d + b]] = row_delta[[a, b]];
806 }
807 }
808 }
809 let delta_metric_grad = metric.metric_grad_direction(delta_g.view(), d);
810
811 for n in 0..n_obs {
812 let wj = &state.wj_rows[n];
813 for c in 0..d {
814 let mut acc = 0.0;
815 for a in 0..d {
816 for b in 0..d {
817 let dg = isometry_dg_entry(jac2.view(), wj.view(), n, d, p, a, b, c);
818 acc += dg * delta_metric_grad[[n, a * d + b]];
819 }
820 }
821 out[n * d + c] = mu * acc;
822 }
823
824 for c in 0..d {
825 let mut acc_res = 0.0;
826 for a in 0..d {
827 for b in 0..d {
828 let metric_grad = metric.metric_grad[[n, a * d + b]];
829 if metric_grad == 0.0 {
830 continue;
831 }
832 let mut bv = 0.0;
833 for dd in 0..d {
834 let vd = v[n * d + dd];
835 if vd == 0.0 {
836 continue;
837 }
838 let mut k_a_cd_w_j_b = 0.0;
839 for i in 0..p {
840 k_a_cd_w_j_b += jac3[[n, i, ((a * d) + c) * d + dd]] * wj[[i, b]];
841 }
842 let h_a_c_w_h_b_d = self.weighted_dot_decoder_vectors(
843 n,
844 p,
845 |i| jac2[[n, (i * d + a) * d + c]],
846 |i| jac2[[n, (i * d + b) * d + dd]],
847 );
848 let h_a_d_w_h_b_c = self.weighted_dot_decoder_vectors(
849 n,
850 p,
851 |i| jac2[[n, (i * d + a) * d + dd]],
852 |i| jac2[[n, (i * d + b) * d + c]],
853 );
854 let mut j_a_w_k_b_cd = 0.0;
855 for i in 0..p {
856 j_a_w_k_b_cd += wj[[i, a]] * jac3[[n, i, ((b * d) + c) * d + dd]];
857 }
858 bv +=
859 (k_a_cd_w_j_b + h_a_c_w_h_b_d + h_a_d_w_h_b_c + j_a_w_k_b_cd) * vd;
860 }
861 acc_res += metric_grad * bv;
862 }
863 }
864 out[n * d + c] += mu * acc_res;
865 }
866 }
867 out
868 }
869
870 /// Per-row pullback metric `g_n = J_n^T W_n J_n = M_n^T M_n` with
871 /// `M_n = U_n^T J_n ∈ ℝ^{r_n × d}`. Returns `(n_obs, d, d)` flattened
872 /// row-major as `(n_obs, d*d)`.
873 ///
874 /// Cost per row: `O(p · r · d)` for the `M_n` build (single pass over
875 /// `U_n` and `J_n`) plus `O(r · d²)` for `M_n^T M_n`. The `p × p` weight
876 /// `W_n` is never materialized.
877 pub fn pullback_metric(&self, latent_dim: usize) -> Option<Array2<f64>> {
878 let jac = self.dimensioned_jacobian_cache("pullback_metric", latent_dim)?;
879 let n_obs = jac.nrows();
880 // `dimensioned_jacobian_cache` enforces the load-bearing `(n, p·d)`
881 // shape contract before the reshape loop below. A stale cross-atom
882 // cache is a hard owner/refresh invariant failure; it is never converted
883 // into a zero isometry contribution (#2294).
884 let mut g_all = Array2::<f64>::zeros((n_obs, latent_dim * latent_dim));
885 for n in 0..n_obs {
886 // M_n = U_n^T J_n (or J_n itself when W = I).
887 let m = self.projected_jacobian_row(n, latent_dim)?;
888 let r = m.nrows();
889 // g_n = M_n^T M_n: (d × d) result, contracting r.
890 for a in 0..latent_dim {
891 for b in 0..latent_dim {
892 let mut s = 0.0;
893 for k in 0..r {
894 s += m[[k, a]] * m[[k, b]];
895 }
896 g_all[[n, a * latent_dim + b]] = s;
897 }
898 }
899 }
900 Some(g_all)
901 }
902
903 /// The scale normalizer `gbar = (1 / (N d)) Σ_n tr(g_n)` of the cached
904 /// pullback metric — the single shared denominator the scale-invariant
905 /// gauge divides every per-row metric by.
906 ///
907 /// `value` / `grad_*` / `hvp` consume this implicitly through
908 /// `Self::normalized_metric_state`; the SAE arrow-Schur assembly cannot
909 /// (it builds explicit per-row `htt` / `htbeta` / `hbb` curvature blocks
910 /// from the raw pullback `g_n`, not through the trait operators), so it
911 /// reads `gbar` here and folds `1/gbar²` into its Gauss-Newton curvature.
912 /// That `1/gbar²` factor is exactly the frozen-normalizer Gauss-Newton
913 /// block of the normalized residual `R_n = g_n/gbar − g^ref_n`: the raw
914 /// block (the GN block of the *un-normalized* `½μ‖g_n − g^ref‖²`) scales
915 /// ∝‖B‖⁴ in the decoder magnitude while the normalized gradient is
916 /// scale-free, so without the factor the joint Newton step collapses and
917 /// the proximal ridge saturates at 1e15 (#795). It stays PSD (a positive
918 /// scalar on an already-PSD Gram block), so the Schur complement is
919 /// unaffected. `None` when the metric is unavailable or degenerate, mirror-
920 /// ing `normalized_metric_state`'s non-positive-normalizer guard.
921 pub fn metric_normalizer(&self, latent_dim: usize) -> Option<f64> {
922 let g = self.pullback_metric(latent_dim)?;
923 let n_obs = g.nrows();
924 let normalizer = average_trace_per_dim(g.view(), n_obs, latent_dim);
925 (normalizer.is_finite() && normalizer > f64::MIN_POSITIVE).then_some(normalizer)
926 }
927
928 /// Reference metric per row for the normalized pullback metric, `(n_obs, d*d)`.
929 fn reference_metric(&self, n_obs: usize, d: usize) -> CowArray<'_, f64, Ix2> {
930 match &self.reference {
931 IsometryReference::Euclidean => {
932 let mut out = Array2::<f64>::zeros((n_obs, d * d));
933 for n in 0..n_obs {
934 for a in 0..d {
935 out[[n, a * d + a]] = 1.0;
936 }
937 }
938 CowArray::from(out)
939 }
940 IsometryReference::UserSupplied(a) => {
941 assert_eq!(a.nrows(), n_obs);
942 assert_eq!(a.ncols(), d * d);
943 CowArray::from(a.view())
944 }
945 }
946 }
947
948 /// Shared normalized metric state for the scale-invariant isometry gauge.
949 ///
950 /// The residual is `R_n = g_n / gbar - g_ref,n / gref_bar`, with
951 /// `gbar = (1 / (N d)) Σ_n tr(g_n)` and `gref_bar = (1 / (N d)) Σ_n tr(g_ref,n)`
952 /// (`gref_bar == 1` for the `Euclidean` reference). `g_ref / gref_bar` is
953 /// constant w.r.t. the decoder coordinates, so the metric gradient/Hessian
954 /// form below is unchanged. The metric-gradient is the exact
955 /// derivative of `0.5 Σ ||R_n||²` with respect to the raw pullback metrics:
956 ///
957 /// `A_n = R_n / gbar - (Σ_l R_l:g_l) I / (gbar² N d)`.
958 ///
959 /// All value, gradient, and HVP paths consume this state so the global
960 /// normalizer's derivative is never detached.
961 fn normalized_metric_state(
962 &self,
963 g: Array2<f64>,
964 n_obs: usize,
965 d: usize,
966 ) -> Option<IsometryMetricState> {
967 let dd = d * d;
968 let trace_denominator = (n_obs * d) as f64;
969 let normalizer = average_trace_per_dim(g.view(), n_obs, d);
970 if !(normalizer.is_finite() && normalizer > f64::MIN_POSITIVE) {
971 self.missing_cache_default(
972 "normalized_metric_state",
973 &format!(
974 "unit-average-speed normalizer is non-positive or non-finite: {normalizer}"
975 ),
976 );
977 return None;
978 }
979 let g_ref = self.reference_metric(n_obs, d);
980 // Normalize the reference by its own average trace per dim so the gauge
981 // is scale-invariant on both sides: a decoder metric proportional to the
982 // reference (up to an arbitrary global scale, common for external chart
983 // metrics / GP-LVM warm starts) gives a zero residual. For `Euclidean`,
984 // `ref_normalizer == 1.0` exactly, preserving the prior behavior bit-for-bit.
985 let ref_normalizer = average_trace_per_dim(g_ref.view(), n_obs, d);
986 if !(ref_normalizer.is_finite() && ref_normalizer > f64::MIN_POSITIVE) {
987 self.missing_cache_default(
988 "normalized_metric_state",
989 &format!(
990 "reference-metric normalizer is non-positive or non-finite: {ref_normalizer}"
991 ),
992 );
993 return None;
994 }
995 let mut residual = Array2::<f64>::zeros((n_obs, dd));
996 let inv_norm = 1.0 / normalizer;
997 let inv_ref_norm = 1.0 / ref_normalizer;
998 for n in 0..n_obs {
999 for k in 0..dd {
1000 residual[[n, k]] = g[[n, k]] * inv_norm - g_ref[[n, k]] * inv_ref_norm;
1001 }
1002 }
1003 let mut residual_dot_g = 0.0;
1004 for n in 0..n_obs {
1005 for k in 0..dd {
1006 residual_dot_g += residual[[n, k]] * g[[n, k]];
1007 }
1008 }
1009 let trace_coeff = residual_dot_g / (normalizer * normalizer * trace_denominator);
1010 let mut metric_grad = Array2::<f64>::zeros((n_obs, dd));
1011 for n in 0..n_obs {
1012 for a in 0..d {
1013 for b in 0..d {
1014 let k = a * d + b;
1015 let mut value = residual[[n, k]] * inv_norm;
1016 if a == b {
1017 value -= trace_coeff;
1018 }
1019 metric_grad[[n, k]] = value;
1020 }
1021 }
1022 }
1023 Some(IsometryMetricState {
1024 g,
1025 residual,
1026 metric_grad,
1027 normalizer,
1028 trace_denominator,
1029 residual_dot_g,
1030 })
1031 }
1032
1033 /// Exact closed-form gradient of the isometry penalty with respect to the
1034 /// cached decoder Jacobian `J ∈ ℝ^{n_obs × p × d}` (the autograd input that
1035 /// torch's `_IsometryPenaltyFn` differentiates). Returns the flattened
1036 /// `(n_obs, p*d)` layout that matches the Jacobian cache.
1037 ///
1038 /// Derivation (W-aware, reference-aware, weight-aware):
1039 ///
1040 /// P = ½ μ Σ_n ‖R_n‖²_F,
1041 /// R_n = g_n / gbar − g^ref_n,
1042 /// gbar = (1 / (N d)) Σ_n tr(g_n)
1043 /// A_n = ∂(P/μ)/∂g_n
1044 /// ∂g_{ab}/∂J_{i,c}
1045 /// = δ_{ca}(W J)_{i,b} + δ_{cb}(W J)_{i,a} (W symmetric)
1046 /// ∂P/∂J_{i,c}
1047 /// = μ Σ_{a,b} A_{ab} ∂g_{ab}/∂J_{i,c}
1048 /// = 2 μ Σ_b A_{cb} (W J)_{i,b}
1049 /// = 2 μ ((W J) A)_{i,c}
1050 ///
1051 /// where `A` includes the exact derivative of the shared `gbar` normalizer.
1052 pub fn grad_jacobian(
1053 &self,
1054 target: ArrayView1<'_, f64>,
1055 rho: ArrayView1<'_, f64>,
1056 ) -> Array2<f64> {
1057 let d = self
1058 .target
1059 .latent_dim
1060 .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1061 let n_obs = target.len() / d;
1062 let p = self.p_out;
1063 let mut grad = Array2::<f64>::zeros((n_obs, p * d));
1064 if !self.has_jacobian_cache("grad_jacobian") {
1065 return grad;
1066 }
1067 let Some(g) = self.pullback_metric(d) else {
1068 return grad;
1069 };
1070 let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1071 return grad;
1072 };
1073 let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1074 for n in 0..n_obs {
1075 let Some(wj) = self.weighted_jacobian_row(n, d) else {
1076 return Array2::<f64>::zeros((n_obs, p * d));
1077 };
1078 for i in 0..p {
1079 for c in 0..d {
1080 let mut acc = 0.0;
1081 for b in 0..d {
1082 acc += metric.metric_grad[[n, c * d + b]] * wj[[i, b]];
1083 }
1084 grad[[n, i * d + c]] = 2.0 * mu * acc;
1085 }
1086 }
1087 }
1088 grad
1089 }
1090}
1091
1092impl AnalyticPenalty for IsometryPenalty {
1093 fn tier(&self) -> PenaltyTier {
1094 PenaltyTier::Psi
1095 }
1096
1097 fn validate_rho(&self, rho: ArrayView1<'_, f64>) -> Result<(), String> {
1098 if rho.len() != 1 {
1099 return Err(format!("isometry rho length {} != 1", rho.len()));
1100 }
1101 resolve_learnable_weight(self.scalar_weight, rho[self.rho_index])?;
1102 Ok(())
1103 }
1104
1105 fn rho_coordinate_domains(&self) -> Result<Vec<(f64, f64)>, String> {
1106 Ok(vec![
1107 learnable_weight_coordinate_domain(self.scalar_weight)?
1108 .ok_or_else(|| "isometry scalar weight must be positive".to_string())?,
1109 ])
1110 }
1111
1112 fn value(&self, target: ArrayView1<'_, f64>, rho: ArrayView1<'_, f64>) -> f64 {
1113 let d = self
1114 .target
1115 .latent_dim
1116 .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1117 let n_obs = target.len() / d;
1118 if !self.has_jacobian_cache("value") {
1119 return Self::DEFAULT_VALUE_ON_MISSING_CACHE;
1120 }
1121 let Some(g) = self.pullback_metric(d) else {
1122 return Self::DEFAULT_VALUE_ON_MISSING_CACHE;
1123 };
1124 let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1125 return Self::DEFAULT_VALUE_ON_MISSING_CACHE;
1126 };
1127 let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1128 let mut acc = 0.0;
1129 for n in 0..n_obs {
1130 for k in 0..(d * d) {
1131 let diff = metric.residual[[n, k]];
1132 acc += diff * diff;
1133 }
1134 }
1135 0.5 * mu * acc
1136 }
1137
1138 fn grad_target(&self, target: ArrayView1<'_, f64>, rho: ArrayView1<'_, f64>) -> Array1<f64> {
1139 // Exact closed-form gradient, W-aware:
1140 //
1141 // P = ½ μ Σ_n ‖R_n‖²_F, R_n = g_n / gbar − g^ref_n
1142 // g_n = J_n^T W_n J_n, W_n = U_n U_n^T
1143 // A_n = ∂(P/μ)/∂g_n, including the exact derivative of
1144 // gbar = (1 / (N d)) Σ_n tr(g_n)
1145 // ∂g_{ab}/∂t_c
1146 // = (H_{:,a,c})^T (W J)_{:,b} + (J_{:,a})^T W H_{:,b,c}
1147 // ∂P/∂t_c
1148 // = μ Σ_{a,b} A_{a,b} · ∂g_{ab}/∂t_c
1149 //
1150 // `H = ∂J/∂t` comes either from the live cache or from the radial
1151 // Duchon `φ''(r)` helper. The sign is positive: differentiating
1152 // `t - c` with respect to `t` contributes `+I`.
1153 let d = self
1154 .target
1155 .latent_dim
1156 .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1157 let n_obs = target.len() / d;
1158 if !self.has_jacobian_cache("grad_target")
1159 || !self.has_jacobian_second_source("grad_target")
1160 {
1161 return Array1::<f64>::zeros(target.len());
1162 }
1163 let Some(g) = self.pullback_metric(d) else {
1164 return Array1::<f64>::zeros(target.len());
1165 };
1166 let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1167 return Array1::<f64>::zeros(target.len());
1168 };
1169 let p = self.p_out;
1170 let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1171 let mut grad = Array1::<f64>::zeros(target.len());
1172 let Some(jac2) = self.jacobian_second(target, n_obs, d) else {
1173 return grad;
1174 };
1175 assert_eq!(jac2.ncols(), p * d * d);
1176
1177 for n in 0..n_obs {
1178 let Some(wj) = self.weighted_jacobian_row(n, d) else {
1179 return grad;
1180 };
1181 for c in 0..d {
1182 let mut acc = 0.0;
1183 for a in 0..d {
1184 for b in 0..d {
1185 let mut dg = 0.0;
1186 for i in 0..p {
1187 dg += jac2[[n, (i * d + a) * d + c]] * wj[[i, b]];
1188 dg += wj[[i, a]] * jac2[[n, (i * d + b) * d + c]];
1189 }
1190 acc += metric.metric_grad[[n, a * d + b]] * dg;
1191 }
1192 }
1193 grad[n * d + c] = mu * acc;
1194 }
1195 }
1196 grad
1197 }
1198
1199 /// Fully analytic - wired through `radial_basis_cartesian_derivative`.
1200 fn hvp(
1201 &self,
1202 target: ArrayView1<'_, f64>,
1203 rho: ArrayView1<'_, f64>,
1204 v: ArrayView1<'_, f64>,
1205 ) -> Array1<f64> {
1206 // Fully analytic isometry Hessian-vector product wired through the
1207 // shared `radial_basis_cartesian_derivative` engine when no
1208 // third-derivative cache is supplied.
1209 //
1210 // The full Hessian of P_iso = (μ/2) Σ_n ||J^T W J / gbar - G_ref||²_F
1211 // (per proposal §4(b)) is
1212 // μ [Dgᵀ · ∂²(0.5||R||²)/∂g² · Dg + A · ∂²g],
1213 // where R = g/gbar - G_ref and A = ∂(0.5||R||²)/∂g includes the global
1214 // gbar derivative.
1215 // B_{ab,cd} = K_{a,cd}^T W J_b + H_{a,c}^T W H_{b,d}
1216 // + H_{a,d}^T W H_{b,c} + J_a^T W K_{b,cd},
1217 // where K is the third decoder derivative and H is the second.
1218 let Some(state) = self.hvp_state(target) else {
1219 return Array1::<f64>::zeros(v.len());
1220 };
1221 self.hvp_with_precomputed_state(&state, rho, v)
1222 }
1223
1224 /// PSD majorizer-vector product `B_GN(target; ρ) v` for the **nonconvex**
1225 /// isometry penalty.
1226 ///
1227 /// The Gauss-Newton block differentiates the normalized residual
1228 /// `R = g/gbar - G_ref` itself and returns `μ DRᵀ DR v`. This is PSD by
1229 /// construction and includes the shared-normalizer derivative exactly;
1230 /// using only `∂g` would reintroduce scale coupling and would not be the
1231 /// Gauss-Newton operator of the objective being minimized.
1232 fn psd_majorizer_hvp(
1233 &self,
1234 target: ArrayView1<'_, f64>,
1235 rho: ArrayView1<'_, f64>,
1236 v: ArrayView1<'_, f64>,
1237 ) -> Array1<f64> {
1238 let d = self
1239 .target
1240 .latent_dim
1241 .expect("IsometryPenalty requires latent_dim on its PsiSlice");
1242 let n_obs = target.len() / d;
1243 if !self.has_jacobian_cache("psd_majorizer_hvp")
1244 || !self.has_jacobian_second_source("psd_majorizer_hvp")
1245 {
1246 return Array1::<f64>::zeros(v.len());
1247 }
1248 let Some(jac2) = self.jacobian_second(target, n_obs, d) else {
1249 return Array1::<f64>::zeros(v.len());
1250 };
1251 let Some(g) = self.pullback_metric(d) else {
1252 return Array1::<f64>::zeros(v.len());
1253 };
1254 let Some(metric) = self.normalized_metric_state(g, n_obs, d) else {
1255 return Array1::<f64>::zeros(v.len());
1256 };
1257 let p = self.p_out;
1258 let mu = validated_learnable_weight(self.scalar_weight, rho[self.rho_index]);
1259 let mut out = Array1::<f64>::zeros(v.len());
1260 let mut wj_rows = Vec::with_capacity(n_obs);
1261 for n in 0..n_obs {
1262 let Some(wj) = self.weighted_jacobian_row(n, d) else {
1263 return Array1::<f64>::zeros(v.len());
1264 };
1265 wj_rows.push(wj);
1266 }
1267 let mut delta_g = Array2::<f64>::zeros((n_obs, d * d));
1268 for n in 0..n_obs {
1269 let row_delta = isometry_row_delta_g(jac2.view(), wj_rows[n].view(), v, n, d, p);
1270 for a in 0..d {
1271 for b in 0..d {
1272 delta_g[[n, a * d + b]] = row_delta[[a, b]];
1273 }
1274 }
1275 }
1276 let (delta_residual, _delta_normalizer) = metric.residual_direction(delta_g.view(), d);
1277 let mut g_dot_delta_residual = 0.0;
1278 for n in 0..n_obs {
1279 for k in 0..(d * d) {
1280 g_dot_delta_residual += metric.g[[n, k]] * delta_residual[[n, k]];
1281 }
1282 }
1283 let inv_norm = 1.0 / metric.normalizer;
1284 let inv_norm_sq = inv_norm * inv_norm;
1285 for n in 0..n_obs {
1286 let wj = &wj_rows[n];
1287 for c in 0..d {
1288 let mut trace_dg = 0.0;
1289 for a in 0..d {
1290 trace_dg += isometry_dg_entry(jac2.view(), wj.view(), n, d, p, a, a, c);
1291 }
1292 let delta_normalizer_c = trace_dg / metric.trace_denominator;
1293 let mut acc = -delta_normalizer_c * inv_norm_sq * g_dot_delta_residual;
1294 for a in 0..d {
1295 for b in 0..d {
1296 let dg = isometry_dg_entry(jac2.view(), wj.view(), n, d, p, a, b, c);
1297 acc += dg * inv_norm * delta_residual[[n, a * d + b]];
1298 }
1299 }
1300 out[n * d + c] = mu * acc;
1301 }
1302 }
1303 out
1304 }
1305
1306 fn grad_rho(&self, target: ArrayView1<'_, f64>, rho: ArrayView1<'_, f64>) -> Array1<f64> {
1307 // P(ρ) = ½ μ · S, where S is the (ρ-independent) Frobenius sum and
1308 // μ = exp(ρ_iso). So ∂P/∂ρ_iso = P.
1309 let mut out = Array1::<f64>::zeros(self.rho_count());
1310 out[self.rho_index] = self.value(target, rho);
1311 out
1312 }
1313
1314 fn rho_count(&self) -> usize {
1315 1
1316 }
1317
1318 fn name(&self) -> &str {
1319 "isometry"
1320 }
1321
1322 impl_scalar_apply_schedule!(scalar_weight);
1323}