WIP: batch sparse.linalg.cg

[skip ci]

Author: lucascolley

scipy/sparse/linalg/_isolve/iterative.py

@@ -6,6 +6,8 @@
 from .utils import make_system
 from scipy.linalg import get_lapack_funcs
 
+from scipy._lib import array_api_extra as xpx
+
 __all__ = ['bicg', 'bicgstab', 'cg', 'cgs', 'gmres', 'qmr']
 
 
@@ -399,21 +401,43 @@ def cg(A, b, x0=None, *, rtol=1e-5, atol=0., maxiter=None, M=None, callback=None
     rho_prev, p = None, None
 
     for iteration in range(maxiter):
-        if np.all(np.linalg.norm(r, axis=-1) < atol):  # Are we done?
+        converged = np.linalg.norm(r, axis=-1) < atol
+        if np.all(converged):
             return x, 0
 
         z = psolve(r)
         rho_cur = dotprod(r, z)
+
         if iteration > 0:
+<<<<<<< HEAD
             beta = rho_cur / rho_prev
             p = (beta * p.T).T 
+=======
+            beta = xpx.apply_where(
+                not converged,
+                (rho_cur, rho_prev),
+                lambda cur, prev: cur / prev,
+                fill_value=0.0,
+                xp=np
+            )
+            p = (beta * p.T).T
+>>>>>>> 07ade92418 (WIP: batch `sparse.linalg.cg`)
             p += z
         else:  # First spin
             p = np.empty_like(r)
             p[:] = z[:]
 
         q = matvec(p)
-        alpha = rho_cur / dotprod(p, q)
+        c = dotprod(p, q)
+
+        alpha = xpx.apply_where(
+            not converged,
+            (rho_cur, c),
+            lambda rc, c: rc / c,
+            fill_value=0.0,
+            xp=np
+        )
+        
         x += (alpha * p.T).T
         r -= (alpha * q.T).T
         rho_prev = rho_cur