Mercurial > hg
changeset 18120:88990d3e3d75
branchmap: extract _updatebranchcache from repo
| author | Pierre-Yves David <pierre-yves.david@logilab.fr> |
|---|---|
| date | Wed, 19 Dec 2012 14:49:06 +0100 |
| parents | 5264464b5f68 |
| children | f8a13f061a8a |
| files | mercurial/branchmap.py mercurial/discovery.py mercurial/localrepo.py |
| diffstat | 3 files changed, 70 insertions(+), 68 deletions(-) [+] |
line wrap: on
line diff
--- a/mercurial/branchmap.py Wed Dec 19 14:47:38 2012 +0100 +++ b/mercurial/branchmap.py Wed Dec 19 14:49:06 2012 +0100 @@ -50,3 +50,64 @@ f.close() except (IOError, OSError): pass + +def update(repo, partial, ctxgen): + """Given a branchhead cache, partial, that may have extra nodes or be + missing heads, and a generator of nodes that are at least a superset of + heads missing, this function updates partial to be correct. + """ + # collect new branch entries + newbranches = {} + for c in ctxgen: + newbranches.setdefault(c.branch(), []).append(c.node()) + # if older branchheads are reachable from new ones, they aren't + # really branchheads. Note checking parents is insufficient: + # 1 (branch a) -> 2 (branch b) -> 3 (branch a) + for branch, newnodes in newbranches.iteritems(): + bheads = partial.setdefault(branch, []) + # Remove candidate heads that no longer are in the repo (e.g., as + # the result of a strip that just happened). Avoid using 'node in + # self' here because that dives down into branchcache code somewhat + # recursively. + bheadrevs = [repo.changelog.rev(node) for node in bheads + if repo.changelog.hasnode(node)] + newheadrevs = [repo.changelog.rev(node) for node in newnodes + if repo.changelog.hasnode(node)] + ctxisnew = bheadrevs and min(newheadrevs) > max(bheadrevs) + # Remove duplicates - nodes that are in newheadrevs and are already + # in bheadrevs. This can happen if you strip a node whose parent + # was already a head (because they're on different branches). + bheadrevs = sorted(set(bheadrevs).union(newheadrevs)) + + # Starting from tip means fewer passes over reachable. If we know + # the new candidates are not ancestors of existing heads, we don't + # have to examine ancestors of existing heads + if ctxisnew: + iterrevs = sorted(newheadrevs) + else: + iterrevs = list(bheadrevs) + + # This loop prunes out two kinds of heads - heads that are + # superseded by a head in newheadrevs, and newheadrevs that are not + # heads because an existing head is their descendant. + while iterrevs: + latest = iterrevs.pop() + if latest not in bheadrevs: + continue + ancestors = set(repo.changelog.ancestors([latest], + bheadrevs[0])) + if ancestors: + bheadrevs = [b for b in bheadrevs if b not in ancestors] + partial[branch] = [repo.changelog.node(rev) for rev in bheadrevs] + + # There may be branches that cease to exist when the last commit in the + # branch was stripped. This code filters them out. Note that the + # branch that ceased to exist may not be in newbranches because + # newbranches is the set of candidate heads, which when you strip the + # last commit in a branch will be the parent branch. + for branch in partial.keys(): + nodes = [head for head in partial[branch] + if repo.changelog.hasnode(head)] + if not nodes: + del partial[branch] +
--- a/mercurial/discovery.py Wed Dec 19 14:47:38 2012 +0100 +++ b/mercurial/discovery.py Wed Dec 19 14:49:06 2012 +0100 @@ -8,6 +8,7 @@ from node import nullid, short from i18n import _ import util, setdiscovery, treediscovery, phases, obsolete, bookmarks +import branchmap def findcommonincoming(repo, remote, heads=None, force=False): """Return a tuple (common, anyincoming, heads) used to identify the common @@ -194,7 +195,7 @@ # This will possibly add new heads and remove existing ones. newmap = dict((branch, heads[1]) for branch, heads in headssum.iteritems() if heads[0] is not None) - repo._updatebranchcache(newmap, missingctx) + branchmap.update(repo, newmap, missingctx) for branch, newheads in newmap.iteritems(): headssum[branch][1][:] = newheads return headssum @@ -205,7 +206,7 @@ cl = repo.changelog # 1-4b. old servers: Check for new topological heads. # Construct {old,new}map with branch = None (topological branch). - # (code based on _updatebranchcache) + # (code based on update) oldheads = set(h for h in remoteheads if h in cl.nodemap) # all nodes in outgoing.missing are children of either: # - an element of oldheads
--- a/mercurial/localrepo.py Wed Dec 19 14:47:38 2012 +0100 +++ b/mercurial/localrepo.py Wed Dec 19 14:49:06 2012 +0100 @@ -682,7 +682,7 @@ # on disk if lrev < catip: ctxgen = (self[r] for r in cl.revs(lrev + 1, catip)) - self._updatebranchcache(partial, ctxgen) + branchmap.update(self, partial, ctxgen) branchmap.write(self, partial, cl.node(catip), catip) lrev = catip # If cacheable tip were lower than actual tip, we need to update the @@ -691,7 +691,7 @@ tiprev = len(self) - 1 if lrev < tiprev: ctxgen = (self[r] for r in cl.revs(lrev + 1, tiprev)) - self._updatebranchcache(partial, ctxgen) + branchmap.update(self, partial, ctxgen) self._branchcache = partial self._branchcachetip = tip @@ -699,9 +699,9 @@ '''returns a dictionary {branch: [branchheads]}''' if self.changelog.filteredrevs: # some changeset are excluded we can't use the cache - branchmap = {} - self._updatebranchcache(branchmap, (self[r] for r in self)) - return branchmap + bmap = {} + branchmap.update(self, bmap, (self[r] for r in self)) + return bmap else: self.updatebranchcache() return self._branchcache @@ -730,66 +730,6 @@ bt[bn] = self._branchtip(heads) return bt - def _updatebranchcache(self, partial, ctxgen): - """Given a branchhead cache, partial, that may have extra nodes or be - missing heads, and a generator of nodes that are at least a superset of - heads missing, this function updates partial to be correct. - """ - # collect new branch entries - newbranches = {} - for c in ctxgen: - newbranches.setdefault(c.branch(), []).append(c.node()) - # if older branchheads are reachable from new ones, they aren't - # really branchheads. Note checking parents is insufficient: - # 1 (branch a) -> 2 (branch b) -> 3 (branch a) - for branch, newnodes in newbranches.iteritems(): - bheads = partial.setdefault(branch, []) - # Remove candidate heads that no longer are in the repo (e.g., as - # the result of a strip that just happened). Avoid using 'node in - # self' here because that dives down into branchcache code somewhat - # recursively. - bheadrevs = [self.changelog.rev(node) for node in bheads - if self.changelog.hasnode(node)] - newheadrevs = [self.changelog.rev(node) for node in newnodes - if self.changelog.hasnode(node)] - ctxisnew = bheadrevs and min(newheadrevs) > max(bheadrevs) - # Remove duplicates - nodes that are in newheadrevs and are already - # in bheadrevs. This can happen if you strip a node whose parent - # was already a head (because they're on different branches). - bheadrevs = sorted(set(bheadrevs).union(newheadrevs)) - - # Starting from tip means fewer passes over reachable. If we know - # the new candidates are not ancestors of existing heads, we don't - # have to examine ancestors of existing heads - if ctxisnew: - iterrevs = sorted(newheadrevs) - else: - iterrevs = list(bheadrevs) - - # This loop prunes out two kinds of heads - heads that are - # superseded by a head in newheadrevs, and newheadrevs that are not - # heads because an existing head is their descendant. - while iterrevs: - latest = iterrevs.pop() - if latest not in bheadrevs: - continue - ancestors = set(self.changelog.ancestors([latest], - bheadrevs[0])) - if ancestors: - bheadrevs = [b for b in bheadrevs if b not in ancestors] - partial[branch] = [self.changelog.node(rev) for rev in bheadrevs] - - # There may be branches that cease to exist when the last commit in the - # branch was stripped. This code filters them out. Note that the - # branch that ceased to exist may not be in newbranches because - # newbranches is the set of candidate heads, which when you strip the - # last commit in a branch will be the parent branch. - for branch in partial.keys(): - nodes = [head for head in partial[branch] - if self.changelog.hasnode(head)] - if not nodes: - del partial[branch] - def lookup(self, key): return self[key].node() @@ -1532,7 +1472,7 @@ tiprev = len(self) - 1 ctxgen = (self[node] for node in newheadnodes if self.changelog.hasnode(node)) - self._updatebranchcache(self._branchcache, ctxgen) + branchmap.update(self, self._branchcache, ctxgen) branchmap.write(self, self._branchcache, self.changelog.tip(), tiprev)