comparison mercurial/wireprotov1peer.py @ 37669:1cb54e6193a6

py3: paper over differences in future exception handling

It looks like Python 3's futures library lacks set_exception_info
entirely. We'll just give up and use set_exception in that case.

# no-check-commit because the underbar naming is just saner here

Differential Revision: https://phab.mercurial-scm.org/D3336

37668:2a42ca2679e2

                return

            try:
                result = fn(**pycompat.strkwargs(args))
            except Exception:
                f.set_exception_info(*sys.exc_info()[1:])
            else:
                f.set_result(result)

            return

            try:
                batchable = fn.batchable(fn.__self__,
                                         **pycompat.strkwargs(args))
            except Exception:
                f.set_exception_info(*sys.exc_info()[1:])
                return

            # Encoded arguments and future holding remote result.
            try:
                encodedargs, fremote = next(batchable)
            except Exception:
                f.set_exception_info(*sys.exc_info()[1:])
                return

            requests.append((command, encodedargs))
            states.append((command, f, batchable, fremote))

            # And ask the coroutine to decode that value.
            try:
                result = next(batchable)
            except Exception:
                f.set_exception_info(*sys.exc_info()[1:])
            else:
                f.set_result(result)

@zi.implementer(repository.ipeercommands, repository.ipeerlegacycommands)
class wirepeer(repository.peer):

37669:1cb54e6193a6

                return

            try:
                result = fn(**pycompat.strkwargs(args))
            except Exception:
                pycompat.future_set_exception_info(f, sys.exc_info()[1:])
            else:
                f.set_result(result)

            return

            try:
                batchable = fn.batchable(fn.__self__,
                                         **pycompat.strkwargs(args))
            except Exception:
                pycompat.future_set_exception_info(f, sys.exc_info()[1:])
                return

            # Encoded arguments and future holding remote result.
            try:
                encodedargs, fremote = next(batchable)
            except Exception:
                pycompat.future_set_exception_info(f, sys.exc_info()[1:])
                return

            requests.append((command, encodedargs))
            states.append((command, f, batchable, fremote))

            # And ask the coroutine to decode that value.
            try:
                result = next(batchable)
            except Exception:
                pycompat.future_set_exception_info(f, sys.exc_info()[1:])
            else:
                f.set_result(result)

@zi.implementer(repository.ipeercommands, repository.ipeerlegacycommands)
class wirepeer(repository.peer):