comparison mercurial/discovery.py @ 11578:bb7af1de5e38

discovery: remove duplication for new remote head discovery

11577:0bc450253312

    if not bases:
        repo.ui.status(_("no changes found\n"))
        return None, 1

    if not force and remoteheads != [nullid]:

        def fail_multiple_heads(unsynced, branch=None):
            if branch:
                msg = _("push creates new remote heads "
                        "on branch '%s'!") % branch
            else:
                msg = _("push creates new remote heads!")

            if unsynced:
                hint = _("you should pull and merge or use push -f to force")
            else:
                hint = _("did you forget to merge? use push -f to force")
            raise util.Abort(msg, hint=hint)

        if remote.capable('branchmap'):
            # Check for each named branch if we're creating new remote heads.
            # To be a remote head after push, node must be either:
            # - unknown locally
            # - a local outgoing head descended from update

            # 4. Update newmap with outgoing changes.
            # This will possibly add new heads and remove existing ones.
            ctxgen = (repo[n] for n in outg)
            repo._updatebranchcache(newmap, ctxgen)

            # 5. Check for new heads.
            # If there are more heads after the push than before, a suitable
            # warning, depending on unsynced status, is displayed.
            for branch in branches:
                if len(newmap[branch]) > len(oldmap[branch]):
                    return fail_multiple_heads(branch in unsynced, branch)

            # 6. Check for unsynced changes on involved branches.
            if unsynced:
                repo.ui.warn(_("note: unsynced remote changes!\n"))

        else:
            # Old servers: Check for new topological heads.
            # Code based on _updatebranchcache.
            newheads = set(h for h in remoteheads if h in cl.nodemap)
            oldheadcnt = len(newheads)
            newheads.update(outg)
            if len(newheads) > 1:
                for latest in reversed(outg):
                    if latest not in newheads:
                        continue
                    minhrev = min(cl.rev(h) for h in newheads)
                    reachable = cl.reachable(latest, cl.node(minhrev))
                    reachable.remove(latest)
                    newheads.difference_update(reachable)
            if len(newheads) > oldheadcnt:
                return fail_multiple_heads(inc)
            if inc:
                repo.ui.warn(_("note: unsynced remote changes!\n"))

    if revs is None:
        # use the fast path, no race possible on push
        nodes = repo.changelog.findmissing(common.keys())
        cg = repo._changegroup(nodes, 'push')

11578:bb7af1de5e38

    if not bases:
        repo.ui.status(_("no changes found\n"))
        return None, 1

    if not force and remoteheads != [nullid]:
        if remote.capable('branchmap'):
            # Check for each named branch if we're creating new remote heads.
            # To be a remote head after push, node must be either:
            # - unknown locally
            # - a local outgoing head descended from update

            # 4. Update newmap with outgoing changes.
            # This will possibly add new heads and remove existing ones.
            ctxgen = (repo[n] for n in outg)
            repo._updatebranchcache(newmap, ctxgen)

        else:
            # 1-4b. old servers: Check for new topological heads.
            # Construct {old,new}map with branch = None (topological branch).
            # (code based on _updatebranchcache)
            oldheads = set(h for h in remoteheads if h in cl.nodemap)
            newheads = oldheads.union(outg)
            if len(newheads) > 1:
                for latest in reversed(outg):
                    if latest not in newheads:
                        continue
                    minhrev = min(cl.rev(h) for h in newheads)
                    reachable = cl.reachable(latest, cl.node(minhrev))
                    reachable.remove(latest)
                    newheads.difference_update(reachable)
            branches = set([None])
            newmap = {None: newheads}
            oldmap = {None: oldheads}
            unsynced = inc and branches or set()

        # 5. Check for new heads.
        # If there are more heads after the push than before, a suitable
        # warning, depending on unsynced status, is displayed.
        for branch in branches:
            if len(newmap[branch]) > len(oldmap[branch]):
                if branch:
                    msg = _("push creates new remote heads "
                            "on branch '%s'!") % branch
                else:
                    msg = _("push creates new remote heads!")

                if branch in unsynced:
                    hint = _("you should pull and merge or use push -f to force")
                else:
                    hint = _("did you forget to merge? use push -f to force")
                raise util.Abort(msg, hint=hint)

        # 6. Check for unsynced changes on involved branches.
        if unsynced:
            repo.ui.warn(_("note: unsynced remote changes!\n"))

    if revs is None:
        # use the fast path, no race possible on push
        nodes = repo.changelog.findmissing(common.keys())
        cg = repo._changegroup(nodes, 'push')