Skip to content

Commit d6146ab

Browse files
authored
Actively send catch-up traffic in tracking mode (#620)
* wip track * fix
1 parent 98f89d8 commit d6146ab

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/handle_append_entries.cxx

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1310,6 +1310,12 @@ void raft_server::handle_append_entries_resp(resp_msg& resp) {
13101310
: resp.get_next_idx();
13111311
need_to_catchup = p->clear_pending_commit() ||
13121312
next_idx_to_send < log_store_->next_slot();
1313+
if (ctx_->get_params()->track_peers_sm_commit_idx_) {
1314+
if (p->get_sm_committed_idx() &&
1315+
p->get_sm_committed_idx() < quick_commit_index_) {
1316+
need_to_catchup = true;
1317+
}
1318+
}
13131319
p_tr("need to catchup peer %d: %d", p->get_id(), need_to_catchup);
13141320

13151321
} else {

0 commit comments

Comments
 (0)