mercurial/bundle2.py

26801:73bf76bf6f14

    def __init__(self, ui, fp):
        """If header is specified, we do not read it out of the stream."""
        self.ui = ui
        self._decompressor = util.decompressors[None]
        super(unbundle20, self).__init__(fp)

    @util.propertycache
    def params(self):
        """dictionary of stream level parameters"""

        if headersize:
            return self._readexact(headersize)
        return None

    def compressed(self):
        return False

formatmap = {'20': unbundle20}

b2streamparamsmap = {}

    """read compression parameter and install payload decompression"""
    if value not in util.decompressors:
        raise error.BundleUnknownFeatureError(params=(param,),
                                              values=(value,))
    unbundler._decompressor = util.decompressors[value]

class bundlepart(object):
    """A bundle2 part contains application level payload

    The part `type` is used to route the part to the application level

26802:42f705f2c02d

    def __init__(self, ui, fp):
        """If header is specified, we do not read it out of the stream."""
        self.ui = ui
        self._decompressor = util.decompressors[None]
        self._compressed = None
        super(unbundle20, self).__init__(fp)

    @util.propertycache
    def params(self):
        """dictionary of stream level parameters"""

        if headersize:
            return self._readexact(headersize)
        return None

    def compressed(self):
        self.params # load params
        return self._compressed

formatmap = {'20': unbundle20}

b2streamparamsmap = {}

    """read compression parameter and install payload decompression"""
    if value not in util.decompressors:
        raise error.BundleUnknownFeatureError(params=(param,),
                                              values=(value,))
    unbundler._decompressor = util.decompressors[value]
    if value is not None:
        unbundler._compressed = True

class bundlepart(object):
    """A bundle2 part contains application level payload

    The part `type` is used to route the part to the application level