Show More
@@ -27,6 +27,15 b' def _serverquote(s):' | |||
|
27 | 27 | return s |
|
28 | 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 | 39 | class sshpeer(wireproto.wirepeer): |
|
31 | 40 | def __init__(self, ui, path, create=False): |
|
32 | 41 | self._url = path |
@@ -108,10 +117,7 b' class sshpeer(wireproto.wirepeer):' | |||
|
108 | 117 | return self._caps |
|
109 | 118 | |
|
110 | 119 | def readerr(self): |
|
111 | s = util.readpipe(self.pipee) | |
|
112 | if s: | |
|
113 | for l in s.splitlines(): | |
|
114 | self.ui.status(_("remote: "), l, '\n') | |
|
120 | _forwardoutput(self.ui, self.pipee) | |
|
115 | 121 | |
|
116 | 122 | def _abort(self, exception): |
|
117 | 123 | self.cleanup() |
General Comments 0
You need to be logged in to leave comments.
Login now