mirrors/rust-lightning
1
0
Fork 0
mirror of https://github.com/lightningdevkit/rust-lightning.git synced 2025-03-03 10:46:48 +01:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #1843 from TheBlueMatt/2022-11-fix-bp-exit-docs

Browse source 
Correct async `lightning-background-processor` exit check docs
This commit is contained in:
Matt Corallo 2022-11-10 00:42:20 +00:00 • committed by GitHub
commit 384c4dc775
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lightning-background-processor/src/lib.rs
View file

@ -358,8 +358,8 @@ macro_rules! define_run_body {
/// Processes background events in a future. /// Processes background events in a future.
/// ///
/// `sleeper` should return a future which completes in the given amount of time and returns a /// `sleeper` should return a future which completes in the given amount of time and returns a
/// boolean indicating whether the background processing should continue. Once `sleeper` returns a /// boolean indicating whether the background processing should exit. Once `sleeper` returns a
/// future which outputs false, the loop will exit and this function's future will complete. /// future which outputs true, the loop will exit and this function's future will complete.
/// ///
/// See [`BackgroundProcessor::start`] for information on which actions this handles. /// See [`BackgroundProcessor::start`] for information on which actions this handles.
#[cfg(feature = "futures")] #[cfg(feature = "futures")]
@ -411,13 +411,13 @@ where
UMH::Target: 'static + CustomMessageHandler, UMH::Target: 'static + CustomMessageHandler,
PS::Target: 'static + Persister<'a, Signer, CW, T, K, F, L, SC>, PS::Target: 'static + Persister<'a, Signer, CW, T, K, F, L, SC>,
{ {
let mut should_continue = true; let mut should_break = true;
define_run_body!(persister, event_handler, chain_monitor, channel_manager, define_run_body!(persister, event_handler, chain_monitor, channel_manager,
gossip_sync, peer_manager, logger, scorer, should_continue, { gossip_sync, peer_manager, logger, scorer, should_break, {
select_biased! { select_biased! {
_ = channel_manager.get_persistable_update_future().fuse() => true, _ = channel_manager.get_persistable_update_future().fuse() => true,
cont = sleeper(Duration::from_millis(100)).fuse() => { exit = sleeper(Duration::from_millis(100)).fuse() => {
should_continue = cont; should_break = exit;
false false
} }
} }