Skip to content

Commit 7df6b69

Browse files
committed
Update
1 parent 2816a10 commit 7df6b69

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/handle_commit.cxx

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ void raft_server::commit_in_bg() {
120120
while ( ( quick_commit_index_ <= sm_commit_index_ ||
121121
sm_commit_index_ >= log_store_->next_slot() - 1 ||
122122
sm_commit_paused_ ) &&
123-
sm_commit_notifier_target_idx_ <= sm_commit_notifier_notified_idx_ ) {
123+
sm_commit_notifier_target_idx_ == sm_commit_notifier_notified_idx_ ) {
124124
std::unique_lock<std::mutex> lock(commit_cv_lock_);
125125

126126
auto wait_check = [this]() {
@@ -315,6 +315,7 @@ bool raft_server::commit_in_bg_exec(size_t timeout_ms) {
315315
watcher->set_result(ret_bool, exp);
316316
}
317317
}
318+
318319
}
319320

320321
p_db( "DONE: commit upto %" PRIu64 ", current idx %" PRIu64,

0 commit comments

Comments
 (0)