113
114
def unpack_revision(elt):
114
115
"""Convert XML element into Revision object."""
115
116
# <changeset> is deprecated...
116
from bzrlib.errors import BzrError
118
117
if elt.tag not in ('revision', 'changeset'):
119
raise BzrError("unexpected tag in revision file: %r" % elt)
118
raise bzrlib.errors.BzrError("unexpected tag in revision file: %r" % elt)
121
120
rev = Revision(committer = elt.get('committer'),
122
121
timestamp = float(elt.get('timestamp')),
177
176
behaves like Branch's.
180
from bzrlib.branch import NoSuchRevision
179
for ancestor_id, distance in iter_ancestors(revision_id, revision_source):
180
if ancestor_id == candidate_id:
184
def iter_ancestors(revision_id, revision_source, only_present=False):
181
185
ancestors = (revision_id,)
182
187
while len(ancestors) > 0:
183
188
new_ancestors = []
184
189
for ancestor in ancestors:
185
if ancestor == candidate_id:
191
yield ancestor, distance
188
193
revision = revision_source.get_revision(ancestor)
189
except NoSuchRevision, e:
194
except bzrlib.errors.NoSuchRevision, e:
190
195
if e.revision == revision_id:
200
yield ancestor, distance
194
201
new_ancestors.extend([p.revision_id for p in revision.parents])
195
202
ancestors = new_ancestors
206
def find_present_ancestors(revision_id, revision_source):
207
"""Return the ancestors of a revision present in a branch.
209
It's possible that a branch won't have the complete ancestry of
210
one of its revisions.
214
anc_iter = enumerate(iter_ancestors(revision_id, revision_source,
216
for anc_order, (anc_id, anc_distance) in anc_iter:
217
if not found_ancestors.has_key(anc_id):
218
found_ancestors[anc_id] = (anc_order, anc_distance)
219
return found_ancestors
222
def __get_closest(intersection):
225
for entry in intersection:
226
if entry[0] == intersection[0][0]:
227
matches.append(entry[2])
231
def common_ancestor(revision_a, revision_b, revision_source):
232
"""Find the ancestor common to both revisions that is closest to both.
234
from bzrlib.trace import mutter
235
a_ancestors = find_present_ancestors(revision_a, revision_source)
236
b_ancestors = find_present_ancestors(revision_b, revision_source)
239
# a_order is used as a tie-breaker when two equally-good bases are found
240
for revision, (a_order, a_distance) in a_ancestors.iteritems():
241
if b_ancestors.has_key(revision):
242
a_intersection.append((a_distance, a_order, revision))
243
b_intersection.append((b_ancestors[revision][1], a_order, revision))
244
mutter("a intersection: %r" % a_intersection)
245
mutter("b intersection: %r" % b_intersection)
247
a_closest = __get_closest(a_intersection)
248
if len(a_closest) == 0:
250
b_closest = __get_closest(b_intersection)
251
assert len(b_closest) != 0
252
mutter ("a_closest %r" % a_closest)
253
mutter ("b_closest %r" % b_closest)
254
if a_closest[0] in b_closest:
256
elif b_closest[0] in a_closest:
259
raise bzrlib.errors.AmbiguousBase((a_closest[0], b_closest[0]))
198
262
class MultipleRevisionSources(object):
263
"""Proxy that looks in multiple branches for revisions."""
199
264
def __init__(self, *args):
200
265
object.__init__(self)
201
266
assert len(args) != 0
202
267
self._revision_sources = args
204
269
def get_revision(self, revision_id):
205
from bzrlib.branch import NoSuchRevision
206
270
for source in self._revision_sources:
208
272
return source.get_revision(revision_id)
209
except NoSuchRevision, e:
273
except bzrlib.errors.NoSuchRevision, e: