1111
1212#![ cfg_attr( docsrs, feature( doc_auto_cfg) ) ]
1313
14+ #![ cfg_attr( all( not( feature = "std" ) , not( test) ) , no_std) ]
15+
16+ #[ cfg( any( test, feature = "std" ) ) ]
17+ extern crate core;
18+
1419#[ macro_use] extern crate lightning;
1520extern crate lightning_rapid_gossip_sync;
1621
@@ -28,15 +33,22 @@ use lightning::util::events::{Event, EventHandler, EventsProvider};
2833use lightning:: util:: logger:: Logger ;
2934use lightning:: util:: persist:: Persister ;
3035use lightning_rapid_gossip_sync:: RapidGossipSync ;
36+ use lightning:: io;
37+
38+ use core:: ops:: Deref ;
39+ use core:: time:: Duration ;
40+
41+ #[ cfg( feature = "std" ) ]
3142use std:: sync:: Arc ;
32- use std:: sync:: atomic:: { AtomicBool , Ordering } ;
33- use std:: thread;
34- use std:: thread:: JoinHandle ;
35- use std:: time:: { Duration , Instant } ;
36- use std:: ops:: Deref ;
43+ #[ cfg( feature = "std" ) ]
44+ use core:: sync:: atomic:: { AtomicBool , Ordering } ;
45+ #[ cfg( feature = "std" ) ]
46+ use std:: thread:: { self , JoinHandle } ;
47+ #[ cfg( feature = "std" ) ]
48+ use std:: time:: Instant ;
3749
3850#[ cfg( feature = "futures" ) ]
39- use futures_util:: { select_biased, future:: FutureExt } ;
51+ use futures_util:: { select_biased, future:: FutureExt , task } ;
4052
4153/// `BackgroundProcessor` takes care of tasks that (1) need to happen periodically to keep
4254/// Rust-Lightning running properly, and (2) either can or should be run in the background. Its
@@ -62,6 +74,7 @@ use futures_util::{select_biased, future::FutureExt};
6274///
6375/// [`ChannelMonitor`]: lightning::chain::channelmonitor::ChannelMonitor
6476/// [`Event`]: lightning::util::events::Event
77+ #[ cfg( feature = "std" ) ]
6578#[ must_use = "BackgroundProcessor will immediately stop on drop. It should be stored until shutdown." ]
6679pub struct BackgroundProcessor {
6780 stop_thread : Arc < AtomicBool > ,
@@ -207,15 +220,15 @@ macro_rules! define_run_body {
207220 ( $persister: ident, $chain_monitor: ident, $process_chain_monitor_events: expr,
208221 $channel_manager: ident, $process_channel_manager_events: expr,
209222 $gossip_sync: ident, $peer_manager: ident, $logger: ident, $scorer: ident,
210- $loop_exit_check: expr, $await: expr)
223+ $loop_exit_check: expr, $await: expr, $get_timer : expr , $timer_elapsed : expr )
211224 => { {
212225 log_trace!( $logger, "Calling ChannelManager's timer_tick_occurred on startup" ) ;
213226 $channel_manager. timer_tick_occurred( ) ;
214227
215- let mut last_freshness_call = Instant :: now ( ) ;
216- let mut last_ping_call = Instant :: now ( ) ;
217- let mut last_prune_call = Instant :: now ( ) ;
218- let mut last_scorer_persist_call = Instant :: now ( ) ;
228+ let mut last_freshness_call = $get_timer ( FRESHNESS_TIMER ) ;
229+ let mut last_ping_call = $get_timer ( PING_TIMER ) ;
230+ let mut last_prune_call = $get_timer ( FIRST_NETWORK_PRUNE_TIMER ) ;
231+ let mut last_scorer_persist_call = $get_timer ( SCORER_PERSIST_TIMER ) ;
219232 let mut have_pruned = false ;
220233
221234 loop {
@@ -237,9 +250,9 @@ macro_rules! define_run_body {
237250
238251 // We wait up to 100ms, but track how long it takes to detect being put to sleep,
239252 // see `await_start`'s use below.
240- let await_start = Instant :: now ( ) ;
253+ let mut await_start = $get_timer ( 1 ) ;
241254 let updates_available = $await;
242- let await_time = await_start . elapsed ( ) ;
255+ let await_slow = $timer_elapsed ( & mut await_start , 1 ) ;
243256
244257 if updates_available {
245258 log_trace!( $logger, "Persisting ChannelManager..." ) ;
@@ -251,12 +264,12 @@ macro_rules! define_run_body {
251264 log_trace!( $logger, "Terminating background processor." ) ;
252265 break ;
253266 }
254- if last_freshness_call . elapsed ( ) . as_secs ( ) > FRESHNESS_TIMER {
267+ if $timer_elapsed ( & mut last_freshness_call , FRESHNESS_TIMER ) {
255268 log_trace!( $logger, "Calling ChannelManager's timer_tick_occurred" ) ;
256269 $channel_manager. timer_tick_occurred( ) ;
257- last_freshness_call = Instant :: now ( ) ;
270+ last_freshness_call = $get_timer ( FRESHNESS_TIMER ) ;
258271 }
259- if await_time > Duration :: from_secs ( 1 ) {
272+ if await_slow {
260273 // On various platforms, we may be starved of CPU cycles for several reasons.
261274 // E.g. on iOS, if we've been in the background, we will be entirely paused.
262275 // Similarly, if we're on a desktop platform and the device has been asleep, we
@@ -271,40 +284,46 @@ macro_rules! define_run_body {
271284 // peers.
272285 log_trace!( $logger, "100ms sleep took more than a second, disconnecting peers." ) ;
273286 $peer_manager. disconnect_all_peers( ) ;
274- last_ping_call = Instant :: now ( ) ;
275- } else if last_ping_call . elapsed ( ) . as_secs ( ) > PING_TIMER {
287+ last_ping_call = $get_timer ( PING_TIMER ) ;
288+ } else if $timer_elapsed ( & mut last_ping_call , PING_TIMER ) {
276289 log_trace!( $logger, "Calling PeerManager's timer_tick_occurred" ) ;
277290 $peer_manager. timer_tick_occurred( ) ;
278- last_ping_call = Instant :: now ( ) ;
291+ last_ping_call = $get_timer ( PING_TIMER ) ;
279292 }
280293
281294 // Note that we want to run a graph prune once not long after startup before
282295 // falling back to our usual hourly prunes. This avoids short-lived clients never
283296 // pruning their network graph. We run once 60 seconds after startup before
284297 // continuing our normal cadence.
285- if last_prune_call . elapsed ( ) . as_secs ( ) > if have_pruned { NETWORK_PRUNE_TIMER } else { FIRST_NETWORK_PRUNE_TIMER } {
298+ if $timer_elapsed ( & mut last_prune_call , if have_pruned { NETWORK_PRUNE_TIMER } else { FIRST_NETWORK_PRUNE_TIMER } ) {
286299 // The network graph must not be pruned while rapid sync completion is pending
287300 if let Some ( network_graph) = $gossip_sync. prunable_network_graph( ) {
288- log_trace!( $logger, "Pruning and persisting network graph." ) ;
289- network_graph. remove_stale_channels_and_tracking( ) ;
301+ #[ cfg( feature = "std" ) ] {
302+ log_trace!( $logger, "Pruning and persisting network graph." ) ;
303+ network_graph. remove_stale_channels_and_tracking( ) ;
304+ }
305+ #[ cfg( not( feature = "std" ) ) ] {
306+ log_warn!( $logger, "Not pruning network graph, consider enabling `std` or doing so manually with remove_stale_channels_and_tracking_with_time." ) ;
307+ log_trace!( $logger, "Persisting network graph." ) ;
308+ }
290309
291310 if let Err ( e) = $persister. persist_graph( network_graph) {
292311 log_error!( $logger, "Error: Failed to persist network graph, check your disk and permissions {}" , e)
293312 }
294313
295- last_prune_call = Instant :: now ( ) ;
314+ last_prune_call = $get_timer ( NETWORK_PRUNE_TIMER ) ;
296315 have_pruned = true ;
297316 }
298317 }
299318
300- if last_scorer_persist_call . elapsed ( ) . as_secs ( ) > SCORER_PERSIST_TIMER {
319+ if $timer_elapsed ( & mut last_scorer_persist_call , SCORER_PERSIST_TIMER ) {
301320 if let Some ( ref scorer) = $scorer {
302321 log_trace!( $logger, "Persisting scorer" ) ;
303322 if let Err ( e) = $persister. persist_scorer( & scorer) {
304323 log_error!( $logger, "Error: Failed to persist scorer, check your disk and permissions {}" , e)
305324 }
306325 }
307- last_scorer_persist_call = Instant :: now ( ) ;
326+ last_scorer_persist_call = $get_timer ( SCORER_PERSIST_TIMER ) ;
308327 }
309328 }
310329
@@ -334,6 +353,11 @@ macro_rules! define_run_body {
334353/// future which outputs true, the loop will exit and this function's future will complete.
335354///
336355/// See [`BackgroundProcessor::start`] for information on which actions this handles.
356+ ///
357+ /// Requires the `futures` feature. Note that while this method is available without the `std`
358+ /// feature, doing so will skip calling [`NetworkGraph::remove_stale_channels_and_tracking`],
359+ /// you should call [`NetworkGraph::remove_stale_channels_and_tracking_with_time`] regularly
360+ /// manually instead.
337361#[ cfg( feature = "futures" ) ]
338362pub async fn process_events_async <
339363 ' a ,
@@ -364,13 +388,13 @@ pub async fn process_events_async<
364388 PM : ' static + Deref < Target = PeerManager < Descriptor , CMH , RMH , OMH , L , UMH > > + Send + Sync ,
365389 S : ' static + Deref < Target = SC > + Send + Sync ,
366390 SC : WriteableScore < ' a > ,
367- SleepFuture : core:: future:: Future < Output = bool > ,
391+ SleepFuture : core:: future:: Future < Output = bool > + core :: marker :: Unpin ,
368392 Sleeper : Fn ( Duration ) -> SleepFuture
369393> (
370394 persister : PS , event_handler : EventHandler , chain_monitor : M , channel_manager : CM ,
371395 gossip_sync : GossipSync < PGS , RGS , G , CA , L > , peer_manager : PM , logger : L , scorer : Option < S > ,
372396 sleeper : Sleeper ,
373- ) -> Result < ( ) , std :: io:: Error >
397+ ) -> Result < ( ) , io:: Error >
374398where
375399 CA :: Target : ' static + chain:: Access ,
376400 CF :: Target : ' static + chain:: Filter ,
@@ -411,9 +435,15 @@ where
411435 false
412436 }
413437 }
438+ } , |t| sleeper( Duration :: from_secs( t) ) ,
439+ |fut: & mut SleepFuture , _| {
440+ let mut waker = task:: noop_waker( ) ;
441+ let mut ctx = task:: Context :: from_waker( & mut waker) ;
442+ core:: pin:: Pin :: new( fut) . poll( & mut ctx) . is_ready( )
414443 } )
415444}
416445
446+ #[ cfg( feature = "std" ) ]
417447impl BackgroundProcessor {
418448 /// Start a background thread that takes care of responsibilities enumerated in the [top-level
419449 /// documentation].
@@ -522,7 +552,8 @@ impl BackgroundProcessor {
522552 define_run_body ! ( persister, chain_monitor, chain_monitor. process_pending_events( & event_handler) ,
523553 channel_manager, channel_manager. process_pending_events( & event_handler) ,
524554 gossip_sync, peer_manager, logger, scorer, stop_thread. load( Ordering :: Acquire ) ,
525- channel_manager. await_persistable_update_timeout( Duration :: from_millis( 100 ) ) )
555+ channel_manager. await_persistable_update_timeout( Duration :: from_millis( 100 ) ) ,
556+ |_| Instant :: now( ) , |time: & Instant , dur| time. elapsed( ) . as_secs( ) > dur)
526557 } ) ;
527558 Self { stop_thread : stop_thread_clone, thread_handle : Some ( handle) }
528559 }
@@ -568,13 +599,14 @@ impl BackgroundProcessor {
568599 }
569600}
570601
602+ #[ cfg( feature = "std" ) ]
571603impl Drop for BackgroundProcessor {
572604 fn drop ( & mut self ) {
573605 self . stop_and_join_thread ( ) . unwrap ( ) ;
574606 }
575607}
576608
577- #[ cfg( test) ]
609+ #[ cfg( all ( feature = "std" , test) ) ]
578610mod tests {
579611 use bitcoin:: blockdata:: block:: BlockHeader ;
580612 use bitcoin:: blockdata:: constants:: genesis_block;
0 commit comments