@@ -242,7 +242,7 @@ pub struct ChainMonitor<ChannelSigner: WriteableEcdsaChannelSigner, C: Deref, T:
242
242
/// The best block height seen, used as a proxy for the passage of time.
243
243
highest_chain_height : AtomicUsize ,
244
244
245
- persistence_notifier : Notifier ,
245
+ event_notifier : Notifier ,
246
246
}
247
247
248
248
impl < 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,
303
303
ChannelMonitorUpdateStatus :: PermanentFailure => {
304
304
monitor_state. channel_perm_failed . store ( true , Ordering :: Release ) ;
305
305
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 ( ) ;
307
307
} ,
308
308
ChannelMonitorUpdateStatus :: InProgress => {
309
309
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,
349
349
persister,
350
350
pending_monitor_events : Mutex :: new ( Vec :: new ( ) ) ,
351
351
highest_chain_height : AtomicUsize :: new ( 0 ) ,
352
- persistence_notifier : Notifier :: new ( ) ,
352
+ event_notifier : Notifier :: new ( ) ,
353
353
}
354
354
}
355
355
@@ -477,7 +477,7 @@ where C::Target: chain::Filter,
477
477
}
478
478
} ,
479
479
}
480
- self . persistence_notifier . notify ( ) ;
480
+ self . event_notifier . notify ( ) ;
481
481
Ok ( ( ) )
482
482
}
483
483
@@ -492,7 +492,7 @@ where C::Target: chain::Filter,
492
492
funding_txo,
493
493
monitor_update_id,
494
494
} ] , counterparty_node_id) ) ;
495
- self . persistence_notifier . notify ( ) ;
495
+ self . event_notifier . notify ( ) ;
496
496
}
497
497
498
498
#[ cfg( any( test, fuzzing, feature = "_test_utils" ) ) ]
@@ -531,7 +531,7 @@ where C::Target: chain::Filter,
531
531
///
532
532
/// [`EventsProvider::process_pending_events`]: crate::util::events::EventsProvider::process_pending_events
533
533
pub fn get_update_future ( & self ) -> Future {
534
- self . persistence_notifier . get_future ( )
534
+ self . event_notifier . get_future ( )
535
535
}
536
536
}
537
537
0 commit comments