From 1ccc6dbf30ab7bb300a3f11b70753dd606b99d8a Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Tue, 3 Oct 2023 15:01:34 -0700 Subject: [PATCH] Bumped inflight updates to 16 and move one lock to rlock. Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 92e70501..964476aa 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -7722,8 +7722,8 @@ func (mset *stream) isCurrent() bool { return mset.node.Current() && !mset.catchup } -// Maximum requests for the whole server that can be in flight. -const maxConcurrentSyncRequests = 8 +// Maximum requests for the whole server that can be in flight at the same time. +const maxConcurrentSyncRequests = 16 var ( errCatchupCorruptSnapshot = errors.New("corrupt stream snapshot detected") @@ -7900,11 +7900,11 @@ RETRY: // Grab sync request again on failures. if sreq == nil { - mset.mu.Lock() + mset.mu.RLock() var state StreamState mset.store.FastState(&state) sreq = mset.calculateSyncRequest(&state, snap) - mset.mu.Unlock() + mset.mu.RUnlock() if sreq == nil { return nil }