Mercurial > public > mercurial-scm > hg

comparison mercurial/bundlerepo.py @ 52643:5cc8deb96b48

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
pyupgrade: modernize calls to superclass methods This is the `legacy` fixer in `pyupgrade`, with the loop yielding the offset of `yield` statements commented out.
author Matt Harbison <matt_harbison@yahoo.com>
date Sun, 05 Jan 2025 22:23:31 -0500
parents cfd30df0f8e4
children dabec69bd6fc
comparison
equal deleted inserted replaced
52642:73ab542565e0 52643:5cc8deb96b48
126 def _chunk(self, rev): 126 def _chunk(self, rev):
127 # Warning: in case of bundle, the diff is against what we stored as 127 # Warning: in case of bundle, the diff is against what we stored as
128 # delta base, not against rev - 1 128 # delta base, not against rev - 1
129 # XXX: could use some caching 129 # XXX: could use some caching
130 if rev <= self.repotiprev: 130 if rev <= self.repotiprev:
131 return super(bundlerevlog, self)._inner._chunk(rev) 131 return super()._inner._chunk(rev)
132 self.bundle.seek(self.start(rev)) 132 self.bundle.seek(self.start(rev))
133 return self.bundle.read(self.length(rev)) 133 return self.bundle.read(self.length(rev))
134 134
135 def revdiff(self, rev1, rev2): 135 def revdiff(self, rev1, rev2):
136 """return or calculate a delta between two revisions""" 136 """return or calculate a delta between two revisions"""
162 chain.append(iterrev) 162 chain.append(iterrev)
163 iterrev = self.index[iterrev][3] 163 iterrev = self.index[iterrev][3]
164 if iterrev == nullrev: 164 if iterrev == nullrev:
165 rawtext = b'' 165 rawtext = b''
166 elif rawtext is None: 166 elif rawtext is None:
167 r = super(bundlerevlog, self)._rawtext( 167 r = super()._rawtext(
168 self.node(iterrev), 168 self.node(iterrev),
169 iterrev, 169 iterrev,
170 ) 170 )
171 __, rawtext, validated = r 171 __, rawtext, validated = r
172 if chain: 172 if chain:
240 self.bundle, 240 self.bundle,
241 self._linkmapper, 241 self._linkmapper,
242 self._dirlogstarts, 242 self._dirlogstarts,
243 dir=d, 243 dir=d,
244 ) 244 )
245 return super(bundlemanifest, self).dirlog(d) 245 return super().dirlog(d)
246 246
247 247
248 class bundlefilelog(filelog.filelog): 248 class bundlefilelog(filelog.filelog):
249 def __init__(self, opener, path, cgunpacker, linkmapper): 249 def __init__(self, opener, path, cgunpacker, linkmapper):
250 filelog.filelog.__init__(self, opener, path) 250 filelog.filelog.__init__(self, opener, path)
263 return False 263 return False
264 264
265 265
266 class bundlephasecache(phases.phasecache): 266 class bundlephasecache(phases.phasecache):
267 def __init__(self, *args, **kwargs): 267 def __init__(self, *args, **kwargs):
268 super(bundlephasecache, self).__init__(*args, **kwargs) 268 super().__init__(*args, **kwargs)
269 if hasattr(self, 'opener'): 269 if hasattr(self, 'opener'):
270 self.opener = vfsmod.readonlyvfs(self.opener) 270 self.opener = vfsmod.readonlyvfs(self.opener)
271 271
272 def write(self, repo): 272 def write(self, repo):
273 raise NotImplementedError 273 raise NotImplementedError
497 if f in self._cgfilespos: 497 if f in self._cgfilespos:
498 self._cgunpacker.seek(self._cgfilespos[f]) 498 self._cgunpacker.seek(self._cgfilespos[f])
499 linkmapper = self.unfiltered().changelog.rev 499 linkmapper = self.unfiltered().changelog.rev
500 return bundlefilelog(self.svfs, f, self._cgunpacker, linkmapper) 500 return bundlefilelog(self.svfs, f, self._cgunpacker, linkmapper)
501 else: 501 else:
502 return super(bundlerepository, self).file(f) 502 return super().file(f)
503 503
504 def close(self): 504 def close(self):
505 """Close assigned bundle file immediately.""" 505 """Close assigned bundle file immediately."""
506 self._bundlefile.close() 506 self._bundlefile.close()
507 if self.tempfile is not None: 507 if self.tempfile is not None:
527 msg = _(b"setting parent to node %s that only exists in the bundle\n") 527 msg = _(b"setting parent to node %s that only exists in the bundle\n")
528 if self.changelog.repotiprev < p1rev: 528 if self.changelog.repotiprev < p1rev:
529 self.ui.warn(msg % hex(p1)) 529 self.ui.warn(msg % hex(p1))
530 if self.changelog.repotiprev < p2rev: 530 if self.changelog.repotiprev < p2rev:
531 self.ui.warn(msg % hex(p2)) 531 self.ui.warn(msg % hex(p2))
532 return super(bundlerepository, self).setparents(p1, p2) 532 return super().setparents(p1, p2)
533 533
534 534
535 def instance(ui, path, create, intents=None, createopts=None): 535 def instance(ui, path, create, intents=None, createopts=None):
536 if create: 536 if create:
537 raise error.Abort(_(b'cannot create new bundle repository')) 537 raise error.Abort(_(b'cannot create new bundle repository'))