Skip to content

Commit 8422fdd

Browse files
committed
node: Use get_persistence_condvar_value
1 parent 057178c commit 8422fdd

File tree

2 files changed

+6
-8
lines changed

2 files changed

+6
-8
lines changed

Cargo.lock

Lines changed: 5 additions & 5 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

node/src/lexe/background_processor.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -74,10 +74,8 @@ impl LexeBackgroundProcessor {
7474
// --- Persistence branches --- //
7575
_ = cm_poll_timer.tick() => {
7676
trace!("Polling channel manager for updates");
77-
// TODO Use get_persistence_condvar_value instead
78-
let timeout = Duration::from_millis(10);
7977
let needs_persist = channel_manager
80-
.await_persistable_update_timeout(timeout);
78+
.get_persistence_condvar_value();
8179
if needs_persist {
8280
let persist_res = persister
8381
.persist_manager(channel_manager.deref())

0 commit comments

Comments
 (0)