facebook/sapling
1
1
Fork 0
mirror of https://github.com/facebook/sapling.git synced 2024-10-06 23:07:18 +03:00
Code Issues Projects Releases Wiki Activity

sshpeer: extract the forward output logic

Browse Source 
We are about to make a more aggressive use of this when reading and writing on
the other pipes. We it needs to be reusable.
This commit is contained in:
Pierre-Yves David 2015-05-18 23:19:11 -05:00
parent b51b0deda6
commit c899dea3d5
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
mercurial/sshpeer.py
View File

@ -27,6 +27,15 @@ def _serverquote(s):
return s
return "'%s'" % s.replace("'", "'\\''")
def _forwardoutput(ui, pipe):
"""display all data currently available on pipe as remote output.
This is non blocking."""
s = util.readpipe(pipe)
if s:
for l in s.splitlines():
ui.status(_("remote: "), l, '\n')
class sshpeer(wireproto.wirepeer):
def __init__(self, ui, path, create=False):
self._url = path
@ -108,10 +117,7 @@ class sshpeer(wireproto.wirepeer):
return self._caps
def readerr(self):
s = util.readpipe(self.pipee)
if s:
for l in s.splitlines():
self.ui.status(_("remote: "), l, '\n')
_forwardoutput(self.ui, self.pipee)
def _abort(self, exception):
self.cleanup()