comparison mercurial/changegroup.py @ 38994:6076053589b9

changegroup: populate _clnodetorev as part of changelog linknode lookup

The thing that matters is that self._clnodetorev is populated with
changesets that are being sent. Back when this code was in an
extension, it wasn't possible to monkeypatch the changelog lookup
function. Now that the code is in core, we can move this code to
where it logically belongs.

Differential Revision: https://phab.mercurial-scm.org/D4186

38993:ee0720e82257

        def lookupcl(x):
            c = cl.read(x)
            clrevorder[x] = len(clrevorder)

            if self._ellipses:
                # Only update mfs if x is going to be sent. Otherwise we
                # end up with bogus linkrevs specified for manifests and
                # we skip some manifest nodes that we should otherwise
                # have sent.
                if (x in self._fullnodes

                    yield chunk
                self._verbosenote(_('%8.i  %s\n') % (size, fname))
        progress.complete()

    def _revisiondeltanarrow(self, store, ischangelog, rev, prev, linknode):
        # build up some mapping information that's useful later. See
        # the local() nested function below.
        if ischangelog:
            self._clnodetorev[linknode] = rev
            linkrev = rev
            self._clrevtolocalrev[linkrev] = rev
        else:
            linkrev = self._clnodetorev[linknode]
            self._clrevtolocalrev[linkrev] = rev

        # This is a node to send in full, because the changeset it
        # corresponds to was a full changeset.
        if linknode in self._fullnodes:
            return _revisiondeltanormal(store, rev, prev, linknode,

38994:6076053589b9

        def lookupcl(x):
            c = cl.read(x)
            clrevorder[x] = len(clrevorder)

            if self._ellipses:
                self._clnodetorev[x] = cl.rev(x)

                # Only update mfs if x is going to be sent. Otherwise we
                # end up with bogus linkrevs specified for manifests and
                # we skip some manifest nodes that we should otherwise
                # have sent.
                if (x in self._fullnodes

                    yield chunk
                self._verbosenote(_('%8.i  %s\n') % (size, fname))
        progress.complete()

    def _revisiondeltanarrow(self, store, ischangelog, rev, prev, linknode):
        linkrev = self._clnodetorev[linknode]
        self._clrevtolocalrev[linkrev] = rev

        # This is a node to send in full, because the changeset it
        # corresponds to was a full changeset.
        if linknode in self._fullnodes:
            return _revisiondeltanormal(store, rev, prev, linknode,