Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[FIXED]
mset.noInterest
requires write lock (#6122)
`mset.noInterest(..)` mentions it requires a write lock to be held: ```go // 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) } ``` This wasn't done in `cleanupNoInterestMessages`. Signed-off-by: Maurice van Veen <[email protected]>
- Loading branch information