Mercurial > hg
comparison mercurial/wireprotov2server.py @ 37728:564a3eec6e63
wireprotov2: add support for more response types
This adds types to represent error and generator responses from
server commands.
Differential Revision: https://phab.mercurial-scm.org/D3388
author | Gregory Szorc <gregory.szorc@gmail.com> |
---|---|
date | Sun, 15 Apr 2018 10:37:29 -0700 |
parents | 5cdde6158426 |
children | 8acd3a9ac4fd |
comparison
equal
deleted
inserted
replaced
37727:5cdde6158426 | 37728:564a3eec6e63 |
---|---|
304 if isinstance(rsp, wireprototypes.cborresponse): | 304 if isinstance(rsp, wireprototypes.cborresponse): |
305 encoded = cbor.dumps(rsp.value, canonical=True) | 305 encoded = cbor.dumps(rsp.value, canonical=True) |
306 action, meta = reactor.oncommandresponseready(outstream, | 306 action, meta = reactor.oncommandresponseready(outstream, |
307 command['requestid'], | 307 command['requestid'], |
308 encoded) | 308 encoded) |
309 elif isinstance(rsp, wireprototypes.v2streamingresponse): | |
310 action, meta = reactor.oncommandresponsereadygen(outstream, | |
311 command['requestid'], | |
312 rsp.gen) | |
313 elif isinstance(rsp, wireprototypes.v2errorresponse): | |
314 action, meta = reactor.oncommanderror(outstream, | |
315 command['requestid'], | |
316 rsp.message, | |
317 rsp.args) | |
309 else: | 318 else: |
310 action, meta = reactor.onservererror( | 319 action, meta = reactor.onservererror( |
311 _('unhandled response type from wire proto command')) | 320 _('unhandled response type from wire proto command')) |
312 | 321 |
313 if action == 'sendframes': | 322 if action == 'sendframes': |