| indygreg | |
| Alphare |
| hg-reviewers |
We don't need to rebuild the full entry. So lets just gather the data we need
to pass to replace_sidedata_info.
| No Linters Available |
| No Unit Test Coverage |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/revlog.py (11 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| 296270a2166a | 14538a180393 | Pierre-Yves David | May 3 2021, 5:45 PM |
| # supported yet, because it introduces garbage data in the | # supported yet, because it introduces garbage data in the | ||||
| # revlog. | # revlog. | ||||
| msg = b"rewriting existing sidedata is not supported yet" | msg = b"rewriting existing sidedata is not supported yet" | ||||
| raise error.Abort(msg) | raise error.Abort(msg) | ||||
| # Apply (potential) flags to add and to remove after running | # Apply (potential) flags to add and to remove after running | ||||
| # the sidedata helpers | # the sidedata helpers | ||||
| new_offset_flags = entry[0] | flags[0] & ~flags[1] | new_offset_flags = entry[0] | flags[0] & ~flags[1] | ||||
| entry = (new_offset_flags,) + entry[1:8] | entry_update = ( | ||||
| entry += (current_offset, len(serialized_sidedata)) | current_offset, | ||||
| len(serialized_sidedata), | |||||
| new_offset_flags, | |||||
| ) | |||||
| # the sidedata computation might have move the file cursors around | # the sidedata computation might have move the file cursors around | ||||
| dfh.seek(current_offset, os.SEEK_SET) | dfh.seek(current_offset, os.SEEK_SET) | ||||
| dfh.write(serialized_sidedata) | dfh.write(serialized_sidedata) | ||||
| new_entries.append(entry) | new_entries.append(entry_update) | ||||
| current_offset += len(serialized_sidedata) | current_offset += len(serialized_sidedata) | ||||
| if self._docket is not None: | if self._docket is not None: | ||||
| self._docket.data_end = dfh.tell() | self._docket.data_end = dfh.tell() | ||||
| # rewrite the new index entries | # rewrite the new index entries | ||||
| ifh.seek(startrev * self.index.entry_size) | ifh.seek(startrev * self.index.entry_size) | ||||
| for i, e in enumerate(new_entries): | for i, e in enumerate(new_entries): | ||||
| rev = startrev + i | rev = startrev + i | ||||
| self.index.replace_sidedata_info(rev, e[8], e[9], e[0]) | self.index.replace_sidedata_info(rev, *e) | ||||
| packed = self.index.entry_binary(rev) | packed = self.index.entry_binary(rev) | ||||
| if rev == 0 and self._docket is None: | if rev == 0 and self._docket is None: | ||||
| header = self._format_flags | self._format_version | header = self._format_flags | self._format_version | ||||
| header = self.index.pack_header(header) | header = self.index.pack_header(header) | ||||
| packed = header + packed | packed = header + packed | ||||
| ifh.write(packed) | ifh.write(packed) | ||||