##// END OF EJS Templates
sshpeer: move logic for sending a request into a new function...
Gregory Szorc -
r36384:a34d5ef5 default
parent child Browse files
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 _callstream(self, cmd, **args):
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