Mercurial > public > mercurial-scm > hg

comparison mercurial/sshpeer.py @ 25422:8dc5ee5b7b09

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
sshpeer: use the doublepipe object for the server to client channel This restores real-time output from ssh server while waiting for protocol data sent by the server.
author Pierre-Yves David <pierre-yves.david@fb.com>
date Wed, 20 May 2015 11:41:48 -0500
parents 3dd3ccf7b807
children dc02a284e034
comparison
equal deleted inserted replaced
25421:3dd3ccf7b807 25422:8dc5ee5b7b09
158 # move to threading. 158 # move to threading.
159 sub = util.popen4(cmd, bufsize=0) 159 sub = util.popen4(cmd, bufsize=0)
160 self.pipeo, self.pipei, self.pipee, self.subprocess = sub 160 self.pipeo, self.pipei, self.pipee, self.subprocess = sub
161 161
162 self.pipei = util.bufferedinputpipe(self.pipei) 162 self.pipei = util.bufferedinputpipe(self.pipei)
163 self.pipei = doublepipe(self.ui, self.pipei, self.pipee)
163 164
164 # skip any noise generated by remote shell 165 # skip any noise generated by remote shell
165 self._callstream("hello") 166 self._callstream("hello")
166 r = self._callstream("between", pairs=("%s-%s" % ("0"*40, "0"*40))) 167 r = self._callstream("between", pairs=("%s-%s" % ("0"*40, "0"*40)))
167 lines = ["", "dummy"] 168 lines = ["", "dummy"]