Mercurial > public > mercurial-scm > hg-stable
comparison mercurial/sshrepo.py @ 11588:8a1f625e971d
protocol: unify stream_out client code
author | Matt Mackall <mpm@selenic.com> |
---|---|
date | Wed, 14 Jul 2010 16:55:44 -0500 |
parents | ddaaaa23bb8f |
children | e8d22fe2ddab |
comparison
equal
deleted
inserted
replaced
11587:a036f6bd1da3 | 11588:8a1f625e971d |
---|---|
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 |