comparison mercurial/changegroup.py @ 38981:227ebd88ce5e

changegroup: pull _fileheader out of cgpacker

It doesn't need any state from the packer.

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

38980:4a202bccafcf

    return struct.pack(">l", length + 4)

def closechunk():
    """return a changegroup chunk header (string) for a zero-length chunk"""
    return struct.pack(">l", 0)

def writechunks(ui, chunks, filename, vfs=None):
    """Write chunks to a file and return its filename.

    The stream is assumed to be a bundle file.

            self._clrevtolocalrev = self._nextclrevtolocalrev
            self._nextclrevtolocalrev = None

        return closechunk()

    def _fileheader(self, fname):
        return chunkheader(len(fname)) + fname

    # Extracted both for clarity and for overriding in extensions.
    def _sortgroup(self, store, ischangelog, nodelist, lookup):
        """Sort nodes for change group and turn them into revnums."""
        # Ellipses serving mode.
        #

        can be sent. Multiple manifests is not supported by cg1 and cg2.
        """

        if dir:
            assert self.version == b'03'
            yield self._fileheader(dir)

        # TODO violates storage abstractions by assuming revlogs.
        dirlog = self._repo.manifestlog._revlog.dirlog(dir)
        for chunk in self.group(mfnodes, dirlog, False, lookuplinknode,
                                units=_('manifests')):

                return linkrevnodes[x]

            filenodes = self._prune(filerevlog, linkrevnodes, commonrevs)
            if filenodes:
                progress.update(i + 1, item=fname)
                h = self._fileheader(fname)
                size = len(h)
                yield h
                for chunk in self.group(filenodes, filerevlog, False,
                                        lookupfilelog):
                    size += len(chunk)

38981:227ebd88ce5e

    return struct.pack(">l", length + 4)

def closechunk():
    """return a changegroup chunk header (string) for a zero-length chunk"""
    return struct.pack(">l", 0)

def _fileheader(path):
    """Obtain a changegroup chunk header for a named path."""
    return chunkheader(len(path)) + path

def writechunks(ui, chunks, filename, vfs=None):
    """Write chunks to a file and return its filename.

    The stream is assumed to be a bundle file.

            self._clrevtolocalrev = self._nextclrevtolocalrev
            self._nextclrevtolocalrev = None

        return closechunk()

    # Extracted both for clarity and for overriding in extensions.
    def _sortgroup(self, store, ischangelog, nodelist, lookup):
        """Sort nodes for change group and turn them into revnums."""
        # Ellipses serving mode.
        #

        can be sent. Multiple manifests is not supported by cg1 and cg2.
        """

        if dir:
            assert self.version == b'03'
            yield _fileheader(dir)

        # TODO violates storage abstractions by assuming revlogs.
        dirlog = self._repo.manifestlog._revlog.dirlog(dir)
        for chunk in self.group(mfnodes, dirlog, False, lookuplinknode,
                                units=_('manifests')):

                return linkrevnodes[x]

            filenodes = self._prune(filerevlog, linkrevnodes, commonrevs)
            if filenodes:
                progress.update(i + 1, item=fname)
                h = _fileheader(fname)
                size = len(h)
                yield h
                for chunk in self.group(filenodes, filerevlog, False,
                                        lookupfilelog):
                    size += len(chunk)