comparison mercurial/localrepo.py @ 11211:e43c23d189a5

push: add --new-branch option to allow intial push of new branches

Compare this to --force which allows anything to be pushed. With --new-branch,
only changesets to named branches not present on the and changesets not
introducing additional heads on existing branches are allowed.

Developed by
  Henrik Stuart <[e-mail]>
  Sune Foldager <[e-mail]>

11210:0c0088881562

                cg = remote.changegroupsubset(fetch, heads, 'pull')
            return self.addchangegroup(cg, 'pull', remote.url())
        finally:
            lock.release()

    def push(self, remote, force=False, revs=None):
        '''Push outgoing changesets (limited by revs) from the current
        repository to remote. Return an integer:
          - 0 means HTTP error *or* nothing to push
          - 1 means we pushed and remote head count is unchanged *or*
            we have outgoing changesets but refused to push

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

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

    def prepush(self, remote, force, revs):
        '''Analyze the local and remote repositories and determine which
        changesets need to be pushed to the remote. Return value depends
        on circumstances:

        If we are not going to push anything, return a tuple (None,

                branches = set(self[n].branch() for n in outg)

                # 2. Check for new branches on the remote.
                remotemap = remote.branchmap()
                newbranches = branches - set(remotemap)
                if newbranches: # new branch requires --force
                    branchnames = ', '.join("%s" % b for b in newbranches)
                    self.ui.warn(_("abort: push creates "
                                   "new remote branches: %s!\n")
                                 % branchnames)
                    self.ui.status(_("(use 'hg push -f' to force)\n"))
                    return None, 0

                # 3. Construct the initial oldmap and newmap dicts.
                # They contain information about the remote heads before and
                # after the push, respectively.
                # Heads not found locally are not included in either dict,

            cg = self._changegroup(nodes, 'push')
        else:
            cg = self.changegroupsubset(update, revs, 'push')
        return cg, remote_heads

    def push_addchangegroup(self, remote, force, revs):
        '''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 = self.prepush(remote, force, revs)
            if ret[0] is not None:
                cg, remote_heads = ret
                # here, we return an integer indicating remote head count change
                return remote.addchangegroup(cg, 'push', self.url())
            # 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):
        '''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 = self.prepush(remote, force, revs)
        if ret[0] is not None:
            cg, remote_heads = ret
            if force:
                remote_heads = ['force']
            # ssh: return remote's addchangegroup()

11211:e43c23d189a5

                cg = remote.changegroupsubset(fetch, heads, 'pull')
            return self.addchangegroup(cg, 'pull', remote.url())
        finally:
            lock.release()

    def push(self, remote, force=False, revs=None, newbranch=False):
        '''Push outgoing changesets (limited by revs) from the current
        repository to remote. Return an integer:
          - 0 means HTTP error *or* nothing to push
          - 1 means we pushed and remote head count is unchanged *or*
            we have outgoing changesets but refused to push

        #
        # 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 prepush(self, remote, force, revs, newbranch):
        '''Analyze the local and remote repositories and determine which
        changesets need to be pushed to the remote. Return value depends
        on circumstances:

        If we are not going to push anything, return a tuple (None,

                branches = set(self[n].branch() for n in outg)

                # 2. Check for new branches on the remote.
                remotemap = remote.branchmap()
                newbranches = branches - set(remotemap)
                if newbranches and not newbranch: # new branch requires --new-branch
                    branchnames = ', '.join("%s" % b for b in newbranches)
                    self.ui.warn(_("abort: push creates "
                                   "new remote branches: %s!\n")
                                 % branchnames)
                    self.ui.status(_("(use 'hg push --new-branch' to create new "
                                     "remote branches)\n"))
                    return None, 0
                branches.difference_update(newbranches)

                # 3. Construct the initial oldmap and newmap dicts.
                # They contain information about the remote heads before and
                # after the push, respectively.
                # Heads not found locally are not included in either dict,

            cg = self._changegroup(nodes, 'push')
        else:
            cg = self.changegroupsubset(update, revs, 'push')
        return cg, remote_heads

    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 = self.prepush(remote, force, revs, newbranch)
            if ret[0] is not None:
                cg, remote_heads = ret
                # here, we return an integer indicating remote head count change
                return remote.addchangegroup(cg, 'push', self.url())
            # 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 = self.prepush(remote, force, revs, newbranch)
        if ret[0] is not None:
            cg, remote_heads = ret
            if force:
                remote_heads = ['force']
            # ssh: return remote's addchangegroup()