Mercurial > hg
comparison mercurial/sshpeer.py @ 25458:4642f0b803ae
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.
| author | Pierre-Yves David <pierre-yves.david@fb.com> |
|---|---|
| date | Wed, 20 May 2015 11:55:59 -0500 |
| parents | 2afa748138e0 |
| children | de7a3893ee65 |
comparison
equal
deleted
inserted
replaced
| 25457:2afa748138e0 | 25458:4642f0b803ae |
|---|---|
| 166 sub = util.popen4(cmd, bufsize=0) | 166 sub = util.popen4(cmd, bufsize=0) |
| 167 self.pipeo, self.pipei, self.pipee, self.subprocess = sub | 167 self.pipeo, self.pipei, self.pipee, self.subprocess = sub |
| 168 | 168 |
| 169 self.pipei = util.bufferedinputpipe(self.pipei) | 169 self.pipei = util.bufferedinputpipe(self.pipei) |
| 170 self.pipei = doublepipe(self.ui, self.pipei, self.pipee) | 170 self.pipei = doublepipe(self.ui, self.pipei, self.pipee) |
| 171 self.pipeo = doublepipe(self.ui, self.pipeo, self.pipee) | |
| 171 | 172 |
| 172 # skip any noise generated by remote shell | 173 # skip any noise generated by remote shell |
| 173 self._callstream("hello") | 174 self._callstream("hello") |
| 174 r = self._callstream("between", pairs=("%s-%s" % ("0"*40, "0"*40))) | 175 r = self._callstream("between", pairs=("%s-%s" % ("0"*40, "0"*40))) |
| 175 lines = ["", "dummy"] | 176 lines = ["", "dummy"] |