Handle ErrCompacted errors for Compact in raftexample

Signed-off-by: Chen Yang <[email protected]>
etcd-io · Aug 16, 2023 · 8cf15c7 · 8cf15c7
1 parent c1b9647
commit 8cf15c7
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/contrib/raftexample/raft.go b/contrib/raftexample/raft.go
@@ -392,10 +392,13 @@ func (rc *raftNode) maybeTriggerSnapshot(applyDoneC <-chan struct{}) {
 		compactIndex = rc.appliedIndex - snapshotCatchUpEntriesN
 	}
 	if err := rc.raftStorage.Compact(compactIndex); err != nil {
-		panic(err)
+		if err != raft.ErrCompacted {
+			panic(err)
+		}
+	} else {
+		log.Printf("compacted log at index %d", compactIndex)
 	}
-
-	log.Printf("compacted log at index %d", compactIndex)
+
 	rc.snapshotIndex = rc.appliedIndex
 }