comparison mercurial/bundle2.py @ 43115:4aa72cdf616f

py3: delete b'' prefix from safehasattr arguments

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

43114:8197b395710e

        self.params  # load params
        return self._compressed

    def close(self):
        """close underlying file"""
        if util.safehasattr(self._fp, b'close'):
            return self._fp.close()


formatmap = {b'20': unbundle20}

    def copy(self):
        """return a copy of the part

        The new part have the very same content but no partid assigned yet.
        Parts with generated data cannot be copied."""
        assert not util.safehasattr(self.data, b'next')
        return self.__class__(
            self.type,
            self._mandatoryparams,
            self._advisoryparams,
            self._data,

                if nbap:
                    msg.append(b' %i advisory' % nbmp)
                msg.append(b')')
            if not self.data:
                msg.append(b' empty payload')
            elif util.safehasattr(self.data, b'next') or util.safehasattr(
                self.data, b'__next__'
            ):
                msg.append(b' streamed payload')
            else:
                msg.append(b' %i bytes payload' % len(self.data))

        """yield chunks of a the part payload

        Exists to handle the different methods to provide data to a part."""
        # we only support fixed size data now.
        # This will be improved in the future.
        if util.safehasattr(self.data, b'next') or util.safehasattr(
            self.data, b'__next__'
        ):
            buff = util.chunkbuffer(self.data)
            chunk = buff.read(preferedchunksize)
            while chunk:

class unbundlepart(unpackermixin):
    """a bundle part read from a bundle"""

    def __init__(self, ui, header, fp):
        super(unbundlepart, self).__init__(fp)
        self._seekable = util.safehasattr(fp, b'seek') and util.safehasattr(
            fp, b'tell'
        )
        self.ui = ui
        # unbundle state attr
        self._headerdata = header

43115:4aa72cdf616f

        self.params  # load params
        return self._compressed

    def close(self):
        """close underlying file"""
        if util.safehasattr(self._fp, 'close'):
            return self._fp.close()


formatmap = {b'20': unbundle20}

    def copy(self):
        """return a copy of the part

        The new part have the very same content but no partid assigned yet.
        Parts with generated data cannot be copied."""
        assert not util.safehasattr(self.data, 'next')
        return self.__class__(
            self.type,
            self._mandatoryparams,
            self._advisoryparams,
            self._data,

                if nbap:
                    msg.append(b' %i advisory' % nbmp)
                msg.append(b')')
            if not self.data:
                msg.append(b' empty payload')
            elif util.safehasattr(self.data, 'next') or util.safehasattr(
                self.data, b'__next__'
            ):
                msg.append(b' streamed payload')
            else:
                msg.append(b' %i bytes payload' % len(self.data))

        """yield chunks of a the part payload

        Exists to handle the different methods to provide data to a part."""
        # we only support fixed size data now.
        # This will be improved in the future.
        if util.safehasattr(self.data, 'next') or util.safehasattr(
            self.data, b'__next__'
        ):
            buff = util.chunkbuffer(self.data)
            chunk = buff.read(preferedchunksize)
            while chunk:

class unbundlepart(unpackermixin):
    """a bundle part read from a bundle"""

    def __init__(self, ui, header, fp):
        super(unbundlepart, self).__init__(fp)
        self._seekable = util.safehasattr(fp, 'seek') and util.safehasattr(
            fp, b'tell'
        )
        self.ui = ui
        # unbundle state attr
        self._headerdata = header