提交 32c32013 编写于 作者: F Fabian Reinartz

Fix loading of persisted blocks

上级 5876a330
......@@ -369,10 +369,7 @@ func (db *DB) reloadBlocks() error {
}
heads = append(heads, b.(*headBlock))
} else {
if ok && meta.ULID != b.Meta().ULID {
if err := b.Close(); err != nil {
return err
}
if !ok || meta.ULID != b.Meta().ULID {
b, err = newPersistedBlock(dirs[i])
if err != nil {
return errors.Wrapf(err, "open persisted block %s", dirs[i])
......@@ -385,7 +382,7 @@ func (db *DB) reloadBlocks() error {
}
for seq, b := range db.seqBlocks {
if _, ok := seqBlocks[seq]; !ok {
if nb, ok := seqBlocks[seq]; !ok || nb != b {
if err := b.Close(); err != nil {
return errors.Wrapf(err, "closing removed block %d", b.Meta().Sequence)
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册