Skip to content

Commit ca9b6e8

Browse files
committed
f more notify
1 parent 8c5b793 commit ca9b6e8

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

lightning/src/ln/channelmanager.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5990,7 +5990,7 @@ where
59905990

59915991
#[cfg(any(test, feature = "_test_utils"))]
59925992
pub fn get_persistence_condvar_value(&self) -> bool {
5993-
self.persistence_notifier.needs_persist()
5993+
self.persistence_notifier.notify_pending()
59945994
}
59955995

59965996
/// Gets the latest best block which was connected either via the [`chain::Listen`] or

lightning/src/util/wakers.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ impl Notifier {
8080
}
8181
}
8282

83-
/// Wake waiters, tracking that persistence needs to occur.
83+
/// Wake waiters, tracking that wake needs to occur even if there are currently no waiters.
8484
pub(crate) fn notify(&self) {
8585
let &(ref persist_mtx, ref cnd) = &self.lock;
8686
let mut lock = persist_mtx.lock().unwrap();
@@ -90,7 +90,7 @@ impl Notifier {
9090
}
9191

9292
#[cfg(any(test, feature = "_test_utils"))]
93-
pub fn needs_persist(&self) -> bool {
93+
pub fn notify_pending(&self) -> bool {
9494
let &(ref mtx, _) = &self.lock;
9595
let guard = mtx.lock().unwrap();
9696
*guard

0 commit comments

Comments
 (0)