Show More
@@ -410,8 +410,7 b' class sshv1peer(wireproto.wirepeer):' | |||||
410 | work += chunk |
|
410 | work += chunk | |
411 | yield wireproto.unescapearg(work) |
|
411 | yield wireproto.unescapearg(work) | |
412 |
|
412 | |||
413 |
def _ |
|
413 | def _sendrequest(self, cmd, args): | |
414 | args = pycompat.byteskwargs(args) |
|
|||
415 | if (self.ui.debugflag |
|
414 | if (self.ui.debugflag | |
416 | and self.ui.configbool('devel', 'debug.peer-request')): |
|
415 | and self.ui.configbool('devel', 'debug.peer-request')): | |
417 | dbg = self.ui.debug |
|
416 | dbg = self.ui.debug | |
@@ -447,11 +446,17 b' class sshv1peer(wireproto.wirepeer):' | |||||
447 |
|
446 | |||
448 | return self._pipei |
|
447 | return self._pipei | |
449 |
|
448 | |||
|
449 | def _callstream(self, cmd, **args): | |||
|
450 | args = pycompat.byteskwargs(args) | |||
|
451 | return self._sendrequest(cmd, args) | |||
|
452 | ||||
450 | def _callcompressable(self, cmd, **args): |
|
453 | def _callcompressable(self, cmd, **args): | |
451 | return self._callstream(cmd, **args) |
|
454 | args = pycompat.byteskwargs(args) | |
|
455 | return self._sendrequest(cmd, args) | |||
452 |
|
456 | |||
453 | def _call(self, cmd, **args): |
|
457 | def _call(self, cmd, **args): | |
454 | self._callstream(cmd, **args) |
|
458 | args = pycompat.byteskwargs(args) | |
|
459 | self._sendrequest(cmd, args) | |||
455 | return self._readframed() |
|
460 | return self._readframed() | |
456 |
|
461 | |||
457 | def _callpush(self, cmd, fp, **args): |
|
462 | def _callpush(self, cmd, fp, **args): |
General Comments 0
You need to be logged in to leave comments.
Login now