Fix data rase on mset.cfg

Signed-off-by: Evan Anderson <evan@stacklok.com>
nats-io · Feb 5, 2025 · 0df8678 · 0df8678
1 parent ffb04c2
commit 0df8678
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/server/jetstream.go b/server/jetstream.go
@@ -1501,12 +1501,14 @@ func (a *Account) filteredStreams(filter string) []*stream {
 	var msets []*stream
 	for _, mset := range jsa.streams {
 		if filter != _EMPTY_ {
+			mset.cfgMu.RLock()
 			for _, subj := range mset.cfg.Subjects {
 				if SubjectsCollide(filter, subj) {
 					msets = append(msets, mset)
 					break
 				}
 			}
+			mset.cfgMu.RUnlock()
 		} else {
 			msets = append(msets, mset)
 		}