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 data race in accessing rg.node

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-09-12 07:43:14 -07:00
parent 8e2c30a75b
commit 3f80348a16
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
server/jetstream_cluster.go
View File

@@ -3642,8 +3642,13 @@ func (js *jetStream) processClusterCreateStream(acc *Account, sa *streamAssignme
return
}
// Re-capture node.
js.mu.RLock()
node := rg.node
js.mu.RUnlock()
// Start our monitoring routine.
if rg.node != nil {
if node != nil {
if !alreadyRunning {
if mset != nil {
mset.monitorWg.Add(1)