Restore comments

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>

server/consumer.go

@@ -3053,6 +3053,7 @@ func (o *consumer) isFilteredMatch(subj string) bool {
 	}
 	// It's quicker to first check for non-wildcard filters, then
 	// iterate again to check for subset match.
+	// TODO(dlc) at speed might be better to just do a sublist with L2 and/or possibly L1.
 	for _, filter := range o.subjf {
 		if subjectIsSubsetMatch(subj, filter.subject) {
 			return true
@@ -4159,6 +4160,7 @@ func (o *consumer) selectStartingSeqNo() {
 					o.sseq = state.LastSeq
 					return
 				}
+				// If we are partitioned here this will be properly set when we become leader.
 				for _, filter := range o.subjf {
 					ss := o.mset.store.FilteredState(1, filter.subject)
 					filter.nextSeq = ss.Last

server/jetstream_test.go

@@ -19070,10 +19070,9 @@ func TestJetStreamConsumerMultipleSubjects(t *testing.T) {
 	})
 	require_NoError(t, err)
 
-	for i := 0; i < 20; i++ {
+	for i := 0; i < 20; i += 2 {
 		sendStreamMsg(t, nc, "events.created", fmt.Sprintf("created %v", i))
 		sendStreamMsg(t, nc, "data.processed", fmt.Sprintf("processed %v", i+1))
-		i++
 	}
 
 	_, err = mset.addConsumer(&ConsumerConfig{