6h4 \SSKJr SSKrSSKrSSKJr SSKJrJr SSKJ r SSK J r \R(aSSK r SSK JrJr SS KJr S rS rS rS r\\4r\SSS.SSSS.0r"SS5r"SS5r"SS5r"SS5r"SS5r"SS5rS4SjrS4SjrS r S!r!S"S#S"S#S#S$S%S#S#S#S%S%S&. r""S'S(\5r#"S)S*5r$"S+S,\%5r&S-r'\ RP"S.S/55r)\ RP"S0S155r*\ RP"S2S355r+g)5) annotationsN)Protocol)binhex)_)attr)errorutil) compressionsssh-v1s exp-narrow-1sexp-ellipses-1sexp-ellipses-2sssh)s transportsversionshttp-v1shttpc\rSrSrSrSrSrg) bytesresponse6z1A wire protocol response consisting of raw bytes.cXlgNdata)selfrs :/usr/lib/python3/dist-packages/mercurial/wireprototypes.py__init__bytesresponse.__init__9s rN__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__rrrr6s ;rrc\rSrSrSrSrSrg)ooberror=zwireproto reply: failure of a batch of operation Something failed during a batch call. The error message is stored in `self.message`. cXlgrmessage)rr&s rrooberror.__init__Ds rr%Nrr rrr"r"=s  rr"c\rSrSrSrSrSrg)pushresHz~wireproto reply: success with simple integer return The call was successful and returned an integer contained in `self.res`. cXlX lgrresoutputrr-r.s rrpushres.__init__N  rr.r-Nrr rrr)r)H  rr)c\rSrSrSrSrSrg)pusherrSz`wireproto reply: failure The call failed. The `self.res` attribute contains the error message. cXlX lgrr,r/s rrpusherr.__init__Yr1rr2Nrr rrr5r5Sr3rr5c"\rSrSrSrSSjrSrg) streamres^a-wireproto reply: binary stream The call was successful and the result is a stream. Accepts a generator containing chunks of data to be sent to the client. ``prefer_uncompressed`` indicates that the data is expected to be uncompressable and that the stream should therefore use the ``none`` engine. NcXlX lgrgenprefer_uncompressed)rr>r?s rrstreamres.__init__js #6 rr=)NFrr rrr:r:^s  7rr:c"\rSrSrSrSSjrSrg)streamreslegacyoa&wireproto reply: uncompressed binary stream The call was successful and the result is a stream. Accepts a generator containing chunks of data to be sent to the client. Like ``streamres``, but sends an uncompressed data for "version 1" clients using the application/mercurial-0.1 media type. NcXlgrr>)rr>s rrstreamreslegacy.__init__zsrrErrr rrrBrBos rrBctU(a+URU5Vs/sHn[U5PM sn$/$s snfr)splitr)lsepvs r decodelistrLs0 ! - 1A -- I.s5c`UR[[U55$![a ef=fr)joinmapr TypeError)rIrJs r encodelistrQs.xxC $$  s! -cURSS5RSS5RSS5RSS5$) N::c,:o;:s=:ereplace)plains rescapebatchargr^s9 dE" u  u  u  rcURSS5RSS5RSS5RSS5$) NrZrYrXrWrVrUrTrSr[)escapeds runescapebatchargras9t$       rsnodessbooleansscsvscsv) sheadss bookmarksscommons obsmarkerssphasess bundlecapsslistkeysscgs cbattemptedsstreams includepatss excludepatscF\rSrSrSr\\RS Sj55r\RS5r \RS5r \RS5r \RS5r \RS5r \RS 5r\RS 5rS rg )baseprotocolhandlera2Abstract base class for wire protocol handlers. A wire protocol handler serves as an interface between protocol command handlers and the wire protocol transport layer. Protocol handlers provide methods to read command arguments, redirect stdio for the duration of the request, handle response types, etc. cg)z\The name of the protocol implementation. Used for uniquely identifying the transport type. Nr rs rnamebaseprotocolhandler.namercg)zreturn the value for arguments in For version 1 transports, returns a list of values in the same order they appear in ``args``. For version 2 transports, returns a dict mapping argument name to value. Nr )rargss rgetargsbaseprotocolhandler.getargsrircg)zReturns the list of protocol-level capabilities of client Returns a list of capabilities as declared by the client for the current request (or connection for stateful protocol handlers).Nr rfs r getprotocaps baseprotocolhandler.getprotocapsrircg)zuProvide a generator for the raw payload. The caller is responsible for ensuring that the full payload is processed. Nr rfs r getpayloadbaseprotocolhandler.getpayloadrircg)aContext manager to possibly redirect stdio. The context manager yields a file-object like object that receives stdout and stderr output when the context manager is active. Or it yields ``None`` if no I/O redirection occurs. The intent of this context manager is to capture stdio output so it may be sent in the response. Some transports support streaming stdio to the client in real time. For these transports, stdio output won't be captured. Nr rfs rmayberedirectstdio&baseprotocolhandler.mayberedirectstdiorircg)z:Returns a string representation of this client (as bytes).Nr rfs rclientbaseprotocolhandler.clientrircg)zAdds advertised capabilities specific to this protocol. Receives the list of capabilities collected so far. Returns a list of capabilities. The passed in argument can be returned. Nr )rrepocapss raddcapabilities#baseprotocolhandler.addcapabilitiesrircg)zValidate that the client has permissions to perform a request. The argument is the permission required to proceed. If the client doesn't have that permission, the exception should raise or abort in a protocol specific manner. Nr )rperms r checkpermbaseprotocolhandler.checkpermrirr N)returnbytes)rrrrrpropertyabcabstractmethodrgrlrorrrurxr}rrr rrrcrcs      OO          II      rrcc>\rSrSrSrS SjrSrSrSrSr g) commandentryi z,Represents a declared wire protocol command.NcpXlX lU=(d [5UlX@lXPlX`lgr)funcrkset transports permission cachekeyfnextracapabilitiesfn)rrrkrrrrs rrcommandentry.__init__ s,  $-$$#6 rcT[UU[UR5URS9$)aMerge this instance with an incoming 2-tuple. This is called when a caller using the old 2-tuple API attempts to replace an instance. The incoming values are merged with data not captured by the 2-tuple and a new instance containing the union of the two objects is returned. rkrr)rrrr)rrrks r_mergecommandentry._merges* 4??+   rc#D# URv URv g7fr)rrkrfs r__iter__commandentry.__iter__-siiiis c`US:Xa UR$US:Xa UR$[S5e)Nrrs can only access elements 0 and 1)rrk IndexError)ris r __getitem__commandentry.__getitem__1s0 699  !V99 @A Ar)rkrrrrr)rNpushNN) rrrrrrrrrrr rrrr s+6  7  Brrc2^\rSrSrSrU4SjrSrSrU=r$) commanddicti:zContainer for registered wire protocol commands. It behaves like a dict. But __setitem__ is overwritten to allow silent coercion of values from 2-tuples for API compatibility. cB>[U[5(aOz[U[5(aZ[U5S:wa [ S5eX;aXR USUS5nO+[USUS[ [5SS9nO [ S5e[TU]%X5$)Ns+command tuples must have exactly 2 elementsrrrrs:command entries must be commandentry instances or 2-tuples) isinstancertuplelen ValueErrorrr TRANSPORTSsuper __setitem__)rkrK __class__s rrcommanddict.__setitem__As a & &  5 ! !1v{ !OPP yGNN1Q41.!aD1":&   w"1((rcUR[;deURU5nU(dgURUR;agg)z?Determine if a command is available for the requested protocol.FT)rgrgetr)rcommandprotoentrys rcommandavailablecommanddict.commandavailable_s@zzZ'''! ::U-- -rr ) rrrrrrrr __classcell__)rs@rrr:s )<  rrc ^U[R[R4;de[RR U5nU[R:XaUR SS5mSnOUR SS5mSnT(dKU[ R:XaSOSnUVs/sH%n[UR5U5S :dM#UPM' sn$UVs1sHoUR5iM nnTVs1sH oUU;dM UiM nnU(a<[R"[S 5US R[U554-5eUVs/sHoUR5T;dMUPM nn[UU4S jS 9nU(dE[R"[S5U-[S5S R[U55-S9eU$s snfs snfs snfs snf)z?Obtain the list of supported compression engines for a request.sserverscompressionenginessserver.compressionenginess experimentalsclientcompressionenginess%experimental.clientcompressionenginesserverpriorityclientpriorityrs,invalid compression engine defined in %s: %ss, cB>TRUR55$r)indexrg)e configenginess r&supportedcompengines..s=#6#6qvvx#@r)keys?%s config option does not specify any known compression enginessusable compression engines: %s)hint)r CLIENTROLE SERVERROLE compenginessupportedwireengines configlistr getattrwireprotosupportrgr AbortrrNsorted) uirolerconfigr r validnames invalidnamesrs @rsupportedcompenginesrns K**K,B,BC CC C))>>tDK {%%% i1FG - 8 : #'4??#:@P" "!ga.@.@.BD&IA&MA{  %00Kq&&(KJ0,D}!0CA}LDkk = >uzz&"678 9  *GkVVX-F1kKG@K kk '    45jj +,-    A 1DHs*'"G GG9 GGG#0G#c:\rSrSrSr\R "5rSrg)encodedresponseia#Represents response data that is already content encoded. Wire protocol version 2 only. Commands typically emit Python objects that are encoded and sent over the wire. If commands emit an object of this type, the encoding step is bypassed and the content from this object is used instead. r N) rrrrrr ibrrr rrrrs 779Drrc\rSrSrSr\R "5r\R "5r\R "SS9r \R "SS9r \R "SS9r \R "SS9r \R "SS9r Srg)alternatelocationresponseizRepresents a response available at an alternate location. Instances are sent in place of actual response objects when the server is sending a "content redirect" response. Only compatible with wire protocol version 2. N)defaultr )rrrrrr rurl mediatypesize fullhashes fullhashseedserverdercertsservercadercertsrr rrrrsf '')C I 774 D&J774(LWWT*Nwwt,rrc:\rSrSrSr\R "5rSrg)indefinitebytestringresponseizRepresents an object to be encoded to an indefinite length bytestring. Instances are initialized from an iterable of chunks, with each chunk being a bytes instance. r N) rrrrrr rchunksrr rrrrs WWYFrr) ), __future__rrtypingrnoderri18nr thirdpartyr TYPE_CHECKINGr r utilsr SSHV1 NARROWCAP ELLIPSESCAP1 ELLIPSESCAPSUPPORTED_ELLIPSESCAPrrr"r)r5r:rBrLrQr^raGETBUNDLE_ARGUMENTSrcrdictrrsrrrr rrrs #       %{3    77"    *   K (K \-B-B`1$1h9x   ---$r