Skip to content

Commit c04b14b

Browse files
committed
add timeout retry strategy to outbound payment
1 parent 0d1c9dd commit c04b14b

File tree

5 files changed

+175
-78
lines changed

5 files changed

+175
-78
lines changed

lightning-background-processor/src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -362,7 +362,7 @@ mod tests {
362362
use lightning::util::ser::Writeable;
363363
use lightning::util::test_utils;
364364
use lightning::util::persist::KVStorePersister;
365-
use lightning_invoice::payment::{InvoicePayer, RetryAttempts};
365+
use lightning_invoice::payment::{InvoicePayer, Retry};
366366
use lightning_invoice::utils::DefaultRouter;
367367
use lightning_persister::FilesystemPersister;
368368
use std::fs;
@@ -749,7 +749,7 @@ mod tests {
749749
let persister = Arc::new(Persister::new(data_dir));
750750
let scorer = Arc::new(Mutex::new(test_utils::TestScorer::with_penalty(0)));
751751
let router = DefaultRouter::new(Arc::clone(&nodes[0].network_graph), Arc::clone(&nodes[0].logger), random_seed_bytes);
752-
let invoice_payer = Arc::new(InvoicePayer::new(Arc::clone(&nodes[0].node), router, scorer, Arc::clone(&nodes[0].logger), |_: &_| {}, RetryAttempts(2)));
752+
let invoice_payer = Arc::new(InvoicePayer::new(Arc::clone(&nodes[0].node), router, scorer, Arc::clone(&nodes[0].logger), |_: &_| {}, Retry::Attempts(2)));
753753
let event_handler = Arc::clone(&invoice_payer);
754754
let bg_processor = BackgroundProcessor::start(persister, event_handler, nodes[0].chain_monitor.clone(), nodes[0].node.clone(), nodes[0].net_graph_msg_handler.clone(), nodes[0].peer_manager.clone(), nodes[0].logger.clone());
755755
assert!(bg_processor.stop().is_ok());

lightning-invoice/src/lib.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@ compile_error!("at least one of the `std` or `no-std` features must be enabled")
2525
pub mod payment;
2626
pub mod utils;
2727

28+
pub(crate) mod time_utils;
29+
2830
extern crate bech32;
2931
extern crate bitcoin_hashes;
3032
#[macro_use] extern crate lightning;

0 commit comments

Comments
 (0)