| hg-reviewers |
This seems like generic functionality we'll want to use from
non-revlog storage backends.
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/revlog.py (6 lines) | |||
| M | mercurial/utils/storageutil.py (4 lines) |
| return False | return False | ||||
| ellipsisprocessor = ( | ellipsisprocessor = ( | ||||
| ellipsisreadprocessor, | ellipsisreadprocessor, | ||||
| ellipsiswriteprocessor, | ellipsiswriteprocessor, | ||||
| ellipsisrawprocessor, | ellipsisrawprocessor, | ||||
| ) | ) | ||||
| def _censoredtext(text): | |||||
| m, offs = storageutil.parsemeta(text) | |||||
| return m and "censored" in m | |||||
| def addflagprocessor(flag, processor): | def addflagprocessor(flag, processor): | ||||
| """Register a flag processor on a revision data flag. | """Register a flag processor on a revision data flag. | ||||
| Invariant: | Invariant: | ||||
| - Flags need to be defined in REVIDX_KNOWN_FLAGS and REVIDX_FLAGS_ORDER, | - Flags need to be defined in REVIDX_KNOWN_FLAGS and REVIDX_FLAGS_ORDER, | ||||
| and REVIDX_RAWTEXT_CHANGING_FLAGS if they can alter rawtext. | and REVIDX_RAWTEXT_CHANGING_FLAGS if they can alter rawtext. | ||||
| - Only one flag processor can be registered on a specific flag. | - Only one flag processor can be registered on a specific flag. | ||||
| - flagprocessors must be 3-tuples of functions (read, write, raw) with the | - flagprocessors must be 3-tuples of functions (read, write, raw) with the | ||||
| p1, p2 = self.parents(node) | p1, p2 = self.parents(node) | ||||
| if node != self.hash(text, p1, p2): | if node != self.hash(text, p1, p2): | ||||
| revornode = rev | revornode = rev | ||||
| if revornode is None: | if revornode is None: | ||||
| revornode = templatefilters.short(hex(node)) | revornode = templatefilters.short(hex(node)) | ||||
| raise error.RevlogError(_("integrity check failed on %s:%s") | raise error.RevlogError(_("integrity check failed on %s:%s") | ||||
| % (self.indexfile, pycompat.bytestr(revornode))) | % (self.indexfile, pycompat.bytestr(revornode))) | ||||
| except error.RevlogError: | except error.RevlogError: | ||||
| if self._censorable and _censoredtext(text): | if self._censorable and storageutil.iscensoredtext(text): | ||||
| raise error.CensoredNodeError(self.indexfile, node, text) | raise error.CensoredNodeError(self.indexfile, node, text) | ||||
| raise | raise | ||||
| def _enforceinlinesize(self, tr, fp=None): | def _enforceinlinesize(self, tr, fp=None): | ||||
| """Check if the revlog is too big for inline and convert if so. | """Check if the revlog is too big for inline and convert if so. | ||||
| This should be called after revisions are added to the revlog. If the | This should be called after revisions are added to the revlog. If the | ||||
| revlog has grown too large to be an inline revlog, it will convert it | revlog has grown too large to be an inline revlog, it will convert it | ||||
| meta[k] = v | meta[k] = v | ||||
| return meta, s + 2 | return meta, s + 2 | ||||
| def packmeta(meta, text): | def packmeta(meta, text): | ||||
| """Add metadata to fulltext to produce revision text.""" | """Add metadata to fulltext to produce revision text.""" | ||||
| keys = sorted(meta) | keys = sorted(meta) | ||||
| metatext = b''.join(b'%s: %s\n' % (k, meta[k]) for k in keys) | metatext = b''.join(b'%s: %s\n' % (k, meta[k]) for k in keys) | ||||
| return b'\x01\n%s\x01\n%s' % (metatext, text) | return b'\x01\n%s\x01\n%s' % (metatext, text) | ||||
| def iscensoredtext(text): | |||||
| meta = parsemeta(text)[0] | |||||
| return meta and b'censored' in meta | |||||