equal
deleted
inserted
replaced
133 return self._recv() |
133 return self._recv() |
134 |
134 |
135 def _call(self, cmd, **args): |
135 def _call(self, cmd, **args): |
136 self.do_cmd(cmd, **args) |
136 self.do_cmd(cmd, **args) |
137 return self._recv() |
137 return self._recv() |
|
138 |
|
139 def _callstream(self, cmd, **args): |
|
140 return self.do_cmd(cmd, **args) |
138 |
141 |
139 def _recv(self): |
142 def _recv(self): |
140 l = self.pipei.readline() |
143 l = self.pipei.readline() |
141 self.readerr() |
144 self.readerr() |
142 try: |
145 try: |
222 try: |
225 try: |
223 return int(r) |
226 return int(r) |
224 except: |
227 except: |
225 self.abort(error.ResponseError(_("unexpected response:"), r)) |
228 self.abort(error.ResponseError(_("unexpected response:"), r)) |
226 |
229 |
227 def stream_out(self): |
|
228 return self.do_cmd('stream_out') |
|
229 |
|
230 instance = sshrepository |
230 instance = sshrepository |