In replication scenario, entry_sm gets updated every time it is used.

Signed-off-by: Anatoliy Bilenko <[email protected]>
canonical · Nov 25, 2024 · 9539a2e · 9539a2e
1 parent 6ba0bf8
commit 9539a2e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/raft/replication.c b/src/raft/replication.c
@@ -1838,7 +1838,10 @@ int replicationApply(struct raft *r)
 			tracef("replicationApply - ENTRY NULL");
 			return 0;
 		}
-		struct sm *entry_sm = log_get_entry_sm(r->log, entry->term, index);
+		raft_term entry_sm_term = entry->term;
+		raft_index entry_sm_index = index;
+		struct sm *entry_sm = log_get_entry_sm(r->log, entry_sm_term,
+						       entry_sm_index);
 		assert(entry_sm != NULL);
 
 		assert(entry->type == RAFT_COMMAND ||
@@ -1865,6 +1868,9 @@ int replicationApply(struct raft *r)
 		}
 
 		if (rv == 0) {
+			entry_sm = log_get_entry_sm(r->log, entry_sm_term,
+						    entry_sm_index);
+			assert(entry_sm != NULL);
 			sm_move(entry_sm, ENTRY_APPLIED);
 		} else {
 			break;