akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

contractcourt/briefcase: avoid bucket modification in ForEach loop

Browse Source 
Since the contents were deleted before the bucket was deleted, we just
delete the bucket immediately.
This commit is contained in:
Johan T. Halseth 2019-06-12 14:21:30 +02:00
parent b7a37728c0
commit ed8d635cf1
No known key found for this signature in database
GPG Key ID: 15BAADA29DA20D26
1 changed files with 7 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
contractcourt/briefcase.go
View File

@ -853,20 +853,9 @@ func (b *boltArbitratorLog) WipeHistory() error {
} }
// Next, we'll delete any lingering contract state within the // Next, we'll delete any lingering contract state within the
// contracts bucket, and the bucket itself once we're done // contracts bucket by removing the bucket itself.
// clearing it out. err = scopeBucket.DeleteBucket(contractsBucketKey)
contractBucket, err := scopeBucket.CreateBucketIfNotExists( if err != nil && err != bbolt.ErrBucketNotFound {
contractsBucketKey,
)
if err != nil {
return err
}
if err := contractBucket.ForEach(func(resKey, _ []byte) error {
return contractBucket.Delete(resKey)
}); err != nil {
return err
}
if err := scopeBucket.DeleteBucket(contractsBucketKey); err != nil {
return err return err
} }
@ -876,20 +865,10 @@ func (b *boltArbitratorLog) WipeHistory() error {
return err return err
} }
// Before we delta the enclosing bucket itself, we'll delta any // We'll delete any chain actions that are still stored by
// chain actions that are still stored. // removing the enclosing bucket.
actionsBucket, err := scopeBucket.CreateBucketIfNotExists( err = scopeBucket.DeleteBucket(actionsBucketKey)
actionsBucketKey, if err != nil && err != bbolt.ErrBucketNotFound {
)
if err != nil {
return err
}
if err := actionsBucket.ForEach(func(resKey, _ []byte) error {
return actionsBucket.Delete(resKey)
}); err != nil {
return err
}
if err := scopeBucket.DeleteBucket(actionsBucketKey); err != nil {
return err return err
} }