add sweeper handler

Author: joostjager

lightning-background-processor/src/lib.rs

@@ -602,7 +602,7 @@ pub(crate) mod futures_util {
 	}
 }
 #[cfg(feature = "futures")]
-use core::task;
+use core::{task, future::Future};
 #[cfg(feature = "futures")]
 use futures_util::{dummy_waker, OptionalSelector, Selector, SelectorOutput};
 
@@ -992,6 +992,22 @@ impl BackgroundProcessor {
 				}
 				event_handler.handle_event(event)
 			};
+			let sweeper_handler = || {
+				let mut fut = Box::pin(sweeper.regenerate_and_broadcast_spend_if_necessary_locked());
+				let mut waker = dummy_waker();
+				let mut ctx = task::Context::from_waker(&mut waker);
+				match fut.as_mut().poll(&mut ctx) {
+					task::Poll::Ready(result) => {
+						if let Err(_) = result {
+							log_error!(logger, "Failed to sweep output")
+						}
+					},
+					task::Poll::Pending => {
+						// In a sync context, we can't wait for the future to complete.
+						debug_assert!(false);
+					},
+				}
+			};
 			define_run_body!(
 				persister,
 				chain_monitor,
@@ -1004,7 +1020,7 @@ impl BackgroundProcessor {
 				},
 				peer_manager,
 				gossip_sync,
-				sweeper,
+				sweeper_handler,
 				logger,
 				scorer,
 				stop_thread.load(Ordering::Acquire),