Mercurial > hg
changeset 51026:8520db304f01
revlog: drop more file description passing between private function
They are no longer used as we are covered by the `reading` context
author | Pierre-Yves David <pierre-yves.david@octobus.net> |
---|---|
date | Tue, 26 Sep 2023 02:54:50 +0200 |
parents | 9011c38b4f65 |
children | 3314c41c3759 |
files | mercurial/bundlerepo.py mercurial/revlog.py mercurial/unionrepo.py |
diffstat | 3 files changed, 19 insertions(+), 18 deletions(-) [+] |
line wrap: on
line diff
--- a/mercurial/bundlerepo.py Tue Sep 26 02:49:18 2023 +0200 +++ b/mercurial/bundlerepo.py Tue Sep 26 02:54:50 2023 +0200 @@ -117,7 +117,7 @@ with super().reading() as x: yield x - def _chunk(self, rev, df=None): + def _chunk(self, rev): # Warning: in case of bundle, the diff is against what we stored as # delta base, not against rev - 1 # XXX: could use some caching @@ -138,7 +138,7 @@ return mdiff.textdiff(self.rawdata(rev1), self.rawdata(rev2)) - def _rawtext(self, node, rev, _df=None): + def _rawtext(self, node, rev): if rev is None: rev = self.rev(node) validated = False @@ -156,7 +156,8 @@ rawtext = b'' elif rawtext is None: r = super(bundlerevlog, self)._rawtext( - self.node(iterrev), iterrev, _df=_df + self.node(iterrev), + iterrev, ) __, rawtext, validated = r if chain:
--- a/mercurial/revlog.py Tue Sep 26 02:49:18 2023 +0200 +++ b/mercurial/revlog.py Tue Sep 26 02:54:50 2023 +0200 @@ -1771,7 +1771,7 @@ p1, p2 = self.parents(node) return storageutil.hashrevisionsha1(text, p1, p2) != node - def _getsegmentforrevs(self, startrev, endrev, df=None): + def _getsegmentforrevs(self, startrev, endrev): """Obtain a segment of raw data corresponding to a range of revisions. Accepts the start and end revisions and an optional already-open @@ -1803,9 +1803,9 @@ end += (endrev + 1) * self.index.entry_size length = end - start - return start, self._segmentfile.read_chunk(start, length, df) - - def _chunk(self, rev, df=None): + return start, self._segmentfile.read_chunk(start, length) + + def _chunk(self, rev): """Obtain a single decompressed chunk for a revision. Accepts an integer revision and an optional already-open file handle @@ -1815,7 +1815,7 @@ Returns a str holding uncompressed data for the requested revision. """ compression_mode = self.index[rev][10] - data = self._getsegmentforrevs(rev, rev, df=df)[1] + data = self._getsegmentforrevs(rev, rev)[1] if compression_mode == COMP_MODE_PLAIN: return data elif compression_mode == COMP_MODE_DEFAULT: @@ -1827,7 +1827,7 @@ msg %= compression_mode raise error.RevlogError(msg) - def _chunks(self, revs, df=None, targetsize=None): + def _chunks(self, revs, targetsize=None): """Obtain decompressed chunks for the specified revisions. Accepts an iterable of numeric revisions that are assumed to be in @@ -1866,11 +1866,11 @@ break try: - offset, data = self._getsegmentforrevs(firstrev, lastrev, df=df) + offset, data = self._getsegmentforrevs(firstrev, lastrev) except OverflowError: # issue4215 - we can't cache a run of chunks greater than # 2G on Windows - return [self._chunk(rev, df=df) for rev in revschunk] + return [self._chunk(rev) for rev in revschunk] decomp = self.decompress # self._decompressor might be None, but will not be used in that case @@ -1974,7 +1974,7 @@ rev = self.rev(nodeorrev) return self._sidedata(rev) - def _revisiondata(self, nodeorrev, _df=None, raw=False): + def _revisiondata(self, nodeorrev, raw=False): # deal with <nodeorrev> argument type if isinstance(nodeorrev, int): rev = nodeorrev @@ -1989,7 +1989,7 @@ # ``rawtext`` is the text as stored inside the revlog. Might be the # revision or might need to be processed to retrieve the revision. - rev, rawtext, validated = self._rawtext(node, rev, _df=_df) + rev, rawtext, validated = self._rawtext(node, rev) if raw and validated: # if we don't want to process the raw text and that raw @@ -2018,7 +2018,7 @@ return text - def _rawtext(self, node, rev, _df=None): + def _rawtext(self, node, rev): """return the possibly unvalidated rawtext for a revision returns (rev, rawtext, validated) @@ -2052,7 +2052,7 @@ if 0 <= rawsize: targetsize = 4 * rawsize - bins = self._chunks(chain, df=_df, targetsize=targetsize) + bins = self._chunks(chain, targetsize=targetsize) if basetext is None: basetext = bytes(bins[0]) bins = bins[1:]
--- a/mercurial/unionrepo.py Tue Sep 26 02:49:18 2023 +0200 +++ b/mercurial/unionrepo.py Tue Sep 26 02:54:50 2023 +0200 @@ -127,7 +127,7 @@ with read_1(), read_2(): yield - def _chunk(self, rev, df=None): + def _chunk(self, rev): if rev <= self.repotiprev: return revlog.revlog._chunk(self, rev) return self.revlog2._chunk(self.node(rev)) @@ -144,7 +144,7 @@ return mdiff.textdiff(self.rawdata(rev1), self.rawdata(rev2)) - def _revisiondata(self, nodeorrev, _df=None, raw=False): + def _revisiondata(self, nodeorrev, raw=False): if isinstance(nodeorrev, int): rev = nodeorrev node = self.node(rev) @@ -158,7 +158,7 @@ func = revlog2._revisiondata else: func = super(unionrevlog, self)._revisiondata - return func(node, _df=_df, raw=raw) + return func(node, raw=raw) def addrevision( self,