Bumped inflight updates to 16 and move one lock to rlock.

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-10-03 15:01:34 -07:00
parent 195227edfd
commit 1ccc6dbf30

View File

@@ -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
}