mset.noInterest(..) mentions it requires a write lock to be held:
// Check if there is no interest in this sequence number across our consumers.
// The consumer passed is optional if we are processing the ack for that consumer.
// Write lock should be held.
func (mset *stream) noInterest(seq uint64, obs *consumer) bool {
return !mset.checkForInterest(seq, obs)
}
mset.noInterest(..)
mentions it requires a write lock to be held:This wasn't done in
cleanupNoInterestMessages
.Signed-off-by: Maurice van Veen github@mauricevanveen.com