gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Fix for datarace accessing mirror tr

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-09-11 21:12:15 -07:00
parent e378f04fc0
commit 349158a349
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
server/stream.go
View File

@@ -2273,9 +2273,6 @@ func (mset *stream) processInboundMirrorMsg(m *inMsg) bool {
}
}
js, stype := mset.js, mset.cfg.Storage
mset.mu.Unlock()
// Do the subject transform if there's one
if mset.mirror.tr != nil {
m.subj = mset.mirror.tr.TransformSubject(m.subj)
@@ -2293,7 +2290,9 @@ func (mset *stream) processInboundMirrorMsg(m *inMsg) bool {
}
}
s := mset.srv
s, js, stype := mset.srv, mset.js, mset.cfg.Storage
mset.mu.Unlock()
var err error
if node != nil {
if js.limitsExceeded(stype) {