##// END OF EJS Templates
sshpeer: extract the forward output logic...
Pierre-Yves David -
r25244:cf90764f default
parent child Browse files
Show More
@@ -27,6 +27,15 b' def _serverquote(s):'
27 return s
27 return s
28 return "'%s'" % s.replace("'", "'\\''")
28 return "'%s'" % s.replace("'", "'\\''")
29
29
30 def _forwardoutput(ui, pipe):
31 """display all data currently available on pipe as remote output.
32
33 This is non blocking."""
34 s = util.readpipe(pipe)
35 if s:
36 for l in s.splitlines():
37 ui.status(_("remote: "), l, '\n')
38
30 class sshpeer(wireproto.wirepeer):
39 class sshpeer(wireproto.wirepeer):
31 def __init__(self, ui, path, create=False):
40 def __init__(self, ui, path, create=False):
32 self._url = path
41 self._url = path
@@ -108,10 +117,7 b' class sshpeer(wireproto.wirepeer):'
108 return self._caps
117 return self._caps
109
118
110 def readerr(self):
119 def readerr(self):
111 s = util.readpipe(self.pipee)
120 _forwardoutput(self.ui, self.pipee)
112 if s:
113 for l in s.splitlines():
114 self.ui.status(_("remote: "), l, '\n')
115
121
116 def _abort(self, exception):
122 def _abort(self, exception):
117 self.cleanup()
123 self.cleanup()
General Comments 0
You need to be logged in to leave comments. Login now