Add postorder traversal to specs
- Spec.preorder_traversal() is now Spec.traverse(). - Caller can supply order='pre' or order='post'
This commit is contained in:
parent
d5c625d87d
commit
63f8af8078
3 changed files with 138 additions and 62 deletions
|
@ -118,7 +118,7 @@ def concretize_compiler(self, spec):
|
||||||
return
|
return
|
||||||
|
|
||||||
try:
|
try:
|
||||||
nearest = next(p for p in spec.preorder_traversal(direction='parents')
|
nearest = next(p for p in spec.traverse(direction='parents')
|
||||||
if p.compiler is not None).compiler
|
if p.compiler is not None).compiler
|
||||||
|
|
||||||
if not nearest in all_compilers:
|
if not nearest in all_compilers:
|
||||||
|
|
|
@ -451,10 +451,19 @@ def concrete(self):
|
||||||
return self._concrete
|
return self._concrete
|
||||||
|
|
||||||
|
|
||||||
def preorder_traversal(self, visited=None, d=0, **kwargs):
|
def traverse(self, visited=None, d=0, **kwargs):
|
||||||
"""Generic preorder traversal of the DAG represented by this spec.
|
"""Generic traversal of the DAG represented by this spec.
|
||||||
This will yield each node in the spec. Options:
|
This will yield each node in the spec. Options:
|
||||||
|
|
||||||
|
order [=pre|post]
|
||||||
|
Order to traverse spec nodes. Defaults to preorder traversal.
|
||||||
|
Options are:
|
||||||
|
|
||||||
|
'pre': Pre-order traversal; each node is yielded before its
|
||||||
|
children in the dependency DAG.
|
||||||
|
'post': Post-order traversal; each node is yielded after its
|
||||||
|
children in the dependency DAG.
|
||||||
|
|
||||||
cover [=nodes|edges|paths]
|
cover [=nodes|edges|paths]
|
||||||
Determines how extensively to cover the dag. Possible vlaues:
|
Determines how extensively to cover the dag. Possible vlaues:
|
||||||
|
|
||||||
|
@ -472,7 +481,7 @@ def preorder_traversal(self, visited=None, d=0, **kwargs):
|
||||||
spec, but also their depth from the root in a (depth, node)
|
spec, but also their depth from the root in a (depth, node)
|
||||||
tuple.
|
tuple.
|
||||||
|
|
||||||
keyfun [=id]
|
key [=id]
|
||||||
Allow a custom key function to track the identity of nodes
|
Allow a custom key function to track the identity of nodes
|
||||||
in the traversal.
|
in the traversal.
|
||||||
|
|
||||||
|
@ -484,6 +493,7 @@ def preorder_traversal(self, visited=None, d=0, **kwargs):
|
||||||
'parents', traverses upwards in the DAG towards the root.
|
'parents', traverses upwards in the DAG towards the root.
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
# get initial values for kwargs
|
||||||
depth = kwargs.get('depth', False)
|
depth = kwargs.get('depth', False)
|
||||||
key_fun = kwargs.get('key', id)
|
key_fun = kwargs.get('key', id)
|
||||||
if isinstance(key_fun, basestring):
|
if isinstance(key_fun, basestring):
|
||||||
|
@ -491,30 +501,36 @@ def preorder_traversal(self, visited=None, d=0, **kwargs):
|
||||||
yield_root = kwargs.get('root', True)
|
yield_root = kwargs.get('root', True)
|
||||||
cover = kwargs.get('cover', 'nodes')
|
cover = kwargs.get('cover', 'nodes')
|
||||||
direction = kwargs.get('direction', 'children')
|
direction = kwargs.get('direction', 'children')
|
||||||
|
order = kwargs.get('order', 'pre')
|
||||||
|
|
||||||
cover_values = ('nodes', 'edges', 'paths')
|
# Make sure kwargs have legal values; raise ValueError if not.
|
||||||
if cover not in cover_values:
|
def validate(name, val, allowed_values):
|
||||||
raise ValueError("Invalid value for cover: %s. Choices are %s"
|
if val not in allowed_values:
|
||||||
% (cover, ",".join(cover_values)))
|
raise ValueError("Invalid value for %s: %s. Choices are %s"
|
||||||
|
% (name, val, ",".join(allowed_values)))
|
||||||
direction_values = ('children', 'parents')
|
validate('cover', cover, ('nodes', 'edges', 'paths'))
|
||||||
if direction not in direction_values:
|
validate('direction', direction, ('children', 'parents'))
|
||||||
raise ValueError("Invalid value for direction: %s. Choices are %s"
|
validate('order', order, ('pre', 'post'))
|
||||||
% (direction, ",".join(direction_values)))
|
|
||||||
|
|
||||||
if visited is None:
|
if visited is None:
|
||||||
visited = set()
|
visited = set()
|
||||||
|
|
||||||
result = (d, self) if depth else self
|
|
||||||
key = key_fun(self)
|
key = key_fun(self)
|
||||||
|
|
||||||
if key in visited:
|
# Node traversal does not yield visited nodes.
|
||||||
if cover == 'nodes': return
|
if key in visited and cover == 'nodes':
|
||||||
if yield_root or d > 0: yield result
|
return
|
||||||
if cover == 'edges': return
|
|
||||||
else:
|
|
||||||
if yield_root or d > 0: yield result
|
|
||||||
|
|
||||||
|
# Determine whether and what to yield for this node.
|
||||||
|
yield_me = yield_root or d > 0
|
||||||
|
result = (d, self) if depth else self
|
||||||
|
|
||||||
|
# Preorder traversal yields before successors
|
||||||
|
if yield_me and order == 'pre':
|
||||||
|
yield result
|
||||||
|
|
||||||
|
# Edge traversal yields but skips children of visited nodes
|
||||||
|
if not (key in visited and cover == 'edges'):
|
||||||
|
# This code determines direction and yields the children/parents
|
||||||
successors = self.dependencies
|
successors = self.dependencies
|
||||||
if direction == 'parents':
|
if direction == 'parents':
|
||||||
successors = self.dependents
|
successors = self.dependents
|
||||||
|
@ -522,9 +538,13 @@ def preorder_traversal(self, visited=None, d=0, **kwargs):
|
||||||
visited.add(key)
|
visited.add(key)
|
||||||
for name in sorted(successors):
|
for name in sorted(successors):
|
||||||
child = successors[name]
|
child = successors[name]
|
||||||
for elt in child.preorder_traversal(visited, d+1, **kwargs):
|
for elt in child.traverse(visited, d+1, **kwargs):
|
||||||
yield elt
|
yield elt
|
||||||
|
|
||||||
|
# Postorder traversal yields after successors
|
||||||
|
if yield_me and order == 'post':
|
||||||
|
yield result
|
||||||
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def short_spec(self):
|
def short_spec(self):
|
||||||
|
@ -610,7 +630,7 @@ def _expand_virtual_packages(self):
|
||||||
a problem.
|
a problem.
|
||||||
"""
|
"""
|
||||||
while True:
|
while True:
|
||||||
virtuals =[v for v in self.preorder_traversal() if v.virtual]
|
virtuals =[v for v in self.traverse() if v.virtual]
|
||||||
if not virtuals:
|
if not virtuals:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
@ -668,7 +688,7 @@ def flat_dependencies(self):
|
||||||
# to the spec -- so they're the user's fault, not Spack's.
|
# to the spec -- so they're the user's fault, not Spack's.
|
||||||
flat_deps = DependencyMap()
|
flat_deps = DependencyMap()
|
||||||
try:
|
try:
|
||||||
for spec in self.preorder_traversal(root=False):
|
for spec in self.traverse(root=False):
|
||||||
if spec.name not in flat_deps:
|
if spec.name not in flat_deps:
|
||||||
new_spec = spec.copy(deps=False)
|
new_spec = spec.copy(deps=False)
|
||||||
flat_deps[spec.name] = new_spec
|
flat_deps[spec.name] = new_spec
|
||||||
|
@ -842,7 +862,7 @@ def validate_names(self):
|
||||||
If they're not, it will raise either UnknownPackageError or
|
If they're not, it will raise either UnknownPackageError or
|
||||||
UnsupportedCompilerError.
|
UnsupportedCompilerError.
|
||||||
"""
|
"""
|
||||||
for spec in self.preorder_traversal():
|
for spec in self.traverse():
|
||||||
# Don't get a package for a virtual name.
|
# Don't get a package for a virtual name.
|
||||||
if not spec.virtual:
|
if not spec.virtual:
|
||||||
spack.db.get(spec.name)
|
spack.db.get(spec.name)
|
||||||
|
@ -910,17 +930,17 @@ def _constrain_dependencies(self, other):
|
||||||
def common_dependencies(self, other):
|
def common_dependencies(self, other):
|
||||||
"""Return names of dependencies that self an other have in common."""
|
"""Return names of dependencies that self an other have in common."""
|
||||||
common = set(
|
common = set(
|
||||||
s.name for s in self.preorder_traversal(root=False))
|
s.name for s in self.traverse(root=False))
|
||||||
common.intersection_update(
|
common.intersection_update(
|
||||||
s.name for s in other.preorder_traversal(root=False))
|
s.name for s in other.traverse(root=False))
|
||||||
return common
|
return common
|
||||||
|
|
||||||
|
|
||||||
def dep_difference(self, other):
|
def dep_difference(self, other):
|
||||||
"""Returns dependencies in self that are not in other."""
|
"""Returns dependencies in self that are not in other."""
|
||||||
mine = set(s.name for s in self.preorder_traversal(root=False))
|
mine = set(s.name for s in self.traverse(root=False))
|
||||||
mine.difference_update(
|
mine.difference_update(
|
||||||
s.name for s in other.preorder_traversal(root=False))
|
s.name for s in other.traverse(root=False))
|
||||||
return mine
|
return mine
|
||||||
|
|
||||||
|
|
||||||
|
@ -979,8 +999,8 @@ def satisfies_dependencies(self, other):
|
||||||
return False
|
return False
|
||||||
|
|
||||||
# For virtual dependencies, we need to dig a little deeper.
|
# For virtual dependencies, we need to dig a little deeper.
|
||||||
self_index = ProviderIndex(self.preorder_traversal(), restrict=True)
|
self_index = ProviderIndex(self.traverse(), restrict=True)
|
||||||
other_index = ProviderIndex(other.preorder_traversal(), restrict=True)
|
other_index = ProviderIndex(other.traverse(), restrict=True)
|
||||||
|
|
||||||
# This handles cases where there are already providers for both vpkgs
|
# This handles cases where there are already providers for both vpkgs
|
||||||
if not self_index.satisfies(other_index):
|
if not self_index.satisfies(other_index):
|
||||||
|
@ -1002,7 +1022,7 @@ def satisfies_dependencies(self, other):
|
||||||
|
|
||||||
def virtual_dependencies(self):
|
def virtual_dependencies(self):
|
||||||
"""Return list of any virtual deps in this spec."""
|
"""Return list of any virtual deps in this spec."""
|
||||||
return [spec for spec in self.preorder_traversal() if spec.virtual]
|
return [spec for spec in self.traverse() if spec.virtual]
|
||||||
|
|
||||||
|
|
||||||
def _dup(self, other, **kwargs):
|
def _dup(self, other, **kwargs):
|
||||||
|
@ -1056,7 +1076,7 @@ def version(self):
|
||||||
|
|
||||||
def __getitem__(self, name):
|
def __getitem__(self, name):
|
||||||
"""TODO: reconcile __getitem__, _add_dependency, __contains__"""
|
"""TODO: reconcile __getitem__, _add_dependency, __contains__"""
|
||||||
for spec in self.preorder_traversal():
|
for spec in self.traverse():
|
||||||
if spec.name == name:
|
if spec.name == name:
|
||||||
return spec
|
return spec
|
||||||
|
|
||||||
|
@ -1067,7 +1087,7 @@ def __contains__(self, spec):
|
||||||
"""True if this spec has any dependency that satisfies the supplied
|
"""True if this spec has any dependency that satisfies the supplied
|
||||||
spec."""
|
spec."""
|
||||||
spec = self._autospec(spec)
|
spec = self._autospec(spec)
|
||||||
for s in self.preorder_traversal():
|
for s in self.traverse():
|
||||||
if s.satisfies(spec):
|
if s.satisfies(spec):
|
||||||
return True
|
return True
|
||||||
return False
|
return False
|
||||||
|
@ -1080,11 +1100,12 @@ def sorted_deps(self):
|
||||||
|
|
||||||
|
|
||||||
def _eq_dag(self, other, vs, vo):
|
def _eq_dag(self, other, vs, vo):
|
||||||
"""Test that entire dependency DAGs are equal."""
|
"""Recursive helper for eq_dag and ne_dag. Does the actual DAG
|
||||||
|
traversal."""
|
||||||
vs.add(id(self))
|
vs.add(id(self))
|
||||||
vo.add(id(other))
|
vo.add(id(other))
|
||||||
|
|
||||||
if self._cmp_node() != other._cmp_node():
|
if self.ne_node(other):
|
||||||
return False
|
return False
|
||||||
|
|
||||||
if len(self.dependencies) != len(other.dependencies):
|
if len(self.dependencies) != len(other.dependencies):
|
||||||
|
@ -1094,13 +1115,14 @@ def _eq_dag(self, other, vs, vo):
|
||||||
osorted = [other.dependencies[name] for name in sorted(other.dependencies)]
|
osorted = [other.dependencies[name] for name in sorted(other.dependencies)]
|
||||||
|
|
||||||
for s, o in zip(ssorted, osorted):
|
for s, o in zip(ssorted, osorted):
|
||||||
|
visited_s = id(s) in vs
|
||||||
|
visited_o = id(o) in vo
|
||||||
|
|
||||||
# Check for duplicate or non-equal dependencies
|
# Check for duplicate or non-equal dependencies
|
||||||
if (id(s) in vs) != (id(o) in vo):
|
if visited_s != visited_o: return False
|
||||||
return False
|
|
||||||
|
|
||||||
# Skip visited nodes
|
# Skip visited nodes
|
||||||
if id(s) in vs:
|
if visited_s or visited_o: continue
|
||||||
continue
|
|
||||||
|
|
||||||
# Recursive check for equality
|
# Recursive check for equality
|
||||||
if not s._eq_dag(o, vs, vo):
|
if not s._eq_dag(o, vs, vo):
|
||||||
|
@ -1110,13 +1132,12 @@ def _eq_dag(self, other, vs, vo):
|
||||||
|
|
||||||
|
|
||||||
def eq_dag(self, other):
|
def eq_dag(self, other):
|
||||||
"""True if the entire dependency DAG of this spec is equal to another."""
|
"""True if the full dependency DAGs of specs are equal"""
|
||||||
return self._eq_dag(other, set(), set())
|
return self._eq_dag(other, set(), set())
|
||||||
|
|
||||||
|
|
||||||
def ne_dag(self, other):
|
def ne_dag(self, other):
|
||||||
"""True if the entire dependency DAG of this spec is not equal to
|
"""True if the full dependency DAGs of specs are not equal"""
|
||||||
another."""
|
|
||||||
return not self.eq_dag(other)
|
return not self.eq_dag(other)
|
||||||
|
|
||||||
|
|
||||||
|
@ -1126,6 +1147,16 @@ def _cmp_node(self):
|
||||||
self.architecture, self.compiler)
|
self.architecture, self.compiler)
|
||||||
|
|
||||||
|
|
||||||
|
def eq_node(self, other):
|
||||||
|
"""Equality with another spec, not including dependencies."""
|
||||||
|
return self._cmp_node() == other._cmp_node()
|
||||||
|
|
||||||
|
|
||||||
|
def ne_node(self, other):
|
||||||
|
"""Inequality with another spec, not including dependencies."""
|
||||||
|
return self._cmp_node() != other._cmp_node()
|
||||||
|
|
||||||
|
|
||||||
def _cmp_key(self):
|
def _cmp_key(self):
|
||||||
"""Comparison key for this node and all dependencies *without*
|
"""Comparison key for this node and all dependencies *without*
|
||||||
considering structure. This is the default, as
|
considering structure. This is the default, as
|
||||||
|
@ -1255,7 +1286,7 @@ def tree(self, **kwargs):
|
||||||
out = ""
|
out = ""
|
||||||
cur_id = 0
|
cur_id = 0
|
||||||
ids = {}
|
ids = {}
|
||||||
for d, node in self.preorder_traversal(cover=cover, depth=True):
|
for d, node in self.traverse(order='pre', cover=cover, depth=True):
|
||||||
out += " " * indent
|
out += " " * indent
|
||||||
if depth:
|
if depth:
|
||||||
out += "%-4d" % d
|
out += "%-4d" % d
|
||||||
|
|
|
@ -48,7 +48,7 @@ def test_conflicting_package_constraints(self):
|
||||||
spec.package.validate_dependencies)
|
spec.package.validate_dependencies)
|
||||||
|
|
||||||
|
|
||||||
def test_unique_node_traversal(self):
|
def test_preorder_node_traversal(self):
|
||||||
dag = Spec('mpileaks ^zmpi')
|
dag = Spec('mpileaks ^zmpi')
|
||||||
dag.normalize()
|
dag.normalize()
|
||||||
|
|
||||||
|
@ -56,14 +56,14 @@ def test_unique_node_traversal(self):
|
||||||
'zmpi', 'fake']
|
'zmpi', 'fake']
|
||||||
pairs = zip([0,1,2,3,4,2,3], names)
|
pairs = zip([0,1,2,3,4,2,3], names)
|
||||||
|
|
||||||
traversal = dag.preorder_traversal()
|
traversal = dag.traverse()
|
||||||
self.assertListEqual([x.name for x in traversal], names)
|
self.assertListEqual([x.name for x in traversal], names)
|
||||||
|
|
||||||
traversal = dag.preorder_traversal(depth=True)
|
traversal = dag.traverse(depth=True)
|
||||||
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
||||||
|
|
||||||
|
|
||||||
def test_unique_edge_traversal(self):
|
def test_preorder_edge_traversal(self):
|
||||||
dag = Spec('mpileaks ^zmpi')
|
dag = Spec('mpileaks ^zmpi')
|
||||||
dag.normalize()
|
dag.normalize()
|
||||||
|
|
||||||
|
@ -71,14 +71,14 @@ def test_unique_edge_traversal(self):
|
||||||
'libelf', 'zmpi', 'fake', 'zmpi']
|
'libelf', 'zmpi', 'fake', 'zmpi']
|
||||||
pairs = zip([0,1,2,3,4,3,2,3,1], names)
|
pairs = zip([0,1,2,3,4,3,2,3,1], names)
|
||||||
|
|
||||||
traversal = dag.preorder_traversal(cover='edges')
|
traversal = dag.traverse(cover='edges')
|
||||||
self.assertListEqual([x.name for x in traversal], names)
|
self.assertListEqual([x.name for x in traversal], names)
|
||||||
|
|
||||||
traversal = dag.preorder_traversal(cover='edges', depth=True)
|
traversal = dag.traverse(cover='edges', depth=True)
|
||||||
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
||||||
|
|
||||||
|
|
||||||
def test_unique_path_traversal(self):
|
def test_preorder_path_traversal(self):
|
||||||
dag = Spec('mpileaks ^zmpi')
|
dag = Spec('mpileaks ^zmpi')
|
||||||
dag.normalize()
|
dag.normalize()
|
||||||
|
|
||||||
|
@ -86,10 +86,55 @@ def test_unique_path_traversal(self):
|
||||||
'libelf', 'zmpi', 'fake', 'zmpi', 'fake']
|
'libelf', 'zmpi', 'fake', 'zmpi', 'fake']
|
||||||
pairs = zip([0,1,2,3,4,3,2,3,1,2], names)
|
pairs = zip([0,1,2,3,4,3,2,3,1,2], names)
|
||||||
|
|
||||||
traversal = dag.preorder_traversal(cover='paths')
|
traversal = dag.traverse(cover='paths')
|
||||||
self.assertListEqual([x.name for x in traversal], names)
|
self.assertListEqual([x.name for x in traversal], names)
|
||||||
|
|
||||||
traversal = dag.preorder_traversal(cover='paths', depth=True)
|
traversal = dag.traverse(cover='paths', depth=True)
|
||||||
|
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
||||||
|
|
||||||
|
|
||||||
|
def test_postorder_node_traversal(self):
|
||||||
|
dag = Spec('mpileaks ^zmpi')
|
||||||
|
dag.normalize()
|
||||||
|
|
||||||
|
names = ['libelf', 'libdwarf', 'dyninst', 'fake', 'zmpi',
|
||||||
|
'callpath', 'mpileaks']
|
||||||
|
pairs = zip([4,3,2,3,2,1,0], names)
|
||||||
|
|
||||||
|
traversal = dag.traverse(order='post')
|
||||||
|
self.assertListEqual([x.name for x in traversal], names)
|
||||||
|
|
||||||
|
traversal = dag.traverse(depth=True, order='post')
|
||||||
|
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
||||||
|
|
||||||
|
|
||||||
|
def test_postorder_edge_traversal(self):
|
||||||
|
dag = Spec('mpileaks ^zmpi')
|
||||||
|
dag.normalize()
|
||||||
|
|
||||||
|
names = ['libelf', 'libdwarf', 'libelf', 'dyninst', 'fake', 'zmpi',
|
||||||
|
'callpath', 'zmpi', 'mpileaks']
|
||||||
|
pairs = zip([4,3,3,2,3,2,1,1,0], names)
|
||||||
|
|
||||||
|
traversal = dag.traverse(cover='edges', order='post')
|
||||||
|
self.assertListEqual([x.name for x in traversal], names)
|
||||||
|
|
||||||
|
traversal = dag.traverse(cover='edges', depth=True, order='post')
|
||||||
|
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
||||||
|
|
||||||
|
|
||||||
|
def test_postorder_path_traversal(self):
|
||||||
|
dag = Spec('mpileaks ^zmpi')
|
||||||
|
dag.normalize()
|
||||||
|
|
||||||
|
names = ['libelf', 'libdwarf', 'libelf', 'dyninst', 'fake', 'zmpi',
|
||||||
|
'callpath', 'fake', 'zmpi', 'mpileaks']
|
||||||
|
pairs = zip([4,3,3,2,3,2,1,2,1,0], names)
|
||||||
|
|
||||||
|
traversal = dag.traverse(cover='paths', order='post')
|
||||||
|
self.assertListEqual([x.name for x in traversal], names)
|
||||||
|
|
||||||
|
traversal = dag.traverse(cover='paths', depth=True, order='post')
|
||||||
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
self.assertListEqual([(x, y.name) for x,y in traversal], pairs)
|
||||||
|
|
||||||
|
|
||||||
|
@ -142,7 +187,7 @@ def test_normalize_with_virtual_spec(self):
|
||||||
|
|
||||||
# make sure nothing with the same name occurs twice
|
# make sure nothing with the same name occurs twice
|
||||||
counts = {}
|
counts = {}
|
||||||
for spec in dag.preorder_traversal(keyfun=id):
|
for spec in dag.traverse(key=id):
|
||||||
if not spec.name in counts:
|
if not spec.name in counts:
|
||||||
counts[spec.name] = 0
|
counts[spec.name] = 0
|
||||||
counts[spec.name] += 1
|
counts[spec.name] += 1
|
||||||
|
@ -152,7 +197,7 @@ def test_normalize_with_virtual_spec(self):
|
||||||
|
|
||||||
|
|
||||||
def check_links(self, spec_to_check):
|
def check_links(self, spec_to_check):
|
||||||
for spec in spec_to_check.preorder_traversal():
|
for spec in spec_to_check.traverse():
|
||||||
for dependent in spec.dependents.values():
|
for dependent in spec.dependents.values():
|
||||||
self.assertIn(
|
self.assertIn(
|
||||||
spec.name, dependent.dependencies,
|
spec.name, dependent.dependencies,
|
||||||
|
|
Loading…
Reference in a new issue