comparison mercurial/localrepo.py @ 11598:5be142109ed4

localrepo: remove push_{unbundle,addchangegroup}(), factor it inside push()

11597:9141d2c9e5a5

        # repo (local filesystem, old ssh servers).
        #
        # unbundle assumes local user cannot lock remote repo (new ssh
        # servers, http servers).

        if remote.capable('unbundle'):
            return self.push_unbundle(remote, force, revs, newbranch)
        return self.push_addchangegroup(remote, force, revs, newbranch)

    def push_addchangegroup(self, remote, force, revs, newbranch):
        '''Push a changegroup by locking the remote and sending the
        addchangegroup command to it. Used for local and old SSH repos.
        Return an integer: see push().
        '''
        lock = remote.lock()
        try:
            ret = discovery.prepush(self, remote, force, revs, newbranch)
            if ret[0] is not None:
                cg, remote_heads = ret
                # we return an integer indicating remote head count change
                return remote.addchangegroup(cg, 'push', self.url(), lock=lock)
            # and here we return 0 for "nothing to push" or 1 for
            # "something to push but I refuse"
            return ret[1]
        finally:
            lock.release()

    def push_unbundle(self, remote, force, revs, newbranch):
        '''Push a changegroup by unbundling it on the remote.  Used for new
        SSH and HTTP repos. Return an integer: see push().'''
        # local repo finds heads on server, finds out what revs it
        # must push.  once revs transferred, if server finds it has
        # different heads (someone else won commit/push race), server
        # aborts.

        ret = discovery.prepush(self, remote, force, revs, newbranch)
        if ret[0] is not None:
            cg, remote_heads = ret
            if force:
                remote_heads = ['force']
            # ssh: return remote's addchangegroup()
            # http: return remote's addchangegroup() or 0 for error
            return remote.unbundle(cg, remote_heads, 'push')
        # as in push_addchangegroup()
        return ret[1]

    def changegroupinfo(self, nodes, source):
        if self.ui.verbose or source == 'bundle':
            self.ui.status(_("%d changesets found\n") % len(nodes))
        if self.ui.debugflag:

11598:5be142109ed4

        # repo (local filesystem, old ssh servers).
        #
        # unbundle assumes local user cannot lock remote repo (new ssh
        # servers, http servers).

        lock = None
        unbundle = remote.capable('unbundle')
        if not unbundle:
            lock = remote.lock()
        try:
            ret = discovery.prepush(self, remote, force, revs, newbranch)
            if ret[0] is None:
                # and here we return 0 for "nothing to push" or 1 for
                # "something to push but I refuse"
                return ret[1]

            cg, remote_heads = ret
            if unbundle:
                # local repo finds heads on server, finds out what revs it must
                # push.  once revs transferred, if server finds it has
                # different heads (someone else won commit/push race), server
                # aborts.
                if force:
                    remote_heads = ['force']
                # ssh: return remote's addchangegroup()
                # http: return remote's addchangegroup() or 0 for error
                return remote.unbundle(cg, remote_heads, 'push')
            else:
                # we return an integer indicating remote head count change
                return remote.addchangegroup(cg, 'push', self.url(), lock=lock)
        finally:
            if lock is not None:
                lock.release()

    def changegroupinfo(self, nodes, source):
        if self.ui.verbose or source == 'bundle':
            self.ui.status(_("%d changesets found\n") % len(nodes))
        if self.ui.debugflag: