sshpeer: also use doublepipe for client to server communication
authorPierre-Yves David <pierre-yves.david@fb.com>
Wed, 20 May 2015 11:55:59 -0500
changeset 25458 4642f0b803ae
parent 25457 2afa748138e0
child 25459 0bda5bfaf0b1
sshpeer: also use doublepipe for client to server communication This will allow even more real time output when the server issue output in the middle a stream push.
mercurial/sshpeer.py
--- a/mercurial/sshpeer.py	Fri Jun 05 04:54:23 2015 -0700
+++ b/mercurial/sshpeer.py	Wed May 20 11:55:59 2015 -0500
@@ -168,6 +168,7 @@
 
         self.pipei = util.bufferedinputpipe(self.pipei)
         self.pipei = doublepipe(self.ui, self.pipei, self.pipee)
+        self.pipeo = doublepipe(self.ui, self.pipeo, self.pipee)
 
         # skip any noise generated by remote shell
         self._callstream("hello")