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

Merge pull request #1925 from cfromknecht/migration-efficiency

Browse Source 
channeldb/migrations: improve performance of edge update migration
This commit is contained in:
Olaoluwa Osuntokun 2018-09-17 15:41:14 -07:00 committed by GitHub
commit 032234c4c8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 24 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
channeldb/migrations.go
View File

@ -514,19 +514,34 @@ func migratePruneEdgeUpdateIndex(tx *bolt.Tx) error {
err)
}
// With the existing edge policies gathered, we'll recreate the index
// and populate it with the correct entries.
//
// NOTE: In bolt DB, calling Delete() on an iterator will actually move
// it to the NEXT item. As a result, we call First() here again to go
// back to the front after the item has been deleted.
updateCursor := edgeUpdateIndex.Cursor()
for k, _ := updateCursor.First(); k != nil; k, _ = updateCursor.First() {
if err := updateCursor.Delete(); err != nil {
log.Info("Constructing set of edge update entries to purge.")
// Build the set of keys that we will remove from the edge update index.
// This will include all keys contained within the bucket.
var updateKeysToRemove [][]byte
err = edgeUpdateIndex.ForEach(func(updKey, _ []byte) error {
updateKeysToRemove = append(updateKeysToRemove, updKey)
return nil
})
if err != nil {
return fmt.Errorf("unable to gather existing edge updates: %v",
err)
}
log.Infof("Removing %d entries from edge update index.",
len(updateKeysToRemove))
// With the set of keys contained in the edge update index constructed,
// we'll proceed in purging all of them from the index.
for _, updKey := range updateKeysToRemove {
if err := edgeUpdateIndex.Delete(updKey); err != nil {
return err
}
}
log.Infof("Repopulating edge update index with %d valid entries.",
len(edgeKeys))
// For each edge key, we'll retrieve the policy, deserialize it, and
// re-add it to the different buckets. By doing so, we'll ensure that
// all existing edge policies are serialized correctly within their