comparison mercurial/revlog.py @ 47037:d57386e5c80e

revlog: have an explicit "pack_header" method

Having to pass the version header when retrieving the binary version of every
single entry is a bit silly. So we extract that special logic in its own method.
This also prepare the move to newer revlog format, not storing the header within
an actual entry…

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

47036:5e64c93d5f94

    def __getitem__(self, i):
        if i == -1:
            return (0, 0, 0, -1, -1, -1, -1, sha1nodeconstants.nullid)
        return list.__getitem__(self, i)

    def entry_binary(self, rev, header):
        """return the raw binary string representing a revision"""
        entry = self[rev]
        if gettype(entry[0]):
            raise error.RevlogError(
                _(b'index entry flags need revlog version 1')

            self[entry[5]][7],
            self[entry[6]][7],
            entry[7],
        )
        return INDEX_ENTRY_V0.pack(*e2)


def parse_index_v0(data, inline):
    s = INDEX_ENTRY_V0.size
    index = []

        with self._indexfp(b'w') as fp:
            self.version &= ~FLAG_INLINE_DATA
            self._inline = False
            for i in self:
                e = self.index.entry_binary(i, self.version)
                fp.write(e)

            # the temp file replace the real index when we exit the context
            # manager

        if self.version & 0xFFFF != REVLOGV2:
            e = e[:8]

        self.index.append(e)
        entry = self.index.entry_binary(curr, self.version)
        self._writeentry(
            transaction,
            ifh,
            dfh,
            entry,

        with self._indexfp(b'w+') as fp:
            fp.seek(startrev * self.index.entry_size)
            for i, entry in enumerate(new_entries):
                rev = startrev + i
                self.index.replace_sidedata_info(rev, entry[8], entry[9])
                packed = self.index.entry_binary(rev, self.version)
                fp.write(packed)

47037:d57386e5c80e

    def __getitem__(self, i):
        if i == -1:
            return (0, 0, 0, -1, -1, -1, -1, sha1nodeconstants.nullid)
        return list.__getitem__(self, i)

    def entry_binary(self, rev):
        """return the raw binary string representing a revision"""
        entry = self[rev]
        if gettype(entry[0]):
            raise error.RevlogError(
                _(b'index entry flags need revlog version 1')

            self[entry[5]][7],
            self[entry[6]][7],
            entry[7],
        )
        return INDEX_ENTRY_V0.pack(*e2)

    def pack_header(self, header):
        """Pack header information in binary"""
        return b''


def parse_index_v0(data, inline):
    s = INDEX_ENTRY_V0.size
    index = []

        with self._indexfp(b'w') as fp:
            self.version &= ~FLAG_INLINE_DATA
            self._inline = False
            for i in self:
                e = self.index.entry_binary(i)
                if i == 0:
                    header = self.index.pack_header(self.version)
                    e = header + e
                fp.write(e)

            # the temp file replace the real index when we exit the context
            # manager

        if self.version & 0xFFFF != REVLOGV2:
            e = e[:8]

        self.index.append(e)
        entry = self.index.entry_binary(curr)
        if curr == 0:
            header = self.index.pack_header(self.version)
            entry = header + entry
        self._writeentry(
            transaction,
            ifh,
            dfh,
            entry,

        with self._indexfp(b'w+') as fp:
            fp.seek(startrev * self.index.entry_size)
            for i, entry in enumerate(new_entries):
                rev = startrev + i
                self.index.replace_sidedata_info(rev, entry[8], entry[9])
                packed = self.index.entry_binary(rev)
                if rev == 0:
                    header = self.index.pack_header(self.version)
                    packed = header + packed
                fp.write(packed)