comparison mercurial/debugcommands.py @ 37057:2ec1fb9de638

wireproto: add request IDs to frames One of my primary goals with the new wire protocol is to make operations faster and enable both client and server-side operations to scale to multiple CPU cores. One of the ways we make server interactions faster is by reducing the number of round trips to that server. With the existing wire protocol, the "batch" command facilitates executing multiple commands from a single request payload. The way it works is the requests for multiple commands are serialized. The server executes those commands sequentially then serializes all their results. As an optimization for reducing round trips, this is very effective. The technical implementation, however, is pretty bad and suffers from a number of deficiencies. For example, it creates a new place where authorization to run a command must be checked. (The lack of this checking in older Mercurial releases was CVE-2018-1000132.) The principles behind the "batch" command are sound. However, the execution is not. Therefore, I want to ditch "batch" in the new wire protocol and have protocol level support for issuing multiple requests in a single round trip. This commit introduces support in the frame-based wire protocol to facilitate this. We do this by adding a "request ID" to each frame. If a server sees frames associated with different "request IDs," it handles them as separate requests. All of this happening possibly as part of the same message from client to server (the same request body in the case of HTTP). We /could/ model the exchange the way pipelined HTTP requests do, where the server processes requests in order they are issued and received. But this artifically constrains scalability. A better model is to allow multi-requests to be executed concurrently and for responses to be sent and handled concurrently. So the specification explicitly allows this. There is some work to be done around specifying dependencies between multi-requests. We take the easy road for now and punt on this problem, declaring that if order is important, clients must not issue the request until responses to dependent requests have been received. This commit focuses on the boilerplate of implementing the request ID. The server reactor still can't manage multiple, in-flight request IDs. This will be addressed in a subsequent commit. Because the wire semantics have changed, we bump the version of the media type. Differential Revision: https://phab.mercurial-scm.org/D2869
author Gregory Szorc <gregory.szorc@gmail.com>
date Wed, 14 Mar 2018 16:51:34 -0700
parents 40206e227412
children f0b6fbea00cf
comparison
equal deleted inserted replaced
37056:861e9d37e56e 37057:2ec1fb9de638
2763 2763
2764 It is possible to emit a *Unified Frame-Based Protocol* by using special 2764 It is possible to emit a *Unified Frame-Based Protocol* by using special
2765 syntax. 2765 syntax.
2766 2766
2767 A frame is composed as a type, flags, and payload. These can be parsed 2767 A frame is composed as a type, flags, and payload. These can be parsed
2768 from a string of the form ``<type> <flags> <payload>``. That is, 3 2768 from a string of the form ``<requestid> <type> <flags> <payload>``. That is,
2769 space-delimited strings. 2769 4 space-delimited strings.
2770 2770
2771 ``payload`` is the simplest: it is evaluated as a Python byte string 2771 ``payload`` is the simplest: it is evaluated as a Python byte string
2772 literal. 2772 literal.
2773
2774 ``requestid`` is an integer defining the request identifier.
2773 2775
2774 ``type`` can be an integer value for the frame type or the string name 2776 ``type`` can be an integer value for the frame type or the string name
2775 of the type. The strings are defined in ``wireprotoframing.py``. e.g. 2777 of the type. The strings are defined in ``wireprotoframing.py``. e.g.
2776 ``command-name``. 2778 ``command-name``.
2777 2779