mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-14 10:10:42 -07:00
@@ -1293,7 +1293,7 @@ func (mb *msgBlock) rebuildStateLocked() (*LostStreamData, []uint64, error) {
|
||||
checksum := hh.Sum(nil)
|
||||
if !bytes.Equal(checksum, data[len(data)-recordHashSize:]) {
|
||||
truncate(index)
|
||||
return gatherLost(lbuf - index), errBadMsg
|
||||
return gatherLost(lbuf - index), tombstones, errBadMsg
|
||||
}
|
||||
copy(mb.lchk[0:], checksum)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user