From 3f80348a1625f825bbb65729a01b6b384160b965 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Tue, 12 Sep 2023 07:43:14 -0700 Subject: [PATCH] Fix for data race in accessing rg.node Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 149b585d..90485042 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -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)