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,