From 490acf5f29e59f0cf57d3b78f64ceda0a376c971 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Mon, 20 Dec 2021 17:37:07 -0800 Subject: [PATCH] Full stream state with interior delete details not needed by recipient of snapshot Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index b97cb6ab..5d3c6fc9 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -4868,8 +4868,9 @@ func (mset *stream) processSnapshot(snap *streamSnapshot) error { mset.processSnapshotDeletes(snap) mset.mu.Lock() + var state StreamState mset.clfs = snap.Failed - state := mset.store.State() + mset.store.FastState(&state) sreq := mset.calculateSyncRequest(&state, snap) s, js, subject, n := mset.srv, mset.js, mset.sa.Sync, mset.node mset.mu.Unlock() @@ -4931,7 +4932,8 @@ RETRY: // Grab sync request again on failures. if sreq == nil { mset.mu.Lock() - state := mset.store.State() + var state StreamState + mset.store.FastState(&state) sreq = mset.calculateSyncRequest(&state, snap) mset.mu.Unlock() if sreq == nil {