From 0144ca6883f37e64d35480a121e8a81e30c48c75 Mon Sep 17 00:00:00 2001 From: tidwall Date: Sun, 21 May 2023 08:29:30 -0700 Subject: [PATCH] fix missing lock --- internal/server/follow.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/server/follow.go b/internal/server/follow.go index a70c2204..e61759f9 100644 --- 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