Merge pull request #200 from hjrbill/bugfix_20241025_lock_append

fix: Fixed the issue of traversal without locking during log append.
eraft-io · Nov 9, 2024 · 56cf6c2 · 56cf6c2
2 parents 3183ea2 + edbc59c
commit 56cf6c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/raftcore/persistent_log.go b/raftcore/persistent_log.go
@@ -233,8 +233,8 @@ func (rfLog *RaftLog) LogItemCount() int {
 //
 // append a new entry to raft logs, put it to storage engine
 func (rfLog *RaftLog) Append(newEnt *pb.Entry) {
-	// rfLog.mu.Lock()
-	// defer rfLog.mu.Unlock()
+	rfLog.mu.Lock()
+	defer rfLog.mu.Unlock()
 	logIdLast, err := rfLog.dbEng.SeekPrefixKeyIdMax(RaftLogPrefix)
 	if err != nil {
 		panic(err)