comparison mercurial/localrepo.py @ 20969:7a679918ee2b

localrepo: add unbundle support

Localrepo now supports the unbundle method of pushing changegroups. We
plan to use the unbundle call for bundle2 so it is important that all
peers supports it. The `peer.unbundle` and `peer.addchangegroup` code
path have small difference so cause some test output changes. None of those
changes seems problematic.

20968:33d5fdd9bd99

    def wrapper(repo, *args, **kwargs):
        return orig(repo.unfiltered(), *args, **kwargs)
    return wrapper

moderncaps = set(('lookup', 'branchmap', 'pushkey', 'known', 'getbundle',
                  'bundle2'))
legacycaps = moderncaps.union(set(['changegroupsubset']))

class localpeer(peer.peerrepository):
    '''peer for a local repo; reflects only the most recent API'''

        return exchange.getbundle(self._repo, source, heads=heads,
                                  common=common, bundlecaps=bundlecaps)

    # TODO We might want to move the next two calls into legacypeer and add
    # unbundle instead.

    def lock(self):
        return self._repo.lock()

    def addchangegroup(self, cg, source, url):

20969:7a679918ee2b

    def wrapper(repo, *args, **kwargs):
        return orig(repo.unfiltered(), *args, **kwargs)
    return wrapper

moderncaps = set(('lookup', 'branchmap', 'pushkey', 'known', 'getbundle',
                  'bundle2', 'unbundle'))
legacycaps = moderncaps.union(set(['changegroupsubset']))

class localpeer(peer.peerrepository):
    '''peer for a local repo; reflects only the most recent API'''

        return exchange.getbundle(self._repo, source, heads=heads,
                                  common=common, bundlecaps=bundlecaps)

    # TODO We might want to move the next two calls into legacypeer and add
    # unbundle instead.

    def unbundle(self, cg, heads, url):
        """apply a bundle on a repo

        This function handles the repo locking itself."""
        try:
            return exchange.unbundle(self._repo, cg, heads, 'push', url)
        except exchange.PushRaced, exc:
            raise error.ResponseError(_('push failed:'), exc.message)

    def lock(self):
        return self._repo.lock()

    def addchangegroup(self, cg, source, url):