Show More
@@ -313,6 +313,7 b' class wirepeer(repository.legacypeer):' | |||||
313 | return self._callstream('stream_out') |
|
313 | return self._callstream('stream_out') | |
314 |
|
314 | |||
315 | def getbundle(self, source, **kwargs): |
|
315 | def getbundle(self, source, **kwargs): | |
|
316 | kwargs = pycompat.byteskwargs(kwargs) | |||
316 | self.requirecap('getbundle', _('look up remote changes')) |
|
317 | self.requirecap('getbundle', _('look up remote changes')) | |
317 | opts = {} |
|
318 | opts = {} | |
318 | bundlecaps = kwargs.get('bundlecaps') |
|
319 | bundlecaps = kwargs.get('bundlecaps') | |
@@ -337,7 +338,7 b' class wirepeer(repository.legacypeer):' | |||||
337 | raise KeyError('unknown getbundle option type %s' |
|
338 | raise KeyError('unknown getbundle option type %s' | |
338 | % keytype) |
|
339 | % keytype) | |
339 | opts[key] = value |
|
340 | opts[key] = value | |
340 | f = self._callcompressable("getbundle", **opts) |
|
341 | f = self._callcompressable("getbundle", **pycompat.strkwargs(opts)) | |
341 | if any((cap.startswith('HG2') for cap in bundlecaps)): |
|
342 | if any((cap.startswith('HG2') for cap in bundlecaps)): | |
342 | return bundle2.getunbundler(self.ui, f) |
|
343 | return bundle2.getunbundler(self.ui, f) | |
343 | else: |
|
344 | else: | |
@@ -444,7 +445,7 b' class wirepeer(repository.legacypeer):' | |||||
444 | yield unescapearg(''.join(work)) |
|
445 | yield unescapearg(''.join(work)) | |
445 |
|
446 | |||
446 | def _submitone(self, op, args): |
|
447 | def _submitone(self, op, args): | |
447 | return self._call(op, **args) |
|
448 | return self._call(op, **pycompat.strkwargs(args)) | |
448 |
|
449 | |||
449 | def debugwireargs(self, one, two, three=None, four=None, five=None): |
|
450 | def debugwireargs(self, one, two, three=None, four=None, five=None): | |
450 | # don't pass optional arguments left at their default value |
|
451 | # don't pass optional arguments left at their default value |
General Comments 0
You need to be logged in to leave comments.
Login now