summaryrefslogtreecommitdiff
path: root/lib/btrfsprogs/btrfsinspect/rebuildnodes/btrees
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/btrees
parenta8cb37f8c7123169c7d2477744aa2523e7cd1d1a (diff)
rebuildnodes: Handle the same node being added twice
Diffstat (limited to 'lib/btrfsprogs/btrfsinspect/rebuildnodes/btrees')
-rw-r--r--lib/btrfsprogs/btrfsinspect/rebuildnodes/btrees/rebuilt_btrees.go16
1 files changed, 12 insertions, 4 deletions
diff --git a/lib/btrfsprogs/btrfsinspect/rebuildnodes/btrees/rebuilt_btrees.go b/lib/btrfsprogs/btrfsinspect/rebuildnodes/btrees/rebuilt_btrees.go
index cbe7df1..a4ccd5e 100644
--- a/lib/btrfsprogs/btrfsinspect/rebuildnodes/btrees/rebuilt_btrees.go
+++ b/lib/btrfsprogs/btrfsinspect/rebuildnodes/btrees/rebuilt_btrees.go
@@ -34,6 +34,7 @@ type rebuiltTree struct {
// mutable
Roots containers.Set[btrfsvol.LogicalAddr]
+ Leafs containers.Set[btrfsvol.LogicalAddr]
Items containers.SortedMap[btrfsprim.Key, keyio.ItemPtr]
}
@@ -175,10 +176,10 @@ func (ts *RebuiltTrees) AddRoot(ctx context.Context, treeID btrfsprim.ObjID, roo
}
for i, leaf := range maps.SortedKeys(tree.leafToRoots) {
progress(i)
- roots := tree.leafToRoots[leaf]
- if !roots.Has(rootNode) {
+ if tree.Leafs.Has(leaf) || !tree.leafToRoots[leaf].Has(rootNode) {
continue
}
+ tree.Leafs.Insert(leaf)
for j, item := range ts.keyIO.ReadNode(leaf).Data.BodyLeaf {
newPtr := keyio.ItemPtr{
Node: leaf,
@@ -234,6 +235,7 @@ func (ts *RebuiltTrees) addTree(ctx context.Context, treeID btrfsprim.ObjID, sta
tree := &rebuiltTree{
ID: treeID,
Roots: make(containers.Set[btrfsvol.LogicalAddr]),
+ Leafs: make(containers.Set[btrfsvol.LogicalAddr]),
}
var root btrfsvol.LogicalAddr
switch treeID {
@@ -404,11 +406,17 @@ func (ts *RebuiltTrees) LeafToRoots(ctx context.Context, treeID btrfsprim.ObjID,
if !ts.AddTree(ctx, treeID) {
return nil
}
+ if ts.graph.Nodes[leaf].Level != 0 {
+ panic(fmt.Errorf("should not happen: NodeToRoots(tree=%v, leaf=%v): not a leaf",
+ treeID, leaf))
+ }
ret := make(containers.Set[btrfsvol.LogicalAddr])
for root := range ts.trees[treeID].leafToRoots[leaf] {
- if !ts.trees[treeID].Roots.Has(root) {
- ret.Insert(root)
+ if ts.trees[treeID].Roots.Has(root) {
+ panic(fmt.Errorf("should not happen: NodeToRoots(tree=%v, leaf=%v): tree contains root=%v but not leaf",
+ treeID, leaf, root))
}
+ ret.Insert(root)
}
if len(ret) == 0 {
return nil