mercurial/changegroup.py

43105:649d3ac37a12

                # validate incoming csets have their manifests
                for cset in pycompat.xrange(clstart, clend):
                    mfnode = cl.changelogrevision(cset).manifest
                    mfest = ml[mfnode].readdelta()
                    # store file cgnodes we must see
                    for f, n in mfest.iteritems():
                        needfiles.setdefault(f, set()).add(n)

            # process the files
            repo.ui.status(_(b"adding file changes\n"))
            newrevs, newfiles = _addchangegroupfiles(

        mfdicts = None
        if self._ellipses and self._isshallow:
            mfdicts = [
                (self._repo.manifestlog[n].read(), lr)
                for (n, lr) in manifests.iteritems()
            ]

        manifests.clear()
        clrevs = set(cl.rev(x) for x in clnodes)

                    raise error.Abort(_(b"received spurious file revlog entry"))
            if not needs:
                del needfiles[f]
    progress.complete()

    for f, needs in needfiles.iteritems():
        fl = repo.file(f)
        for n in needs:
            try:
                fl.rev(n)
            except error.LookupError:

43106:d783f945a701

                # validate incoming csets have their manifests
                for cset in pycompat.xrange(clstart, clend):
                    mfnode = cl.changelogrevision(cset).manifest
                    mfest = ml[mfnode].readdelta()
                    # store file cgnodes we must see
                    for f, n in pycompat.iteritems(mfest):
                        needfiles.setdefault(f, set()).add(n)

            # process the files
            repo.ui.status(_(b"adding file changes\n"))
            newrevs, newfiles = _addchangegroupfiles(

        mfdicts = None
        if self._ellipses and self._isshallow:
            mfdicts = [
                (self._repo.manifestlog[n].read(), lr)
                for (n, lr) in pycompat.iteritems(manifests)
            ]

        manifests.clear()
        clrevs = set(cl.rev(x) for x in clnodes)

                    raise error.Abort(_(b"received spurious file revlog entry"))
            if not needs:
                del needfiles[f]
    progress.complete()

    for f, needs in pycompat.iteritems(needfiles):
        fl = repo.file(f)
        for n in needs:
            try:
                fl.rev(n)
            except error.LookupError: