mercurial-scm/hg: mercurial/wireprototypes.py annotate

annotate mercurial/wireprototypes.py @ 52049:af54626bf358

dirstate-map: add a missing debug wait point when accessing the v2 docket fc8e37c380d3 added synchronization points to the dirstate to allow for race condition testing without actually requiring a time-based race condition to happen. This changes adds the `pre-read-file` wait point before we read the docket, since callers might ask for the parents before anything else is read, leading to the first read being done before the wait point. This removes some differences in test output which were presumed to be speed related, but weren't.

author	Rapha?l Gom?s <rgomes@octobus.net>
date	Mon, 14 Oct 2024 14:14:21 +0200
parents	f4733654f144
children	47981c4bfeee

rev	line source
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	1 # Copyright 2018 Gregory Szorc <gregory.szorc@gmail.com>
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	2 #
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	3 # This software may be used and distributed according to the terms of the
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	4 # GNU General Public License version 2 or any later version.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	5
51859 f4733654f144 typing: add `from __future__ import annotations` to most files Matt Harbison <matt_harbison@yahoo.com> parents: 51725 diff changeset	6 from __future__ import annotations
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	7
51725 278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	8 import typing
278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	9
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	10 from .node import (
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	11 bin,
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	12 hex,
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	13 )
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	14 from .i18n import _
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	15 from .thirdparty import attr
51725 278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	16
278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	17 # Force pytype to use the non-vendored package
278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	18 if typing.TYPE_CHECKING:
278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	19 # noinspection PyPackageRequirements
278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	20 import attr
278af66e6595 typing: induce pytype to use the standard `attr` instead of the vendored copy Matt Harbison <matt_harbison@yahoo.com> parents: 50926 diff changeset	21
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	22 from . import (
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	23 error,
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	24 util,
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	25 )
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	26 from .interfaces import util as interfaceutil
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	27 from .utils import compression
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	28
36536 3cd245945ef3 wireprotoserver: move SSHV1 and SSHV2 constants to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 36371 diff changeset	29 # Names of the SSH protocol implementations.
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	30 SSHV1 = b'ssh-v1'
36536 3cd245945ef3 wireprotoserver: move SSHV1 and SSHV2 constants to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 36371 diff changeset	31
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	32 NARROWCAP = b'exp-narrow-1'
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	33 ELLIPSESCAP1 = b'exp-ellipses-1'
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	34 ELLIPSESCAP = b'exp-ellipses-2'
42415 c767e655ffda narrow: use narrow_widen wireproto command to widen in case of ellipses Pulkit Goyal <7895pulkit@gmail.com> parents: 42041 diff changeset	35 SUPPORTED_ELLIPSESCAP = (ELLIPSESCAP1, ELLIPSESCAP)
40074 f7011b44d205 wireprotoserver: move narrow capabilities to wireprototypes.py Pulkit Goyal <pulkit@yandex-team.ru> parents: 40025 diff changeset	36
36609 abc3b9801563 wireproto: allow wire protocol commands to declare transport support Gregory Szorc <gregory.szorc@gmail.com> parents: 36536 diff changeset	37 # All available wire protocol transports.
abc3b9801563 wireproto: allow wire protocol commands to declare transport support Gregory Szorc <gregory.szorc@gmail.com> parents: 36536 diff changeset	38 TRANSPORTS = {
45942 89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	39 SSHV1: {
89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	40 b'transport': b'ssh',
89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	41 b'version': 1,
89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	42 },
89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	43 b'http-v1': {
89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	44 b'transport': b'http',
89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	45 b'version': 1,
89a2afe31e82 formating: upgrade to black 20.8b1 Augie Fackler <raf@durin42.com> parents: 44452 diff changeset	46 },
36609 abc3b9801563 wireproto: allow wire protocol commands to declare transport support Gregory Szorc <gregory.szorc@gmail.com> parents: 36536 diff changeset	47 }
abc3b9801563 wireproto: allow wire protocol commands to declare transport support Gregory Szorc <gregory.szorc@gmail.com> parents: 36536 diff changeset	48
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	49
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	50 class bytesresponse:
36074 2f7290555c96 wireproto: introduce type for raw byte responses (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 36073 diff changeset	51 """A wire protocol response consisting of raw bytes."""
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	52
36074 2f7290555c96 wireproto: introduce type for raw byte responses (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 36073 diff changeset	53 def __init__(self, data):
2f7290555c96 wireproto: introduce type for raw byte responses (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 36073 diff changeset	54 self.data = data
2f7290555c96 wireproto: introduce type for raw byte responses (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 36073 diff changeset	55
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	56
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	57 class ooberror:
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	58 """wireproto reply: failure of a batch of operation
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	59
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	60 Something failed during a batch call. The error message is stored in
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	61 `self.message`.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	62 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	63
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	64 def __init__(self, message):
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	65 self.message = message
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	66
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	67
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	68 class pushres:
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	69 """wireproto reply: success with simple integer return
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	70
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	71 The call was successful and returned an integer contained in `self.res`.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	72 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	73
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	74 def __init__(self, res, output):
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	75 self.res = res
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	76 self.output = output
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	77
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	78
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	79 class pusherr:
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	80 """wireproto reply: failure
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	81
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	82 The call failed. The `self.res` attribute contains the error message.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	83 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	84
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	85 def __init__(self, res, output):
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	86 self.res = res
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	87 self.output = output
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	88
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	89
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	90 class streamres:
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	91 """wireproto reply: binary stream
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	92
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	93 The call was successful and the result is a stream.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	94
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	95 Accepts a generator containing chunks of data to be sent to the client.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	96
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	97 ``prefer_uncompressed`` indicates that the data is expected to be
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	98 uncompressable and that the stream should therefore use the ``none``
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	99 engine.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	100 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	101
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	102 def __init__(self, gen=None, prefer_uncompressed=False):
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	103 self.gen = gen
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	104 self.prefer_uncompressed = prefer_uncompressed
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	105
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	106
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	107 class streamreslegacy:
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	108 """wireproto reply: uncompressed binary stream
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	109
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	110 The call was successful and the result is a stream.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	111
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	112 Accepts a generator containing chunks of data to be sent to the client.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	113
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	114 Like ``streamres``, but sends an uncompressed data for "version 1" clients
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	115 using the application/mercurial-0.1 media type.
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	116 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	117
36073 cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	118 def __init__(self, gen=None):
cd6ab329c5c7 wireprototypes: move wire protocol response types to new module Gregory Szorc <gregory.szorc@gmail.com> parents: diff changeset	119 self.gen = gen
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	120
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	121
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	122 # list of nodes encoding / decoding
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	123 def decodelist(l, sep=b' '):
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	124 if l:
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	125 return [bin(v) for v in l.split(sep)]
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	126 return []
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	127
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	128
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	129 def encodelist(l, sep=b' '):
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	130 try:
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	131 return sep.join(map(hex, l))
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	132 except TypeError:
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	133 raise
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	134
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	135
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	136 # batched call argument encoding
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	137
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	138
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	139 def escapebatcharg(plain):
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	140 return (
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	141 plain.replace(b':', b':c')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	142 .replace(b',', b':o')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	143 .replace(b';', b':s')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	144 .replace(b'=', b':e')
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	145 )
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	146
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	147
5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	148 def unescapebatcharg(escaped):
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	149 return (
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	150 escaped.replace(b':e', b'=')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	151 .replace(b':s', b';')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	152 .replace(b':o', b',')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	153 .replace(b':c', b':')
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	154 )
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	155
37612 5e71dea79aae wireproto: move value encoding functions to wireprototypes (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37485 diff changeset	156
37613 96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	157 # mapping of options accepted by getbundle and their types
96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	158 #
42955 9668744c9122 wireprototypes: clarify documentation of getbundle argument types Martin von Zweigbergk <martinvonz@google.com> parents: 42814 diff changeset	159 # Meant to be extended by extensions. It is the extension's responsibility to
9668744c9122 wireprototypes: clarify documentation of getbundle argument types Martin von Zweigbergk <martinvonz@google.com> parents: 42814 diff changeset	160 # ensure such options are properly processed in exchange.getbundle.
37613 96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	161 #
96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	162 # supported types are:
96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	163 #
42955 9668744c9122 wireprototypes: clarify documentation of getbundle argument types Martin von Zweigbergk <martinvonz@google.com> parents: 42814 diff changeset	164 # :nodes: list of binary nodes, transmitted as space-separated hex nodes
9668744c9122 wireprototypes: clarify documentation of getbundle argument types Martin von Zweigbergk <martinvonz@google.com> parents: 42814 diff changeset	165 # :csv: list of values, transmitted as comma-separated values
9668744c9122 wireprototypes: clarify documentation of getbundle argument types Martin von Zweigbergk <martinvonz@google.com> parents: 42814 diff changeset	166 # :scsv: set of values, transmitted as comma-separated values
37613 96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	167 # :plain: string with no transformation needed.
96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	168 GETBUNDLE_ARGUMENTS = {
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	169 b'heads': b'nodes',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	170 b'bookmarks': b'boolean',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	171 b'common': b'nodes',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	172 b'obsmarkers': b'boolean',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	173 b'phases': b'boolean',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	174 b'bundlecaps': b'scsv',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	175 b'listkeys': b'csv',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	176 b'cg': b'boolean',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	177 b'cbattempted': b'boolean',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	178 b'stream': b'boolean',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	179 b'includepats': b'csv',
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	180 b'excludepats': b'csv',
37613 96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	181 }
96d735601ca1 wireproto: move gboptsmap to wireprototypes and rename (API) Gregory Szorc <gregory.szorc@gmail.com> parents: 37612 diff changeset	182
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	183
37810 856f381ad74b interfaceutil: module to stub out zope.interface Gregory Szorc <gregory.szorc@gmail.com> parents: 37783 diff changeset	184 class baseprotocolhandler(interfaceutil.Interface):
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	185 """Abstract base class for wire protocol handlers.
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	186
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	187 A wire protocol handler serves as an interface between protocol command
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	188 handlers and the wire protocol transport layer. Protocol handlers provide
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	189 methods to read command arguments, redirect stdio for the duration of
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	190 the request, handle response types, etc.
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	191 """
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	192
37810 856f381ad74b interfaceutil: module to stub out zope.interface Gregory Szorc <gregory.szorc@gmail.com> parents: 37783 diff changeset	193 name = interfaceutil.Attribute(
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	194 """The name of the protocol implementation.
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	195
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	196 Used for uniquely identifying the transport type.
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	197 """
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	198 )
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	199
37296 78103e4138b1 wireproto: port protocol handler to zope.interface Gregory Szorc <gregory.szorc@gmail.com> parents: 37294 diff changeset	200 def getargs(args):
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	201 """return the value for arguments in <args>
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	202
37485 0b7475ea38cf wireproto: port heads command to wire protocol v2 Gregory Szorc <gregory.szorc@gmail.com> parents: 37414 diff changeset	203 For version 1 transports, returns a list of values in the same
0b7475ea38cf wireproto: port heads command to wire protocol v2 Gregory Szorc <gregory.szorc@gmail.com> parents: 37414 diff changeset	204 order they appear in ``args``. For version 2 transports, returns
0b7475ea38cf wireproto: port heads command to wire protocol v2 Gregory Szorc <gregory.szorc@gmail.com> parents: 37414 diff changeset	205 a dict mapping argument name to value.
0b7475ea38cf wireproto: port heads command to wire protocol v2 Gregory Szorc <gregory.szorc@gmail.com> parents: 37414 diff changeset	206 """
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	207
37393 afcfdf53e4b5 wireproto: provide accessors for client capabilities Joerg Sonnenberger <joerg@bec.de> parents: 37296 diff changeset	208 def getprotocaps():
afcfdf53e4b5 wireproto: provide accessors for client capabilities Joerg Sonnenberger <joerg@bec.de> parents: 37296 diff changeset	209 """Returns the list of protocol-level capabilities of client
afcfdf53e4b5 wireproto: provide accessors for client capabilities Joerg Sonnenberger <joerg@bec.de> parents: 37296 diff changeset	210
afcfdf53e4b5 wireproto: provide accessors for client capabilities Joerg Sonnenberger <joerg@bec.de> parents: 37296 diff changeset	211 Returns a list of capabilities as declared by the client for
afcfdf53e4b5 wireproto: provide accessors for client capabilities Joerg Sonnenberger <joerg@bec.de> parents: 37296 diff changeset	212 the current request (or connection for stateful protocol handlers)."""
afcfdf53e4b5 wireproto: provide accessors for client capabilities Joerg Sonnenberger <joerg@bec.de> parents: 37296 diff changeset	213
37414 2d965bfeb8f6 wireproto: allow direct stream processing for unbundle Joerg Sonnenberger <joerg@bec.de> parents: 37393 diff changeset	214 def getpayload():
2d965bfeb8f6 wireproto: allow direct stream processing for unbundle Joerg Sonnenberger <joerg@bec.de> parents: 37393 diff changeset	215 """Provide a generator for the raw payload.
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	216
37414 2d965bfeb8f6 wireproto: allow direct stream processing for unbundle Joerg Sonnenberger <joerg@bec.de> parents: 37393 diff changeset	217 The caller is responsible for ensuring that the full payload is
2d965bfeb8f6 wireproto: allow direct stream processing for unbundle Joerg Sonnenberger <joerg@bec.de> parents: 37393 diff changeset	218 processed.
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	219 """
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	220
37296 78103e4138b1 wireproto: port protocol handler to zope.interface Gregory Szorc <gregory.szorc@gmail.com> parents: 37294 diff changeset	221 def mayberedirectstdio():
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	222 """Context manager to possibly redirect stdio.
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	223
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	224 The context manager yields a file-object like object that receives
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	225 stdout and stderr output when the context manager is active. Or it
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	226 yields ``None`` if no I/O redirection occurs.
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	227
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	228 The intent of this context manager is to capture stdio output
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	229 so it may be sent in the response. Some transports support streaming
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	230 stdio to the client in real time. For these transports, stdio output
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	231 won't be captured.
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	232 """
0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	233
37296 78103e4138b1 wireproto: port protocol handler to zope.interface Gregory Szorc <gregory.szorc@gmail.com> parents: 37294 diff changeset	234 def client():
36371 0c231df1ffdc wireprototypes: move baseprotocolhandler from wireprotoserver Gregory Szorc <gregory.szorc@gmail.com> parents: 36074 diff changeset	235 """Returns a string representation of this client (as bytes)."""
36613 6e585bca962e wireproto: add transport specific capabilities in the transport Gregory Szorc <gregory.szorc@gmail.com> parents: 36609 diff changeset	236
37296 78103e4138b1 wireproto: port protocol handler to zope.interface Gregory Szorc <gregory.szorc@gmail.com> parents: 37294 diff changeset	237 def addcapabilities(repo, caps):
36613 6e585bca962e wireproto: add transport specific capabilities in the transport Gregory Szorc <gregory.szorc@gmail.com> parents: 36609 diff changeset	238 """Adds advertised capabilities specific to this protocol.
6e585bca962e wireproto: add transport specific capabilities in the transport Gregory Szorc <gregory.szorc@gmail.com> parents: 36609 diff changeset	239
6e585bca962e wireproto: add transport specific capabilities in the transport Gregory Szorc <gregory.szorc@gmail.com> parents: 36609 diff changeset	240 Receives the list of capabilities collected so far.
6e585bca962e wireproto: add transport specific capabilities in the transport Gregory Szorc <gregory.szorc@gmail.com> parents: 36609 diff changeset	241
6e585bca962e wireproto: add transport specific capabilities in the transport Gregory Szorc <gregory.szorc@gmail.com> parents: 36609 diff changeset	242 Returns a list of capabilities. The passed in argument can be returned.
6e585bca962e wireproto: add transport specific capabilities in the transport Gregory Szorc <gregory.szorc@gmail.com> parents: 36609 diff changeset	243 """
36801 66de4555cefd wireproto: formalize permissions checking as part of protocol interface Gregory Szorc <gregory.szorc@gmail.com> parents: 36613 diff changeset	244
37296 78103e4138b1 wireproto: port protocol handler to zope.interface Gregory Szorc <gregory.szorc@gmail.com> parents: 37294 diff changeset	245 def checkperm(perm):
36801 66de4555cefd wireproto: formalize permissions checking as part of protocol interface Gregory Szorc <gregory.szorc@gmail.com> parents: 36613 diff changeset	246 """Validate that the client has permissions to perform a request.
66de4555cefd wireproto: formalize permissions checking as part of protocol interface Gregory Szorc <gregory.szorc@gmail.com> parents: 36613 diff changeset	247
66de4555cefd wireproto: formalize permissions checking as part of protocol interface Gregory Szorc <gregory.szorc@gmail.com> parents: 36613 diff changeset	248 The argument is the permission required to proceed. If the client
66de4555cefd wireproto: formalize permissions checking as part of protocol interface Gregory Szorc <gregory.szorc@gmail.com> parents: 36613 diff changeset	249 doesn't have that permission, the exception should raise or abort
66de4555cefd wireproto: formalize permissions checking as part of protocol interface Gregory Szorc <gregory.szorc@gmail.com> parents: 36613 diff changeset	250 in a protocol specific manner.
66de4555cefd wireproto: formalize permissions checking as part of protocol interface Gregory Szorc <gregory.szorc@gmail.com> parents: 36613 diff changeset	251 """
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	252
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	253
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	254 class commandentry:
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	255 """Represents a declared wire protocol command."""
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	256
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	257 def __init__(
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	258 self,
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	259 func,
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	260 args=b'',
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	261 transports=None,
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	262 permission=b'push',
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	263 cachekeyfn=None,
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	264 extracapabilitiesfn=None,
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	265 ):
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	266 self.func = func
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	267 self.args = args
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	268 self.transports = transports or set()
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	269 self.permission = permission
40021 c537144fdbef wireprotov2: support response caching Gregory Szorc <gregory.szorc@gmail.com> parents: 40020 diff changeset	270 self.cachekeyfn = cachekeyfn
40172 30f70d11c224 wireprotov2: advertise recommended batch size for requests Gregory Szorc <gregory.szorc@gmail.com> parents: 40074 diff changeset	271 self.extracapabilitiesfn = extracapabilitiesfn
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	272
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	273 def _merge(self, func, args):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	274 """Merge this instance with an incoming 2-tuple.
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	275
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	276 This is called when a caller using the old 2-tuple API attempts
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	277 to replace an instance. The incoming values are merged with
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	278 data not captured by the 2-tuple and a new instance containing
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	279 the union of the two objects is returned.
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	280 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	281 return commandentry(
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	282 func,
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	283 args=args,
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	284 transports=set(self.transports),
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	285 permission=self.permission,
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	286 )
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	287
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	288 # Old code treats instances as 2-tuples. So expose that interface.
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	289 def __iter__(self):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	290 yield self.func
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	291 yield self.args
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	292
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	293 def __getitem__(self, i):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	294 if i == 0:
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	295 return self.func
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	296 elif i == 1:
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	297 return self.args
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	298 else:
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	299 raise IndexError(b'can only access elements 0 and 1')
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	300
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	301
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	302 class commanddict(dict):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	303 """Container for registered wire protocol commands.
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	304
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	305 It behaves like a dict. But __setitem__ is overwritten to allow silent
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	306 coercion of values from 2-tuples for API compatibility.
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	307 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	308
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	309 def __setitem__(self, k, v):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	310 if isinstance(v, commandentry):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	311 pass
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	312 # Cast 2-tuples to commandentry instances.
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	313 elif isinstance(v, tuple):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	314 if len(v) != 2:
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	315 raise ValueError(b'command tuples must have exactly 2 elements')
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	316
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	317 # It is common for extensions to wrap wire protocol commands via
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	318 # e.g. ``wireproto.commands[x] = (newfn, args)``. Because callers
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	319 # doing this aren't aware of the new API that uses objects to store
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	320 # command entries, we automatically merge old state with new.
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	321 if k in self:
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	322 v = self[k]._merge(v[0], v[1])
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	323 else:
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	324 # Use default values from @wireprotocommand.
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	325 v = commandentry(
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	326 v[0],
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	327 args=v[1],
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	328 transports=set(TRANSPORTS),
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	329 permission=b'push',
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	330 )
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	331 else:
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	332 raise ValueError(
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	333 b'command entries must be commandentry instances '
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	334 b'or 2-tuples'
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	335 )
37781 352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	336
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	337 return super(commanddict, self).__setitem__(k, v)
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	338
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	339 def commandavailable(self, command, proto):
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	340 """Determine if a command is available for the requested protocol."""
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	341 assert proto.name in TRANSPORTS
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	342
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	343 entry = self.get(command)
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	344
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	345 if not entry:
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	346 return False
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	347
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	348 if proto.name not in entry.transports:
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	349 return False
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	350
352932a11905 wireproto: move command registration types to wireprototypes Gregory Szorc <gregory.szorc@gmail.com> parents: 37728 diff changeset	351 return True
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	352
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	353
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	354 def supportedcompengines(ui, role):
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	355 """Obtain the list of supported compression engines for a request."""
42041 3e47d1ec9da5 util: extract compression code in `mercurial.utils.compression` Pierre-Yves David <pierre-yves.david@octobus.net> parents: 40492 diff changeset	356 assert role in (compression.CLIENTROLE, compression.SERVERROLE)
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	357
42041 3e47d1ec9da5 util: extract compression code in `mercurial.utils.compression` Pierre-Yves David <pierre-yves.david@octobus.net> parents: 40492 diff changeset	358 compengines = compression.compengines.supportedwireengines(role)
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	359
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	360 # Allow config to override default list and ordering.
42041 3e47d1ec9da5 util: extract compression code in `mercurial.utils.compression` Pierre-Yves David <pierre-yves.david@octobus.net> parents: 40492 diff changeset	361 if role == compression.SERVERROLE:
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	362 configengines = ui.configlist(b'server', b'compressionengines')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	363 config = b'server.compressionengines'
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	364 else:
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	365 # This is currently implemented mainly to facilitate testing. In most
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	366 # cases, the server should be in charge of choosing a compression engine
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	367 # because a server has the most to lose from a sub-optimal choice. (e.g.
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	368 # CPU DoS due to an expensive engine or a network DoS due to poor
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	369 # compression ratio).
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	370 configengines = ui.configlist(
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	371 b'experimental', b'clientcompressionengines'
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	372 )
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	373 config = b'experimental.clientcompressionengines'
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	374
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	375 # No explicit config. Filter out the ones that aren't supposed to be
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	376 # advertised and return default ordering.
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	377 if not configengines:
50910 93b0de7f13ca compression: use sysstr to specify attribute to fetch for priority Pierre-Yves David <pierre-yves.david@octobus.net> parents: 48946 diff changeset	378 attr = 'serverpriority' if role == util.SERVERROLE else 'clientpriority'
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	379 return [
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	380 e for e in compengines if getattr(e.wireprotosupport(), attr) > 0
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	381 ]
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	382
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	383 # If compression engines are listed in the config, assume there is a good
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	384 # reason for it (like server operators wanting to achieve specific
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	385 # performance characteristics). So fail fast if the config references
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	386 # unusable compression engines.
44452 9d2b2df2c2ba cleanup: run pyupgrade on our source tree to clean up varying things Augie Fackler <augie@google.com> parents: 43481 diff changeset	387 validnames = {e.name() for e in compengines}
9d2b2df2c2ba cleanup: run pyupgrade on our source tree to clean up varying things Augie Fackler <augie@google.com> parents: 43481 diff changeset	388 invalidnames = {e for e in configengines if e not in validnames}
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	389 if invalidnames:
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	390 raise error.Abort(
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	391 _(b'invalid compression engine defined in %s: %s')
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	392 % (config, b', '.join(sorted(invalidnames)))
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	393 )
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	394
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	395 compengines = [e for e in compengines if e.name() in configengines]
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	396 compengines = sorted(
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	397 compengines, key=lambda e: configengines.index(e.name())
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	398 )
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	399
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	400 if not compengines:
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	401 raise error.Abort(
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	402 _(
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	403 b'%s config option does not specify any known '
687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	404 b'compression engines'
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	405 )
2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	406 % config,
43077 687b865b95ad formatting: byteify all mercurial/ and hgext/ string literals Augie Fackler <augie@google.com> parents: 43076 diff changeset	407 hint=_(b'usable compression engines: %s')
43481 f5fcf7123a92 wireprototypes: disable pytype where it's just confused Augie Fackler <augie@google.com> parents: 43089 diff changeset	408 % b', '.sorted(validnames), # pytype: disable=attribute-error
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	409 )
37783 9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	410
9d818539abfa wireproto: move supportedcompengines out of wireproto Gregory Szorc <gregory.szorc@gmail.com> parents: 37781 diff changeset	411 return compengines
40020 ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	412
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	413
40020 ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	414 @attr.s
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	415 class encodedresponse:
40020 ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	416 """Represents response data that is already content encoded.
ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	417
ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	418 Wire protocol version 2 only.
ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	419
ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	420 Commands typically emit Python objects that are encoded and sent over the
ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	421 wire. If commands emit an object of this type, the encoding step is bypassed
ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	422 and the content from this object is used instead.
ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	423 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	424
40020 ed919b90acda wireprotov2: define type to represent pre-encoded object Gregory Szorc <gregory.szorc@gmail.com> parents: 39814 diff changeset	425 data = attr.ib()
40025 b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	426
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	427
40025 b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	428 @attr.s
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	429 class alternatelocationresponse:
40025 b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	430 """Represents a response available at an alternate location.
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	431
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	432 Instances are sent in place of actual response objects when the server
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	433 is sending a "content redirect" response.
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	434
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	435 Only compatible with wire protocol version 2.
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	436 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	437
40025 b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	438 url = attr.ib()
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	439 mediatype = attr.ib()
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	440 size = attr.ib(default=None)
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	441 fullhashes = attr.ib(default=None)
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	442 fullhashseed = attr.ib(default=None)
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	443 serverdercerts = attr.ib(default=None)
b099e6032f38 wireprotov2: server support for sending content redirects Gregory Szorc <gregory.szorc@gmail.com> parents: 40021 diff changeset	444 servercadercerts = attr.ib(default=None)
40328 2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	445
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	446
40328 2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	447 @attr.s
48946 642e31cb55f0 py3: use class X: instead of class X(object): Gregory Szorc <gregory.szorc@gmail.com> parents: 48875 diff changeset	448 class indefinitebytestringresponse:
40328 2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	449 """Represents an object to be encoded to an indefinite length bytestring.
2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	450
2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	451 Instances are initialized from an iterable of chunks, with each chunk being
2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	452 a bytes instance.
2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	453 """
43076 2372284d9457 formatting: blacken the codebase Augie Fackler <augie@google.com> parents: 42955 diff changeset	454
40328 2c55716f8a1c wireprotov2: add response type that serializes to indefinite length bytestring Gregory Szorc <gregory.szorc@gmail.com> parents: 40176 diff changeset	455 chunks = attr.ib()

Mercurial > public > mercurial-scm > hg

annotate mercurial/wireprototypes.py @ 52049:af54626bf358