summaryrefslogtreecommitdiff
path: root/lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go
diff options
context:
space:
mode:
authorLuke Shumaker <lukeshu@lukeshu.com>2022-12-22 18:24:03 -0700
committerLuke Shumaker <lukeshu@lukeshu.com>2022-12-23 17:51:14 -0700
commit3e22a30a7febd9890163966d01dd2b34656c9e39 (patch)
tree3cb0ae9be13fb078b54832ade42b8ce37aecc248 /lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go
parenta8cb37f8c7123169c7d2477744aa2523e7cd1d1a (diff)
rebuildnodes: Handle the same node being added twice
Diffstat (limited to 'lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go')
-rw-r--r--lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go16
1 files changed, 9 insertions, 7 deletions
diff --git a/lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go b/lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go
index e05399e..4e60632 100644
--- a/lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go
+++ b/lib/btrfsprogs/btrfsinspect/rebuildnodes/rebuild.go
@@ -352,16 +352,18 @@ func (o *rebuilder) resolveTreeAugments(ctx context.Context, listsWithDistances
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
func (o *rebuilder) wantAugment(ctx context.Context, treeID btrfsprim.ObjID, choices containers.Set[btrfsvol.LogicalAddr]) {
- choicesWithDist := make(map[btrfsvol.LogicalAddr]int)
- for choice := range choices {
- if dist, ok := o.rebuilt.COWDistance(ctx, treeID, o.graph.Nodes[choice].Owner); ok {
- choicesWithDist[choice] = dist
- }
- }
- if len(choicesWithDist) == 0 {
+ if len(choices) == 0 {
dlog.Errorf(ctx, "augment(tree=%v): could not find wanted item", treeID)
return
}
+ choicesWithDist := make(map[btrfsvol.LogicalAddr]int, len(choices))
+ for choice := range choices {
+ dist, ok := o.rebuilt.COWDistance(ctx, treeID, o.graph.Nodes[choice].Owner)
+ if !ok {
+ panic(fmt.Errorf("should not happen: .wantAugment called for tree=%v with invalid choice=%v", treeID, choice))
+ }
+ choicesWithDist[choice] = dist
+ }
dlog.Infof(ctx, "augment(tree=%v): %v", treeID, maps.SortedKeys(choicesWithDist))
o.pendingAugments[treeID] = append(o.pendingAugments[treeID], choicesWithDist)
}