@@ -520,7 +520,7 @@ where
520
520
521
521
let payer = self . payer . node_id ( ) ;
522
522
let first_hops = self . payer . first_hops ( ) ;
523
- let inflight_htlcs = self . create_inflight_map ( ) ;
523
+ let inflight_htlcs = self . payer . inflight_htlcs ( ) ;
524
524
let route = self . router . find_route (
525
525
& payer, & params, Some ( & first_hops. iter ( ) . collect :: < Vec < _ > > ( ) ) , inflight_htlcs
526
526
) . map_err ( |e| PaymentError :: Routing ( e) ) ?;
@@ -586,7 +586,7 @@ where
586
586
587
587
let payer = self . payer . node_id ( ) ;
588
588
let first_hops = self . payer . first_hops ( ) ;
589
- let inflight_htlcs = self . create_inflight_map ( ) ;
589
+ let inflight_htlcs = self . payer . inflight_htlcs ( ) ;
590
590
591
591
let route = self . router . find_route (
592
592
& payer, & params, Some ( & first_hops. iter ( ) . collect :: < Vec < _ > > ( ) ) , inflight_htlcs
@@ -624,12 +624,6 @@ where
624
624
pub fn remove_cached_payment ( & self , payment_hash : & PaymentHash ) {
625
625
self . payment_cache . lock ( ) . unwrap ( ) . remove ( payment_hash) ;
626
626
}
627
-
628
- /// Construct an [`InFlightHtlcs`] containing information about currently used up liquidity
629
- /// across payments.
630
- fn create_inflight_map ( & self ) -> InFlightHtlcs {
631
- self . payer . inflight_htlcs ( )
632
- }
633
627
}
634
628
635
629
fn expiry_time_from_unix_epoch ( invoice : & Invoice ) -> Duration {
@@ -1470,7 +1464,7 @@ mod tests {
1470
1464
1471
1465
let payment_id = invoice_payer. pay_invoice ( & invoice) . unwrap ( ) ;
1472
1466
1473
- let inflight_map = invoice_payer. create_inflight_map ( ) ;
1467
+ let inflight_map = invoice_payer. payer . inflight_htlcs ( ) ;
1474
1468
// First path check
1475
1469
assert_eq ! ( inflight_map. 0 . get( & ( 0 , false ) ) . unwrap( ) . clone( ) , 94 ) ;
1476
1470
assert_eq ! ( inflight_map. 0 . get( & ( 1 , true ) ) . unwrap( ) . clone( ) , 84 ) ;
@@ -1484,7 +1478,7 @@ mod tests {
1484
1478
payment_id, payment_hash, path : route. paths [ 0 ] . clone ( )
1485
1479
} ) ;
1486
1480
1487
- let inflight_map = invoice_payer. create_inflight_map ( ) ;
1481
+ let inflight_map = invoice_payer. payer . inflight_htlcs ( ) ;
1488
1482
1489
1483
assert_eq ! ( inflight_map. 0 . get( & ( 0 , false ) ) , None ) ;
1490
1484
assert_eq ! ( inflight_map. 0 . get( & ( 1 , true ) ) , None ) ;
@@ -1642,7 +1636,7 @@ mod tests {
1642
1636
InvoicePayer :: new ( & payer, router, & logger, event_handler, Retry :: Attempts ( 0 ) ) ;
1643
1637
1644
1638
invoice_payer. pay_invoice ( & invoice_to_pay) . unwrap ( ) ;
1645
- let inflight_map = invoice_payer. create_inflight_map ( ) ;
1639
+ let inflight_map = invoice_payer. payer . inflight_htlcs ( ) ;
1646
1640
1647
1641
// Only the second path, which failed with `MonitorUpdateInProgress` should be added to our
1648
1642
// inflight map because retries are disabled.
@@ -1673,7 +1667,7 @@ mod tests {
1673
1667
InvoicePayer :: new ( & payer, router, & logger, event_handler, Retry :: Attempts ( 0 ) ) ;
1674
1668
1675
1669
invoice_payer. pay_invoice ( & invoice_to_pay) . unwrap ( ) ;
1676
- let inflight_map = invoice_payer. create_inflight_map ( ) ;
1670
+ let inflight_map = invoice_payer. payer . inflight_htlcs ( ) ;
1677
1671
1678
1672
// All paths successful, hence we check of the existence of all 5 hops.
1679
1673
assert_eq ! ( inflight_map. 0 . len( ) , 5 ) ;
0 commit comments