Mercurial > public > mercurial-scm > hg
comparison mercurial/wireproto.py @ 21072:0879352d67d8
wireproto: add a _calltwowaystream method on wirepeer
This method will be used by bundle2 pushes. It calls a command, feeds it with a
stream and receives another stream in reply.
Actual implementation for ssh and http will be done in later changesets.
| author | Pierre-Yves David <pierre-yves.david@fb.com> |
|---|---|
| date | Tue, 15 Apr 2014 17:19:46 -0400 |
| parents | 0a9cae236738 |
| children | 438803e4bd97 |
comparison
equal
deleted
inserted
replaced
| 21071:19b9f23a8c6f | 21072:0879352d67d8 |
|---|---|
| 413 returns the server reply as a (ret, output) tuple. ret is either | 413 returns the server reply as a (ret, output) tuple. ret is either |
| 414 empty (error) or a stringified int. | 414 empty (error) or a stringified int. |
| 415 """ | 415 """ |
| 416 raise NotImplementedError() | 416 raise NotImplementedError() |
| 417 | 417 |
| 418 def _calltwowaystream(self, cmd, fp, **args): | |
| 419 """execute <cmd> on server | |
| 420 | |
| 421 The command will send a stream to the server and get a stream in reply. | |
| 422 """ | |
| 423 raise NotImplementedError() | |
| 424 | |
| 418 def _abort(self, exception): | 425 def _abort(self, exception): |
| 419 """clearly abort the wire protocol connection and raise the exception | 426 """clearly abort the wire protocol connection and raise the exception |
| 420 """ | 427 """ |
| 421 raise NotImplementedError() | 428 raise NotImplementedError() |
| 422 | 429 |