Add jitter for flushing stream state

Signed-off-by: Maurice van Veen <[email protected]>
nats-io · Dec 5, 2024 · 716b139 · 716b139
1 parent 5e757eb
commit 716b139
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/filestore.go b/server/filestore.go
@@ -8157,8 +8157,10 @@ func (fs *fileStore) flushStreamStateLoop(qch, done chan struct{}) {
 	defer close(done)
 
 	// Make sure we do not try to write these out too fast.
+	// Spread these out for large numbers on a server restart.
 	const writeThreshold = 2 * time.Minute
-	t := time.NewTicker(writeThreshold)
+	writeJitter := time.Duration(mrand.Int63n(int64(30 * time.Second)))
+	t := time.NewTicker(writeThreshold + writeJitter)
 	defer t.Stop()
 
 	for {