.

wcfs/internal/xbtree/δbtail.go

@@ -305,21 +305,26 @@ func (δBtail *ΔBtail) rebuildAll() (err error) {
 	defer xerr.Context(&err, "ΔBtail rebuildAll")
 	// XXX locking
 
-	trackNewRoots := δBtail.trackNewRoots
+	tracefΔBtail("\nRebuildAll @%s..@%s    trackNewRoots: %s\n", δBtail.Tail(), δBtail.Head(), δBtail.trackNewRoots)
 
-	tracefΔBtail("\nRebuildAll @%s..@%s    trackNewRoots: %s\n", δBtail.Tail(), δBtail.Head(), trackNewRoots)
-
-	for root := range trackNewRoots {
-		δTtail := δBtail.vδTbyRoot[root] // must be there
-		δtrackSet, δrevSet, err := δTtail.rebuild(root, δBtail.δZtail, δBtail.db)
-		if err != nil {
-			return err
-		}
-		δBtail.trackSet.UnionInplace(δtrackSet)
-		δBtail.vδBroots_Update(root, δrevSet)
+	for root := range δBtail.trackNewRoots {
+		δBtail.rebuild1(root)
 	}
 
-	δBtail.trackNewRoots = setOid{}
+	return nil
+}
+
+// rebuild1 rebuilds ΔBtail for single root.
+func (δBtail *ΔBtail) rebuild1(root zodb.Oid) error {
+	// XXX locking
+	delete(δBtail.trackNewRoots, root)
+	δTtail := δBtail.vδTbyRoot[root] // must be there
+	δtrackSet, δrevSet, err := δTtail.rebuild(root, δBtail.δZtail, δBtail.db)
+	if err != nil {
+		return err
+	}
+	δBtail.trackSet.UnionInplace(δtrackSet)
+	δBtail.vδBroots_Update(root, δrevSet)
 	return nil
 }