Stop matching in filteredPendingLocked FSS scan when partial found

Signed-off-by: Neil Twigg <[email protected]>
nats-io · Jul 5, 2024 · 07a5f35 · 07a5f35
1 parent cc7f492
commit 07a5f35
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/filestore.go b/server/filestore.go
@@ -2499,6 +2499,10 @@ func (mb *msgBlock) filteredPendingLocked(filter string, wc bool, sseq uint64) (
 
 	var havePartial bool
 	mb.fss.Match(stringToBytes(filter), func(bsubj []byte, ss *SimpleState) {
+		if havePartial {
+			// If we already found a partial then don't do anything else.
+			return
+		}
 		if ss.firstNeedsUpdate {
 			mb.recalculateFirstForSubj(bytesToString(bsubj), ss.First, ss)
 		}