From cf5322088dfd06a2fd86223ff99cbc539dfb75e9 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Thu, 28 Oct 2021 12:36:01 -0700 Subject: [PATCH] Race around accessing storage type Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index aa1f589f..6872ff47 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -4867,7 +4867,10 @@ func (mset *stream) processCatchupMsg(msg []byte) (uint64, error) { return 0, errors.New("bad catchup msg") } + mset.mu.RLock() st := mset.cfg.Storage + mset.mu.RUnlock() + if mset.js.limitsExceeded(st) || mset.jsa.limitsExceeded(st) { return 0, NewJSInsufficientResourcesError() }