Skip to content

Commit

Permalink
node: Use get_persistence_condvar_value
Browse files Browse the repository at this point in the history
  • Loading branch information
MaxFangX committed Aug 10, 2022
1 parent 057178c commit 8422fdd
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 8 deletions.
10 changes: 5 additions & 5 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 1 addition & 3 deletions node/src/lexe/background_processor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -74,10 +74,8 @@ impl LexeBackgroundProcessor {
// --- Persistence branches --- //
_ = cm_poll_timer.tick() => {
trace!("Polling channel manager for updates");
// TODO Use get_persistence_condvar_value instead
let timeout = Duration::from_millis(10);
let needs_persist = channel_manager
.await_persistable_update_timeout(timeout);
.get_persistence_condvar_value();
if needs_persist {
let persist_res = persister
.persist_manager(channel_manager.deref())
Expand Down

0 comments on commit 8422fdd

Please sign in to comment.