refactor Etcdserver.snapshot to extract compaction into a separate method

ahrtr · ahrtr · commit efae0d29f7ff · 2024-09-27T10:48:50.000+01:00
Signed-off-by: Benjamin Wang &lt;benjamin.ahrtr@gmail.com&gt;
diff --git a/server/etcdserver/server.go b/server/etcdserver/server.go
@@ -1207,6 +1207,7 @@ func (s *EtcdServer) triggerSnapshot(ep *etcdProgress) {
 	s.forceSnapshot = false
 
 	s.snapshot(ep.appliedi, ep.confState)
+	s.compactRaftLog(ep.appliedi)
 	ep.snapi = ep.appliedi
 }
 
@@ -2171,6 +2172,11 @@ func (s *EtcdServer) snapshot(snapi uint64, confState raftpb.ConfState) {
 		zap.Uint64("snapshot-index", snap.Metadata.Index),
 	)
 
+}
+
+func (s *EtcdServer) compactRaftLog(snapi uint64) {
+	lg := s.Logger()
+
 	// When sending a snapshot, etcd will pause compaction.
 	// After receives a snapshot, the slow follower needs to get all the entries right after
 	// the snapshot sent to catch up. If we do not pause compaction, the log entries right after
@@ -2187,7 +2193,7 @@ func (s *EtcdServer) snapshot(snapi uint64, confState raftpb.ConfState) {
 		compacti = snapi - s.Cfg.SnapshotCatchUpEntries
 	}
 
-	err = s.r.raftStorage.Compact(compacti)
+	err := s.r.raftStorage.Compact(compacti)
 	if err != nil {
 		// the compaction was done asynchronously with the progress of raft.
 		// raft log might already been compact.
