mercurial/localrepo.py

24640:685639f9430d

                                common=common, bundlecaps=bundlecaps, **kwargs)
        if bundlecaps is not None and 'HG2Y' in bundlecaps:
            # When requesting a bundle2, getbundle returns a stream to make the
            # wire level function happier. We need to build a proper object
            # from it in local peer.
            cg = bundle2.unbundle20(self.ui, cg)
        return cg

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

            if util.safehasattr(ret, 'getchunks'):
                # This is a bundle20 object, turn it into an unbundler.
                # This little dance should be dropped eventually when the API
                # is finally improved.
                stream = util.chunkbuffer(ret.getchunks())
                ret = bundle2.unbundle20(self.ui, stream)
            return ret
        except error.PushRaced, exc:
            raise error.ResponseError(_('push failed:'), str(exc))

    def lock(self):

24641:60fecc5b14a4

                                common=common, bundlecaps=bundlecaps, **kwargs)
        if bundlecaps is not None and 'HG2Y' in bundlecaps:
            # When requesting a bundle2, getbundle returns a stream to make the
            # wire level function happier. We need to build a proper object
            # from it in local peer.
            cg = bundle2.getunbundler(self.ui, cg)
        return cg

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

            if util.safehasattr(ret, 'getchunks'):
                # This is a bundle20 object, turn it into an unbundler.
                # This little dance should be dropped eventually when the API
                # is finally improved.
                stream = util.chunkbuffer(ret.getchunks())
                ret = bundle2.getunbundler(self.ui, stream)
            return ret
        except error.PushRaced, exc:
            raise error.ResponseError(_('push failed:'), str(exc))

    def lock(self):