Handle ErrCompacted errors for Compact in raftexample

Signed-off-by: Chen Yang <[email protected]> Signed-off-by: chenyangyang.cy <[email protected]>
ahrtr · Aug 18, 2023 · 68db708 · 68db708
1 parent c1b9647
commit 68db708
Showing 1 changed file with 5 additions and 2 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
 }