Fix for data race in memstore.LoadNextMsg

Signed-off-by: Waldemar Quevedo <wally@synadia.com>
nats-io · Sep 17, 2023 · 14f0dc3 · 14f0dc3
1 parent 6f38056
commit 14f0dc3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/memstore.go b/server/memstore.go
@@ -952,7 +952,11 @@ func (ms *memStore) LoadNextMsg(filter string, wc bool, start uint64, smp *Store
 				continue
 			}
 			if ss.firstNeedsUpdate {
+				ms.mu.RUnlock()
+				ms.mu.Lock()
 				ms.recalculateFirstForSubj(subj, ss.First, ss)
+				ms.mu.Unlock()
+				ms.mu.RLock()
 			}
 			if ss.First < fseq {
 				fseq = ss.First