| indygreg | |
| krbullock |
| hg-reviewers |
This is no longer needed.
| Lint Skipped |
| Unit Tests Skipped |
| return handler | return handler | ||||
| def _processpart(op, part): | def _processpart(op, part): | ||||
| """process a single part from a bundle | """process a single part from a bundle | ||||
| The part is guaranteed to have been fully consumed when the function exits | The part is guaranteed to have been fully consumed when the function exits | ||||
| (even if an exception is raised).""" | (even if an exception is raised).""" | ||||
| try: | |||||
| handler = _gethandler(op, part) | handler = _gethandler(op, part) | ||||
| if handler is None: | if handler is None: | ||||
| return | return | ||||
| # handler is called outside the above try block so that we don't | # handler is called outside the above try block so that we don't | ||||
| # risk catching KeyErrors from anything other than the | # risk catching KeyErrors from anything other than the | ||||
| # parthandlermapping lookup (any KeyError raised by handler() | # parthandlermapping lookup (any KeyError raised by handler() | ||||
| # itself represents a defect of a different variety). | # itself represents a defect of a different variety). | ||||
| output = None | output = None | ||||
| if op.captureoutput and op.reply is not None: | if op.captureoutput and op.reply is not None: | ||||
| op.ui.pushbuffer(error=True, subproc=True) | op.ui.pushbuffer(error=True, subproc=True) | ||||
| output = '' | output = '' | ||||
| try: | try: | ||||
| handler(op, part) | handler(op, part) | ||||
| finally: | finally: | ||||
| if output is not None: | if output is not None: | ||||
| output = op.ui.popbuffer() | output = op.ui.popbuffer() | ||||
| if output: | if output: | ||||
| outpart = op.reply.newpart('output', data=output, | outpart = op.reply.newpart('output', data=output, | ||||
| mandatory=False) | mandatory=False) | ||||
| outpart.addparam( | outpart.addparam( | ||||
| 'in-reply-to', pycompat.bytestr(part.id), mandatory=False) | 'in-reply-to', pycompat.bytestr(part.id), mandatory=False) | ||||
| finally: | |||||
| pass | |||||
| def decodecaps(blob): | def decodecaps(blob): | ||||
| """decode a bundle2 caps bytes blob into a dictionary | """decode a bundle2 caps bytes blob into a dictionary | ||||
| The blob is a list of capabilities (one per line) | The blob is a list of capabilities (one per line) | ||||
| Capabilities may have values using a line of the form:: | Capabilities may have values using a line of the form:: | ||||
| capability=value1,value2,value3 | capability=value1,value2,value3 | ||||