comparison mercurial/revlog.py @ 51081:5ffee3cff8de

revlog: remove the `_indexfp` method

The method is only used two time and we want to move that code to a lower level
object. So we simply inline the method to simplify further refactoring.

51080:09d60aed5f5d

        # we are done streaming.

        if self._inline:

            def get_stream():
                with self._indexfp() as fp:
                    yield None
                    size = index_size + data_size
                    if size <= 65536:
                        yield fp.read(size)
                    else:

                (self._indexfile, inline_stream, index_size + data_size),
            ]
        else:

            def get_index_stream():
                with self._indexfp() as fp:
                    yield None
                    if index_size <= 65536:
                        yield fp.read(index_size)
                    else:
                        yield from util.filechunkiter(fp, limit=index_size)

        if self._docket is None:
            return None
        t = self._docket.default_compression_header
        c = self._get_decompressor(t)
        return c.decompress

    def _indexfp(self):
        """file object for the revlog's index file"""
        return self.opener(self._indexfile, mode=b"r")

    def __index_write_fp(self):
        # You should not use this directly and use `_writing` instead
        try:
            f = self.opener(

51081:5ffee3cff8de

        # we are done streaming.

        if self._inline:

            def get_stream():
                with self.opener(self._indexfile, mode=b"r") as fp:
                    yield None
                    size = index_size + data_size
                    if size <= 65536:
                        yield fp.read(size)
                    else:

                (self._indexfile, inline_stream, index_size + data_size),
            ]
        else:

            def get_index_stream():
                with self.opener(self._indexfile, mode=b"r") as fp:
                    yield None
                    if index_size <= 65536:
                        yield fp.read(index_size)
                    else:
                        yield from util.filechunkiter(fp, limit=index_size)

        if self._docket is None:
            return None
        t = self._docket.default_compression_header
        c = self._get_decompressor(t)
        return c.decompress

    def __index_write_fp(self):
        # You should not use this directly and use `_writing` instead
        try:
            f = self.opener(