equal
deleted
inserted
replaced
275 |
275 |
276 def _calltwowaystream(self, cmd, fp, **args): |
276 def _calltwowaystream(self, cmd, fp, **args): |
277 r = self._call(cmd, **args) |
277 r = self._call(cmd, **args) |
278 if r: |
278 if r: |
279 # XXX needs to be made better |
279 # XXX needs to be made better |
280 raise util.Abort('unexpected remote reply: %s' % r) |
280 raise error.Abort('unexpected remote reply: %s' % r) |
281 while True: |
281 while True: |
282 d = fp.read(4096) |
282 d = fp.read(4096) |
283 if not d: |
283 if not d: |
284 break |
284 break |
285 self._send(d) |
285 self._send(d) |