fix missing lock

tidwall · May 21, 2023 · 0144ca6 · 0144ca6
1 parent add9873
commit 0144ca6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/server/follow.go b/internal/server/follow.go
@@ -302,6 +302,7 @@ func (s *Server) followStep(host string, port int, followc int) error {
 		if !caughtUp {
 			if aofsz >= int(aofSize) {
 				caughtUp = true
+				s.mu.Lock()
 				s.flushAOF(false)
 				s.fcup = true
 				s.fcuponce = true