Needed to undo since we already recorded

Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-11-18 14:09:52 -08:00
parent 49c5c873ca
commit 63c4c23cae

View File

@@ -1596,6 +1596,8 @@ func (mb *msgBlock) skipMsg(seq uint64, now time.Time) {
mb.dmap = make(map[uint64]struct{})
}
mb.dmap[seq] = struct{}{}
mb.msgs--
mb.bytes -= emptyRecordLen
}
mb.mu.Unlock()