| Alphare |
| hg-reviewers |
The value is still the same and still not treated, but now it exists one disk.
| No Linters Available |
| No Unit Test Coverage |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/cext/revlog.c (9 lines) | |||
| M | mercurial/pure/parsers.py (6 lines) | |||
| M | mercurial/revlogutils/constants.py (7 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| 7311364a7789 | d88aa87c2efa | Pierre-Yves David | May 3 2021, 12:41 PM |
| link_rev = getbe32(data + 20); | link_rev = getbe32(data + 20); | ||||
| parent_1 = getbe32(data + 24); | parent_1 = getbe32(data + 24); | ||||
| parent_2 = getbe32(data + 28); | parent_2 = getbe32(data + 28); | ||||
| c_node_id = data + 32; | c_node_id = data + 32; | ||||
| if (self->format_version == format_v1) { | if (self->format_version == format_v1) { | ||||
| sidedata_offset = 0; | sidedata_offset = 0; | ||||
| sidedata_comp_len = 0; | sidedata_comp_len = 0; | ||||
| data_comp_mode = comp_mode_inline; | |||||
| } else { | } else { | ||||
| sidedata_offset = getbe64(data + 64); | sidedata_offset = getbe64(data + 64); | ||||
| sidedata_comp_len = getbe32(data + 72); | sidedata_comp_len = getbe32(data + 72); | ||||
| data_comp_mode = data[76]; | |||||
| } | } | ||||
| data_comp_mode = comp_mode_inline; | |||||
| return Py_BuildValue(tuple_format, offset_flags, comp_len, uncomp_len, | return Py_BuildValue(tuple_format, offset_flags, comp_len, uncomp_len, | ||||
| base_rev, link_rev, parent_1, parent_2, c_node_id, | base_rev, link_rev, parent_1, parent_2, c_node_id, | ||||
| self->nodelen, sidedata_offset, sidedata_comp_len, | self->nodelen, sidedata_offset, sidedata_comp_len, | ||||
| data_comp_mode); | data_comp_mode); | ||||
| } | } | ||||
| /* | /* | ||||
| * Pack header information in binary | * Pack header information in binary | ||||
| */ | */ | ||||
| PyErr_SetString(PyExc_TypeError, "11-tuple required"); | PyErr_SetString(PyExc_TypeError, "11-tuple required"); | ||||
| return NULL; | return NULL; | ||||
| } | } | ||||
| if (c_node_id_len != self->nodelen) { | if (c_node_id_len != self->nodelen) { | ||||
| PyErr_SetString(PyExc_TypeError, "invalid node"); | PyErr_SetString(PyExc_TypeError, "invalid node"); | ||||
| return NULL; | return NULL; | ||||
| } | } | ||||
| if (data_comp_mode != comp_mode_inline) { | if (self->format_version == format_v1 && | ||||
| data_comp_mode != comp_mode_inline) { | |||||
| PyErr_Format(PyExc_ValueError, | PyErr_Format(PyExc_ValueError, | ||||
| "invalid data compression mode: %i", | "invalid data compression mode: %i", | ||||
| data_comp_mode); | data_comp_mode); | ||||
| return NULL; | return NULL; | ||||
| } | } | ||||
| if (self->new_length == self->added_length) { | if (self->new_length == self->added_length) { | ||||
| size_t new_added_length = | size_t new_added_length = | ||||
| putbe32(parent_1, data + 24); | putbe32(parent_1, data + 24); | ||||
| putbe32(parent_2, data + 28); | putbe32(parent_2, data + 28); | ||||
| memcpy(data + 32, c_node_id, c_node_id_len); | memcpy(data + 32, c_node_id, c_node_id_len); | ||||
| /* Padding since SHA-1 is only 20 bytes for now */ | /* Padding since SHA-1 is only 20 bytes for now */ | ||||
| memset(data + 32 + c_node_id_len, 0, 32 - c_node_id_len); | memset(data + 32 + c_node_id_len, 0, 32 - c_node_id_len); | ||||
| if (self->format_version == format_v2) { | if (self->format_version == format_v2) { | ||||
| putbe64(sidedata_offset, data + 64); | putbe64(sidedata_offset, data + 64); | ||||
| putbe32(sidedata_comp_len, data + 72); | putbe32(sidedata_comp_len, data + 72); | ||||
| data[76] = (char)data_comp_mode; | |||||
| /* Padding for 96 bytes alignment */ | /* Padding for 96 bytes alignment */ | ||||
| memset(data + 76, 0, self->entry_size - 76); | memset(data + 77, 0, self->entry_size - 77); | ||||
| } | } | ||||
| if (self->ntinitialized) | if (self->ntinitialized) | ||||
| nt_insert(&self->nt, c_node_id, rev); | nt_insert(&self->nt, c_node_id, rev); | ||||
| Py_CLEAR(self->headrevs); | Py_CLEAR(self->headrevs); | ||||
| Py_RETURN_NONE; | Py_RETURN_NONE; | ||||
| } | } | ||||
| entry[0] = offset_flags | entry[0] = offset_flags | ||||
| entry[8] = sidedata_offset | entry[8] = sidedata_offset | ||||
| entry[9] = sidedata_length | entry[9] = sidedata_length | ||||
| entry = tuple(entry) | entry = tuple(entry) | ||||
| new = self._pack_entry(entry) | new = self._pack_entry(entry) | ||||
| self._extra[rev - self._lgt] = new | self._extra[rev - self._lgt] = new | ||||
| def _unpack_entry(self, data): | def _unpack_entry(self, data): | ||||
| return self.index_format.unpack(data) + ( | return self.index_format.unpack(data) | ||||
| revlog_constants.COMP_MODE_INLINE, | |||||
| ) | |||||
| def _pack_entry(self, entry): | def _pack_entry(self, entry): | ||||
| return self.index_format.pack(*entry[:10]) | return self.index_format.pack(*entry[:11]) | ||||
| def entry_binary(self, rev): | def entry_binary(self, rev): | ||||
| """return the raw binary string representing a revision""" | """return the raw binary string representing a revision""" | ||||
| entry = self[rev] | entry = self[rev] | ||||
| return self._pack_entry(entry) | return self._pack_entry(entry) | ||||
| def pack_header(self, header): | def pack_header(self, header): | ||||
| """pack header information as binary""" | """pack header information as binary""" | ||||
| # 4 bytes: uncompressed length | # 4 bytes: uncompressed length | ||||
| # 4 bytes: base rev | # 4 bytes: base rev | ||||
| # 4 bytes: link rev | # 4 bytes: link rev | ||||
| # 4 bytes: parent 1 rev | # 4 bytes: parent 1 rev | ||||
| # 4 bytes: parent 2 rev | # 4 bytes: parent 2 rev | ||||
| # 32 bytes: nodeid | # 32 bytes: nodeid | ||||
| # 8 bytes: sidedata offset | # 8 bytes: sidedata offset | ||||
| # 4 bytes: sidedata compressed length | # 4 bytes: sidedata compressed length | ||||
| # 20 bytes: Padding to align to 96 bytes (see RevlogV2Plan wiki page) | # 1 bytes: compression mode (2 lower bit are data_compression_mode) | ||||
| INDEX_ENTRY_V2 = struct.Struct(b">Qiiiiii20s12xQi20x") | # 19 bytes: Padding to align to 96 bytes (see RevlogV2Plan wiki page) | ||||
| assert INDEX_ENTRY_V2.size == 32 * 3 | INDEX_ENTRY_V2 = struct.Struct(b">Qiiiiii20s12xQiB19x") | ||||
| assert INDEX_ENTRY_V2.size == 32 * 3, INDEX_ENTRY_V2.size | |||||
| # revlog index flags | # revlog index flags | ||||
| # For historical reasons, revlog's internal flags were exposed via the | # For historical reasons, revlog's internal flags were exposed via the | ||||
| # wire protocol and are even exposed in parts of the storage APIs. | # wire protocol and are even exposed in parts of the storage APIs. | ||||
| # revision has censor metadata, must be verified | # revision has censor metadata, must be verified | ||||
| REVIDX_ISCENSORED = repository.REVISION_FLAG_CENSORED | REVIDX_ISCENSORED = repository.REVISION_FLAG_CENSORED | ||||