Skip to content

Commit 1606e03

Browse files
committed
Fix data rase on mset.cfg
Signed-off-by: Evan Anderson <[email protected]>
1 parent 67aa107 commit 1606e03

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

server/jetstream.go

+2
Original file line numberDiff line numberDiff line change
@@ -1556,12 +1556,14 @@ func (a *Account) filteredStreams(filter string) []*stream {
15561556
var msets []*stream
15571557
for _, mset := range jsa.streams {
15581558
if filter != _EMPTY_ {
1559+
mset.cfgMu.RLock()
15591560
for _, subj := range mset.cfg.Subjects {
15601561
if SubjectsCollide(filter, subj) {
15611562
msets = append(msets, mset)
15621563
break
15631564
}
15641565
}
1566+
mset.cfgMu.RUnlock()
15651567
} else {
15661568
msets = append(msets, mset)
15671569
}

0 commit comments

Comments
 (0)