From c49d081341c8e76f2b7708153dc26767ca8dafa3 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Thu, 7 Jul 2022 09:05:50 -0700 Subject: [PATCH] Fix data race Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index f8c01b35..9315c37a 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -703,7 +703,10 @@ func (s *Server) JetStreamIsStreamAssigned(account, stream string) bool { if acc == nil { return false } - return cc.isStreamAssigned(acc, stream) + js.mu.RLock() + assigned := cc.isStreamAssigned(acc, stream) + js.mu.RUnlock() + return assigned } // streamAssigned informs us if this server has this stream assigned.