@@ -242,7 +242,7 @@ pub struct ChainMonitor<ChannelSigner: WriteableEcdsaChannelSigner, C: Deref, T:
242242 /// The best block height seen, used as a proxy for the passage of time.
243243 highest_chain_height : AtomicUsize ,
244244
245- persistence_notifier : Notifier ,
245+ event_notifier : Notifier ,
246246}
247247
248248impl < ChannelSigner : WriteableEcdsaChannelSigner , C : Deref , T : Deref , F : Deref , L : Deref , P : Deref > ChainMonitor < ChannelSigner , C , T , F , L , P >
@@ -303,7 +303,7 @@ where C::Target: chain::Filter,
303303 ChannelMonitorUpdateStatus :: PermanentFailure => {
304304 monitor_state. channel_perm_failed . store ( true , Ordering :: Release ) ;
305305 self . pending_monitor_events . lock ( ) . unwrap ( ) . push ( ( * funding_outpoint, vec ! [ MonitorEvent :: UpdateFailed ( * funding_outpoint) ] , monitor. get_counterparty_node_id ( ) ) ) ;
306- self . persistence_notifier . notify ( ) ;
306+ self . event_notifier . notify ( ) ;
307307 } ,
308308 ChannelMonitorUpdateStatus :: InProgress => {
309309 log_debug ! ( self . logger, "Channel Monitor sync for channel {} in progress, holding events until completion!" , log_funding_info!( monitor) ) ;
@@ -349,7 +349,7 @@ where C::Target: chain::Filter,
349349 persister,
350350 pending_monitor_events : Mutex :: new ( Vec :: new ( ) ) ,
351351 highest_chain_height : AtomicUsize :: new ( 0 ) ,
352- persistence_notifier : Notifier :: new ( ) ,
352+ event_notifier : Notifier :: new ( ) ,
353353 }
354354 }
355355
@@ -477,7 +477,7 @@ where C::Target: chain::Filter,
477477 }
478478 } ,
479479 }
480- self . persistence_notifier . notify ( ) ;
480+ self . event_notifier . notify ( ) ;
481481 Ok ( ( ) )
482482 }
483483
@@ -492,7 +492,7 @@ where C::Target: chain::Filter,
492492 funding_txo,
493493 monitor_update_id,
494494 } ] , counterparty_node_id) ) ;
495- self . persistence_notifier . notify ( ) ;
495+ self . event_notifier . notify ( ) ;
496496 }
497497
498498 #[ cfg( any( test, fuzzing, feature = "_test_utils" ) ) ]
@@ -531,7 +531,7 @@ where C::Target: chain::Filter,
531531 ///
532532 /// [`EventsProvider::process_pending_events`]: crate::util::events::EventsProvider::process_pending_events
533533 pub fn get_update_future ( & self ) -> Future {
534- self . persistence_notifier . get_future ( )
534+ self . event_notifier . get_future ( )
535535 }
536536}
537537
0 commit comments