comparison mercurial/revlog.py @ 13831:d69c9510d648

changegroup: introduce bundler objects

This makes the bundler pluggable at lower levels.

13830:2dc6e09f2a7d

        if type(text) == str: # only accept immutable objects
            self._cache = (node, curr, text)
        return node

    def group(self, nodelist, lookup):
        """Calculate a delta group, yielding a sequence of changegroup chunks
        (strings).

        Given a list of changeset revs, return a set of deltas and
        metadata corresponding to nodes. The first delta is

        revs = sorted([self.rev(n) for n in nodelist])

        # if we don't have any revisions touched by these changesets, bail
        if not revs:
            yield changegroup.closechunk()
            return

        # add the parent of the first rev
        p = self.parentrevs(revs[0])[0]
        revs.insert(0, p)

        # build deltas
        for r in xrange(len(revs) - 1):
            a, b = revs[r], revs[r + 1]
            nb = self.node(b)

            p = self.parents(nb)
            meta = nb + p[0] + p[1] + lookup(self, nb)
            if a == nullrev:
                d = self.revision(nb)
                meta += mdiff.trivialdiffheader(len(d))
            else:
                d = self.revdiff(a, b)
            yield changegroup.chunkheader(len(meta) + len(d))
            yield meta
            yield d

        yield changegroup.closechunk()

    def addgroup(self, bundle, linkmapper, transaction):
        """
        add a delta group

13831:d69c9510d648

        if type(text) == str: # only accept immutable objects
            self._cache = (node, curr, text)
        return node

    def group(self, nodelist, bundler):
        """Calculate a delta group, yielding a sequence of changegroup chunks
        (strings).

        Given a list of changeset revs, return a set of deltas and
        metadata corresponding to nodes. The first delta is

        revs = sorted([self.rev(n) for n in nodelist])

        # if we don't have any revisions touched by these changesets, bail
        if not revs:
            yield bundler.close()
            return

        # add the parent of the first rev
        p = self.parentrevs(revs[0])[0]
        revs.insert(0, p)

        # build deltas
        for r in xrange(len(revs) - 1):
            a, b = revs[r], revs[r + 1]
            nb = self.node(b)
            p1, p2 = self.parents(nb)
            prefix = ''

            if a == nullrev:
                d = self.revision(nb)
                prefix = mdiff.trivialdiffheader(len(d))
            else:
                d = self.revdiff(a, b)
            for c in bundler.revchunk(self, nb, p1, p2, prefix, d):
                yield c

        yield bundler.close()

    def addgroup(self, bundle, linkmapper, transaction):
        """
        add a delta group