comparison mercurial/revlog.py @ 46710:4cd214c9948d

revlogv2: don't assume that the sidedata of the last rev is right after data

We are going to be rewriting sidedata soon, it's going to be appended to the
revlog data file, meaning that the data and the sidedata might not be
contiguous.

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

46709:3d740058b467

            raise

    # Derived from index values.

    def end(self, rev):
        return self.start(rev) + self.length(rev) + self.sidedata_length(rev)

    def parents(self, node):
        i = self.index
        d = i[self.rev(node)]
        return i[d[5]][7], i[d[6]][7]  # map revisions to nodes inline

        btext = [rawtext]

        curr = len(self)
        prev = curr - 1
        offset = self.end(prev)

        if self._concurrencychecker:
            if self._inline:
                # offset is "as if" it were in the .d file, so we need to add on
                # the size of the entry metadata.

        if type(rawtext) == bytes:  # only accept immutable objects
            self._revisioncache = (node, curr, rawtext)
        self._chainbasecache[curr] = deltainfo.chainbase
        return curr

    def _writeentry(
        self, transaction, ifh, dfh, entry, data, link, offset, sidedata
    ):
        # Files opened in a+ mode have inconsistent behavior on various

46710:4cd214c9948d

            raise

    # Derived from index values.

    def end(self, rev):
        return self.start(rev) + self.length(rev)

    def parents(self, node):
        i = self.index
        d = i[self.rev(node)]
        return i[d[5]][7], i[d[6]][7]  # map revisions to nodes inline

        btext = [rawtext]

        curr = len(self)
        prev = curr - 1

        offset = self._get_data_offset(prev)

        if self._concurrencychecker:
            if self._inline:
                # offset is "as if" it were in the .d file, so we need to add on
                # the size of the entry metadata.

        if type(rawtext) == bytes:  # only accept immutable objects
            self._revisioncache = (node, curr, rawtext)
        self._chainbasecache[curr] = deltainfo.chainbase
        return curr

    def _get_data_offset(self, prev):
        """Returns the current offset in the (in-transaction) data file.
        Versions < 2 of the revlog can get this 0(1), revlog v2 needs a docket
        file to store that information: since sidedata can be rewritten to the
        end of the data file within a transaction, you can have cases where, for
        example, rev `n` does not have sidedata while rev `n - 1` does, leading
        to `n - 1`'s sidedata being written after `n`'s data.

        TODO cache this in a docket file before getting out of experimental."""
        if self.version & 0xFFFF != REVLOGV2:
            return self.end(prev)

        offset = 0
        for rev, entry in enumerate(self.index):
            sidedata_end = entry[8] + entry[9]
            # Sidedata for a previous rev has potentially been written after
            # this rev's end, so take the max.
            offset = max(self.end(rev), offset, sidedata_end)
        return offset

    def _writeentry(
        self, transaction, ifh, dfh, entry, data, link, offset, sidedata
    ):
        # Files opened in a+ mode have inconsistent behavior on various