comparison mercurial/changegroup.py @ 39010:fcdab6629dde

changegroup: emit delta group close chunk outside of deltagroup()

I want to make deltagroup() emit data structures rather than
serialized deltas. Upcoming commits will demonstrate why.

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

39009:9e8eb2b444e5

    If units is not None, progress detail will be generated, units specifies
    the type of revlog that is touched (changelog, manifest, etc.).
    """
    # if we don't have any revisions touched by these changesets, bail
    if len(revs) == 0:
        yield closechunk()
        return

    cl = repo.changelog

    # add the parent of the first rev

            yield x

    if progress:
        progress.complete()

    yield closechunk()

class cgpacker(object):
    def __init__(self, repo, filematcher, version, allowreorder,
                 deltaparentfn, builddeltaheader, manifestsend,
                 bundlecaps=None, ellipses=False,
                 shallow=False, ellipsisroots=None, fullnodes=None):

        clstate, chunks = self._generatechangelog(cl, clnodes)
        for chunk in chunks:
            size += len(chunk)
            yield chunk

        self._verbosenote(_('%8.i (changelog)\n') % size)

        clrevorder = clstate['clrevorder']
        mfs = clstate['mfs']

            for chunk in it:
                size += len(chunk)
                yield chunk

        self._verbosenote(_('%8.i (manifests)\n') % size)
        yield self._manifestsend

    # The 'source' parameter is useful for extensions
    def generatefiles(self, changedfiles, commonrevs, source,

                    precomputedellipsis=self._precomputedellipsis)

                for chunk in it:
                    size += len(chunk)
                    yield chunk
                self._verbosenote(_('%8.i  %s\n') % (size, fname))
        progress.complete()

def _deltaparentprev(store, rev, p1, p2, prev):
    """Resolve a delta parent to the previous revision.

39010:fcdab6629dde

    If units is not None, progress detail will be generated, units specifies
    the type of revlog that is touched (changelog, manifest, etc.).
    """
    # if we don't have any revisions touched by these changesets, bail
    if len(revs) == 0:
        return

    cl = repo.changelog

    # add the parent of the first rev

            yield x

    if progress:
        progress.complete()

class cgpacker(object):
    def __init__(self, repo, filematcher, version, allowreorder,
                 deltaparentfn, builddeltaheader, manifestsend,
                 bundlecaps=None, ellipses=False,
                 shallow=False, ellipsisroots=None, fullnodes=None):

        clstate, chunks = self._generatechangelog(cl, clnodes)
        for chunk in chunks:
            size += len(chunk)
            yield chunk

        close = closechunk()
        size += len(close)
        yield closechunk()

        self._verbosenote(_('%8.i (changelog)\n') % size)

        clrevorder = clstate['clrevorder']
        mfs = clstate['mfs']

            for chunk in it:
                size += len(chunk)
                yield chunk

            close = closechunk()
            size += len(close)
            yield close

        self._verbosenote(_('%8.i (manifests)\n') % size)
        yield self._manifestsend

    # The 'source' parameter is useful for extensions
    def generatefiles(self, changedfiles, commonrevs, source,

                    precomputedellipsis=self._precomputedellipsis)

                for chunk in it:
                    size += len(chunk)
                    yield chunk

                close = closechunk()
                size += len(close)
                yield close

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

def _deltaparentprev(store, rev, p1, p2, prev):
    """Resolve a delta parent to the previous revision.