##// END OF EJS Templates
wrapfunction: use sysstr instead of bytes as argument in "remotefilelog"...
marmoute -
r51682:cbd1da10 default
parent child Browse files
Show More
@@ -317,31 +317,31 b' def uisetup(ui):'
317 317 changegroup.cgpacker = shallowbundle.shallowcg1packer
318 318
319 319 extensions.wrapfunction(
320 changegroup, b'_addchangegroupfiles', shallowbundle.addchangegroupfiles
320 changegroup, '_addchangegroupfiles', shallowbundle.addchangegroupfiles
321 321 )
322 322 extensions.wrapfunction(
323 changegroup, b'makechangegroup', shallowbundle.makechangegroup
323 changegroup, 'makechangegroup', shallowbundle.makechangegroup
324 324 )
325 extensions.wrapfunction(localrepo, b'makestore', storewrapper)
326 extensions.wrapfunction(exchange, b'pull', exchangepull)
327 extensions.wrapfunction(merge, b'applyupdates', applyupdates)
328 extensions.wrapfunction(merge, b'_checkunknownfiles', checkunknownfiles)
329 extensions.wrapfunction(context.workingctx, b'_checklookup', checklookup)
330 extensions.wrapfunction(scmutil, b'_findrenames', findrenames)
325 extensions.wrapfunction(localrepo, 'makestore', storewrapper)
326 extensions.wrapfunction(exchange, 'pull', exchangepull)
327 extensions.wrapfunction(merge, 'applyupdates', applyupdates)
328 extensions.wrapfunction(merge, '_checkunknownfiles', checkunknownfiles)
329 extensions.wrapfunction(context.workingctx, '_checklookup', checklookup)
330 extensions.wrapfunction(scmutil, '_findrenames', findrenames)
331 331 extensions.wrapfunction(
332 copies, b'_computeforwardmissing', computeforwardmissing
332 copies, '_computeforwardmissing', computeforwardmissing
333 333 )
334 extensions.wrapfunction(dispatch, b'runcommand', runcommand)
335 extensions.wrapfunction(repair, b'_collectbrokencsets', _collectbrokencsets)
336 extensions.wrapfunction(context.changectx, b'filectx', filectx)
337 extensions.wrapfunction(context.workingctx, b'filectx', workingfilectx)
338 extensions.wrapfunction(patch, b'trydiff', trydiff)
339 extensions.wrapfunction(hg, b'verify', _verify)
334 extensions.wrapfunction(dispatch, 'runcommand', runcommand)
335 extensions.wrapfunction(repair, '_collectbrokencsets', _collectbrokencsets)
336 extensions.wrapfunction(context.changectx, 'filectx', filectx)
337 extensions.wrapfunction(context.workingctx, 'filectx', workingfilectx)
338 extensions.wrapfunction(patch, 'trydiff', trydiff)
339 extensions.wrapfunction(hg, 'verify', _verify)
340 340 scmutil.fileprefetchhooks.add(b'remotefilelog', _fileprefetchhook)
341 341
342 342 # disappointing hacks below
343 extensions.wrapfunction(scmutil, b'getrenamedfn', getrenamedfn)
344 extensions.wrapfunction(revset, b'filelog', filelogrevset)
343 extensions.wrapfunction(scmutil, 'getrenamedfn', getrenamedfn)
344 extensions.wrapfunction(revset, 'filelog', filelogrevset)
345 345 revset.symbols[b'filelog'] = revset.filelog
346 346
347 347
@@ -374,7 +374,7 b' def cloneshallow(orig, ui, repo, *args, '
374 374 else:
375 375 return orig(self, *args, **kwargs)
376 376
377 extensions.wrapfunction(exchange, b'pull', pull_shallow)
377 extensions.wrapfunction(exchange, 'pull', pull_shallow)
378 378
379 379 # Wrap the stream logic to add requirements and to pass include/exclude
380 380 # patterns around.
@@ -393,14 +393,14 b' def cloneshallow(orig, ui, repo, *args, '
393 393 else:
394 394 return orig()
395 395
396 extensions.wrapfunction(remote, b'stream_out', stream_out_shallow)
396 extensions.wrapfunction(remote, 'stream_out', stream_out_shallow)
397 397
398 398 def stream_wrap(orig, op):
399 399 setup_streamout(op.repo, op.remote)
400 400 return orig(op)
401 401
402 402 extensions.wrapfunction(
403 streamclone, b'maybeperformlegacystreamclone', stream_wrap
403 streamclone, 'maybeperformlegacystreamclone', stream_wrap
404 404 )
405 405
406 406 def canperformstreamclone(orig, pullop, bundle2=False):
@@ -417,7 +417,7 b' def cloneshallow(orig, ui, repo, *args, '
417 417 return supported, requirements
418 418
419 419 extensions.wrapfunction(
420 streamclone, b'canperformstreamclone', canperformstreamclone
420 streamclone, 'canperformstreamclone', canperformstreamclone
421 421 )
422 422
423 423 try:
@@ -721,7 +721,7 b' def onetimeclientsetup(ui):'
721 721 )
722 722
723 723 extensions.wrapfunction(
724 remotefilelog.remotefilelog, b'addrawrevision', addrawrevision
724 remotefilelog.remotefilelog, 'addrawrevision', addrawrevision
725 725 )
726 726
727 727 def changelogadd(orig, self, *args, **kwargs):
@@ -749,7 +749,7 b' def onetimeclientsetup(ui):'
749 749 del pendingfilecommits[:]
750 750 return node
751 751
752 extensions.wrapfunction(changelog.changelog, b'add', changelogadd)
752 extensions.wrapfunction(changelog.changelog, 'add', changelogadd)
753 753
754 754
755 755 def getrenamedfn(orig, repo, endrev=None):
@@ -1083,7 +1083,7 b' def exchangepull(orig, repo, remote, *ar'
1083 1083 if util.safehasattr(remote, b'_callstream'):
1084 1084 remote._localrepo = repo
1085 1085 elif util.safehasattr(remote, b'getbundle'):
1086 extensions.wrapfunction(remote, b'getbundle', localgetbundle)
1086 extensions.wrapfunction(remote, 'getbundle', localgetbundle)
1087 1087
1088 1088 return orig(repo, remote, *args, **kwargs)
1089 1089
@@ -67,7 +67,7 b' def setupserver(ui, repo):'
67 67 )
68 68
69 69 extensions.wrapfunction(
70 changegroup.cgpacker, b'generatefiles', generatefiles
70 changegroup.cgpacker, 'generatefiles', generatefiles
71 71 )
72 72
73 73
@@ -207,7 +207,7 b' def onetimesetup(ui):'
207 207 ):
208 208 yield x
209 209
210 extensions.wrapfunction(streamclone, b'_walkstreamfiles', _walkstreamfiles)
210 extensions.wrapfunction(streamclone, '_walkstreamfiles', _walkstreamfiles)
211 211
212 212 # expose remotefilelog capabilities
213 213 def _capabilities(orig, repo, proto):
@@ -222,7 +222,7 b' def onetimesetup(ui):'
222 222 caps.append(b'x_rfl_getfile')
223 223 return caps
224 224
225 extensions.wrapfunction(wireprotov1server, b'_capabilities', _capabilities)
225 extensions.wrapfunction(wireprotov1server, '_capabilities', _capabilities)
226 226
227 227 def _adjustlinkrev(orig, self, *args, **kwargs):
228 228 # When generating file blobs, taking the real path is too slow on large
@@ -233,7 +233,7 b' def onetimesetup(ui):'
233 233 return orig(self, *args, **kwargs)
234 234
235 235 extensions.wrapfunction(
236 context.basefilectx, b'_adjustlinkrev', _adjustlinkrev
236 context.basefilectx, '_adjustlinkrev', _adjustlinkrev
237 237 )
238 238
239 239 def _iscmd(orig, cmd):
@@ -241,7 +241,7 b' def onetimesetup(ui):'
241 241 return False
242 242 return orig(cmd)
243 243
244 extensions.wrapfunction(wireprotoserver, b'iscmd', _iscmd)
244 extensions.wrapfunction(wireprotoserver, 'iscmd', _iscmd)
245 245
246 246
247 247 def _loadfileblob(repo, cachepath, path, node):
General Comments 0
You need to be logged in to leave comments. Login now