pytest: rework test_real_data and test_real_biases to be parallel.

This speeds them up, and exercises the askrene parallel code.

Before: test_real_data: 260s  test_real_biases: 173s
After:  test_real_data: 133s  test_real_biases: 106s

And this is because much of the time is spent uncompressing the gossmap
and startup.

Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>

Author: rustyrussell

tests/test_askrene.py

@@ -1405,7 +1405,7 @@ def test_min_htlc_after_excess(node_factory, bitcoind):
 
 
 @pytest.mark.slow_test
-def test_real_data(node_factory, bitcoind):
+def test_real_data(node_factory, bitcoind, executor):
     # Route from Rusty's node to the top nodes
     # From tests/data/gossip-store-2024-09-22-node-map.xz:
     # Me: 3301:024b9a1fa8e006f1e3937f65f66c408e6da8e1ca728ea43222a7381df1cc449605:BLUEIRON
@@ -1451,59 +1451,63 @@ def test_real_data(node_factory, bitcoind):
         limit = 100
         expected = (9, 96, 6565466, 668476, 90)
 
-    fees = {}
+    # 0.5% is the norm
+    MAX_FEE = AMOUNT // 200
+
+    # Do these in parallel.
+    futs = {}
     for n in range(0, limit):
-        print(f"XXX: {n}")
-        # 0.5% is the norm
-        MAX_FEE = AMOUNT // 200
+        futs[n] = executor.submit(l1.rpc.getroutes,
+                                  source=l1.info['id'],
+                                  destination=nodeids[n],
+                                  amount_msat=AMOUNT,
+                                  layers=['auto.sourcefree', 'auto.localchans'],
+                                  maxfee_msat=MAX_FEE,
+                                  final_cltv=18)
 
+    
+    fees = {}
+    prevs = {}
+    for n in range(0, limit):
+        fees[n] = []
         if n in badnodes:
             with pytest.raises(RpcError, match=badnodes[n]):
-                l1.rpc.getroutes(source=l1.info['id'],
-                                 destination=nodeids[n],
-                                 amount_msat=AMOUNT,
-                                 layers=['auto.sourcefree', 'auto.localchans'],
-                                 maxfee_msat=MAX_FEE,
-                                 final_cltv=18)
-            fees[n] = []
-            continue
-
-        try:
-            prev = l1.rpc.getroutes(source=l1.info['id'],
-                                    destination=nodeids[n],
-                                    amount_msat=AMOUNT,
-                                    layers=['auto.sourcefree', 'auto.localchans'],
-                                    maxfee_msat=MAX_FEE,
-                                    final_cltv=18)
-        except RpcError:
-            fees[n] = []
+                futs[n].result(TIMEOUT)
             continue
 
-        # Now stress it, by asking it to spend 1msat less!
-        fees[n] = [sum([r['path'][0]['amount_msat'] for r in prev['routes']]) - AMOUNT]
+        prevs[n] = futs[n].result(TIMEOUT)
+
+    # Stress it by asking harder for each one which succeeded
+    while prevs != {}:
+        futs = {}
+        for n, prev in prevs.items():
+            # Record fees
+            fees[n].append(sum([r['path'][0]['amount_msat'] for r in prev['routes']]) - AMOUNT)
+            # Now stress it, by asking it to spend 1msat less!
+            futs[n] = executor.submit(l1.rpc.getroutes,
+                                      source=l1.info['id'],
+                                      destination=nodeids[n],
+                                      amount_msat=AMOUNT,
+                                      layers=['auto.sourcefree', 'auto.localchans'],
+                                      maxfee_msat=fees[n][-1] - 1,
+                                      final_cltv=18)
 
-        while True:
-            # Keep making it harder...
+        for n, fut in futs.items():
             try:
-                routes = l1.rpc.getroutes(source=l1.info['id'],
-                                          destination=nodeids[n],
-                                          amount_msat=AMOUNT,
-                                          layers=['auto.sourcefree', 'auto.localchans'],
-                                          maxfee_msat=fees[n][-1] - 1,
-                                          final_cltv=18)
+                routes = fut.result(TIMEOUT)
             except RpcError:
-                break
+                # Too much, this one is one.
+                del prevs[n]
+                continue
 
             fee = sum([r['path'][0]['amount_msat'] for r in routes['routes']]) - AMOUNT
             # Should get less expensive
             assert fee < fees[n][-1]
 
             # Should get less likely (Note!  This is violated because once we care
             # about fees, the total is reduced, leading to better prob!).
-#            assert routes['probability_ppm'] < prev['probability_ppm']
-
-            fees[n].append(fee)
-            prev = routes
+#            assert routes['probability_ppm'] < prevs[n]['probability_ppm']
+            prevs[n] = routes
 
     # Which succeeded in improving
     improved = [n for n in fees if len(fees[n]) > 1]
@@ -1521,10 +1525,12 @@ def test_real_data(node_factory, bitcoind):
             best = n
 
     assert (len(fees[best]), len(improved), total_first_fee, total_final_fee, percent_fee_reduction) == expected
+    # askrene will have restricted how many we run
+    assert l1.daemon.is_in_log(r"Too many running at once \(4 vs 4\): waiting")
 
 
 @pytest.mark.slow_test
-def test_real_biases(node_factory, bitcoind):
+def test_real_biases(node_factory, bitcoind, executor):
     # Route from Rusty's node to the top 100.
     # From tests/data/gossip-store-2024-09-22-node-map.xz:
     # Me: 3301:024b9a1fa8e006f1e3937f65f66c408e6da8e1ca728ea43222a7381df1cc449605:BLUEIRON
@@ -1572,22 +1578,34 @@ def test_real_biases(node_factory, bitcoind):
     num_changed = {}
     bias_ineffective = 0
 
+    # 0.5% is the norm
+    MAX_FEE = AMOUNT // 200
+
+    # To exercise parallelism, do bases all at once.
+    futures = {}
+    for n in range(0, limit):
+        if n in badnodes:
+            continue
+        futures[n] = executor.submit(l1.rpc.getroutes,
+                                         source=l1.info[ 'id'],
+                                         destination=nodeids[n],
+                                         amount_msat=AMOUNT,
+                                         layers=['auto.sourcefree', 'auto.localchans'],
+                                         maxfee_msat=MAX_FEE,
+                                         final_cltv=18)
+
+    base_routes = {}
+    for n in range(0, limit):
+        if n in badnodes:
+            continue
+        base_routes[n] = futures[n].result(TIMEOUT)
+
     for bias in (1, 2, 4, 8, 16, 32, 64, 100):
         num_changed[bias] = 0
         for n in range(0, limit):
-            # 0.5% is the norm
-            MAX_FEE = AMOUNT // 200
-
             if n in badnodes:
                 continue
-
-            route = l1.rpc.getroutes(source=l1.info['id'],
-                                     destination=nodeids[n],
-                                     amount_msat=AMOUNT,
-                                     layers=['auto.sourcefree', 'auto.localchans'],
-                                     maxfee_msat=MAX_FEE,
-                                     final_cltv=18)
-
+            route = base_routes[n]
             # Now add bias against final channel, see if it changes.
             chan = route['routes'][0]['path'][-1]['short_channel_id_dir']