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