| indygreg | |
| Alphare |
| hg-reviewers |
This is not used anywhere.
| No Linters Available |
| No Unit Test Coverage |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/revlog.py (9 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| afc29816fd82 | 4d784388ed49 | Pierre-Yves David | May 3 2021, 6:25 AM |
| if self._inline: | if self._inline: | ||||
| transaction.add(self._indexfile, end + isize) | transaction.add(self._indexfile, end + isize) | ||||
| dfh = None | dfh = None | ||||
| else: | else: | ||||
| transaction.add(self._indexfile, isize) | transaction.add(self._indexfile, isize) | ||||
| transaction.add(self._datafile, end) | transaction.add(self._datafile, end) | ||||
| dfh = self._datafp(b"a+") | dfh = self._datafp(b"a+") | ||||
| def flush(): | |||||
| if dfh: | |||||
| dfh.flush() | |||||
| ifh.flush() | |||||
| self._writinghandles = (ifh, dfh) | self._writinghandles = (ifh, dfh) | ||||
| empty = True | empty = True | ||||
| try: | try: | ||||
| deltacomputer = deltautil.deltacomputer(self) | deltacomputer = deltautil.deltacomputer(self) | ||||
| # loop through our set of deltas | # loop through our set of deltas | ||||
| for data in deltas: | for data in deltas: | ||||
| node, p1, p2, linknode, deltabase, delta, flags, sidedata = data | node, p1, p2, linknode, deltabase, delta, flags, sidedata = data | ||||
| hlen = struct.calcsize(b">lll") | hlen = struct.calcsize(b">lll") | ||||
| oldlen = self.rawsize(baserev) | oldlen = self.rawsize(baserev) | ||||
| newlen = len(delta) - hlen | newlen = len(delta) - hlen | ||||
| if delta[:hlen] != mdiff.replacediffheader(oldlen, newlen): | if delta[:hlen] != mdiff.replacediffheader(oldlen, newlen): | ||||
| raise error.CensoredBaseError( | raise error.CensoredBaseError( | ||||
| self.display_id, self.node(baserev) | self.display_id, self.node(baserev) | ||||
| ) | ) | ||||
| if not flags and self._peek_iscensored(baserev, delta, flush): | if not flags and self._peek_iscensored(baserev, delta): | ||||
| flags |= REVIDX_ISCENSORED | flags |= REVIDX_ISCENSORED | ||||
| # We assume consumers of addrevisioncb will want to retrieve | # We assume consumers of addrevisioncb will want to retrieve | ||||
| # the added revision, which will require a call to | # the added revision, which will require a call to | ||||
| # revision(). revision() will fast path if there is a cache | # revision(). revision() will fast path if there is a cache | ||||
| # hit. So, we tell _addrevision() to always cache in this case. | # hit. So, we tell _addrevision() to always cache in this case. | ||||
| # We're only using addgroup() in the context of changegroup | # We're only using addgroup() in the context of changegroup | ||||
| # generation so the revision data can always be handled as raw | # generation so the revision data can always be handled as raw | ||||
| def iscensored(self, rev): | def iscensored(self, rev): | ||||
| """Check if a file revision is censored.""" | """Check if a file revision is censored.""" | ||||
| if not self._censorable: | if not self._censorable: | ||||
| return False | return False | ||||
| return self.flags(rev) & REVIDX_ISCENSORED | return self.flags(rev) & REVIDX_ISCENSORED | ||||
| def _peek_iscensored(self, baserev, delta, flush): | def _peek_iscensored(self, baserev, delta): | ||||
| """Quickly check if a delta produces a censored revision.""" | """Quickly check if a delta produces a censored revision.""" | ||||
| if not self._censorable: | if not self._censorable: | ||||
| return False | return False | ||||
| return storageutil.deltaiscensored(delta, baserev, self.rawsize) | return storageutil.deltaiscensored(delta, baserev, self.rawsize) | ||||
| def getstrippoint(self, minlink): | def getstrippoint(self, minlink): | ||||
| """find the minimum rev that must be stripped to strip the linkrev | """find the minimum rev that must be stripped to strip the linkrev | ||||