From e1a00a883c46d71854988c9a178ef39e59f0856f Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Tue, 18 Jul 2023 11:29:59 -0700 Subject: [PATCH] Fix bug that would race around check for last sequence per subject Signed-off-by: Derek Collison --- server/stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/stream.go b/server/stream.go index 8e1dcd5a..492f3be5 100644 --- a/server/stream.go +++ b/server/stream.go @@ -3861,7 +3861,7 @@ func (mset *stream) processJetStreamMsg(subject, reply string, hdr, msg []byte, } // Expected last sequence per subject. // If we are clustered we have prechecked seq > 0. - if seq, exists := getExpectedLastSeqPerSubject(hdr); exists && (!isClustered || seq == 0) { + if seq, exists := getExpectedLastSeqPerSubject(hdr); exists { // TODO(dlc) - We could make a new store func that does this all in one. var smv StoreMsg var fseq uint64