Merge pull request #686 from steveyen/scorch
scorch removeOldBoltSnapshots() deletes from correct bucket
This commit is contained in:
commit
59797c35fa
|
@ -448,22 +448,25 @@ func (s *Scorch) removeOldBoltSnapshots() (numRemoved int, err error) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return 0, err
|
return 0, err
|
||||||
}
|
}
|
||||||
defer func() {
|
|
||||||
if err == nil {
|
|
||||||
err = s.rootBolt.Sync()
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
defer func() {
|
defer func() {
|
||||||
if err == nil {
|
if err == nil {
|
||||||
err = tx.Commit()
|
err = tx.Commit()
|
||||||
} else {
|
} else {
|
||||||
_ = tx.Rollback()
|
_ = tx.Rollback()
|
||||||
}
|
}
|
||||||
|
if err == nil {
|
||||||
|
err = s.rootBolt.Sync()
|
||||||
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
snapshots := tx.Bucket(boltSnapshotsBucket)
|
||||||
|
if snapshots == nil {
|
||||||
|
return 0, nil
|
||||||
|
}
|
||||||
|
|
||||||
for _, epochToRemove := range epochsToRemove {
|
for _, epochToRemove := range epochsToRemove {
|
||||||
k := segment.EncodeUvarintAscending(nil, epochToRemove)
|
k := segment.EncodeUvarintAscending(nil, epochToRemove)
|
||||||
err = tx.DeleteBucket(k)
|
err = snapshots.DeleteBucket(k)
|
||||||
if err == bolt.ErrBucketNotFound {
|
if err == bolt.ErrBucketNotFound {
|
||||||
err = nil
|
err = nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user