6hqsSSKJr SSKrSSKrSSKJr SSKJr SSKJ r J r J r J r JrJrJrJrJrJrJrJrJrJrJr SSKJrJr \R<r\R>r\"S5r \"S 5r!S \ \!4-r"S r#SOS jr$SOS jr%Sr&Sr'\RP"5r)SPSjr*\*"SSSS9S5r+\*"SSSS9S5r,\*"SSS9S5r-\*"SSSS9S5r.\*"SS SS9S!5r/\*"S"S#SS9S$5r0\*"S%S&SS9S'5r1/S(Qr2S)r3\*"S*SS9S+5r4\*"S,S-SS9S.5r \*"S/S0SS9S15r5\*"S2S3SS9S45r6S5r7\*"S6S&SS9S75r8\*"S8SS9S95r9\*"S:SS9S;5r:\*"S5r;\*"S?S@SS9SA5r<\*"SBSCSS9SD5r=\*"SESFSS9SG5r>\*"SHSISS9SJ5r\*"SKSS9SL5r?\*"SMS8SS9SN5r@g)Q) annotationsN)_)hex)bundle2 bundlecaches changegroup discoveryencodingerrorexchangehookpushkeypycompatrepoview requirements streamcloneutilwireprototypes)procutil stringutils/incompatible Mercurial client; bundle2 requireds9see https://www.mercurial-scm.org/wiki/IncompatibleClients%s (%s) cUR5H/nURS5(dMUSSRS5s $ SS/$)aReturns a list of compression methods supported by the client. Returns a list of the compression methods supported by the client according to the protocol capabilities. If no such capability has been announced, fallback to the default of zlib and uncompressed. scomp=N,szlibsnone) getprotocaps startswithsplit)protocaps =/usr/lib/python3/dist-packages/mercurial/wireprotov1server.pyclientcompressionsupportr!1sH!!# >>( # #qr7==& &$ W cURRSS5nU(aUbUS-[R;aUS- nUR U5$)zObtain the repo used for processing wire protocol commands. The intent of this function is to serve as a monkeypatch point for extensions that need commands to operate on different repo views under specialized circumstances. serversviews.hidden)uiconfigr filtertablefiltered)reporcommand accesshidden viewconfigs r getdispatchrepor-AsO 73J   "  #x';'; ;j == $$r"c`[XX#S9n[UupEURU5nU"X/UQ76$)N)r+)r-commandsgetargs)r)rr*r+funcspecargss r dispatchr4Vs8 4 KD'"JD == D  #d ##r"c0nUHnXB;dM X$X4'X$ M U(a3[RRSUSRU54-5 U$)Ns,warning: %s ignored unexpected arguments %s r)rstderrwritejoin)cmdkeysothersoptsks r optionsr>_s[ D  ;iDG  <DIIf%& '  Kr"c*URn[RUR;nU(aUR SSU-5nUbU$UR SSU-5nUbU$U(aUR SS5nUbU$UR SS5$)zWhether a bundle1 operation is allowed from the server. Priority is: 1. server.bundle1gd. (if generaldelta active) 2. server.bundle1. 3. server.bundle1gd (if generaldelta active) 4. server.bundle1 r$s bundle1gd.%ss bundle1.%ss bundle1gdsbundle1)r%requirementsmodGENERALDELTA_REQUIREMENTr configbool)r)actionr%gdvs r bundle1allowedrFms B  1 1T5F5F FB MM)_v%= > =H i!78A} MM)\ 2 =H ==J //r"pushcF^^^^[RR5VVs1sHup4USS:XdMUiM snnmTS;a[R"ST-5eTcSm[ T[ 5(d[R"S5eUUUU4SjnU$s snnf)a{Decorator to declare a wire protocol command. ``name`` is the name of the wire protocol command being provided. ``args`` defines the named arguments accepted by the command. It is a space-delimited list of argument names. ``*`` denotes a special value that says to accept all named arguments. ``permission`` defines the permission type needed to run this command. Can be ``push`` or ``pull``. These roughly map to read-write and read-only, respectively. Default is to assume command requires ``push`` permissions because otherwise commands not declaring their permissions could modify a repository that is supposed to be read-only. sversionrrGpullsCinvalid wire protocol permission; got %s; expected "push" or "pull"r"s:arguments for version 1 commands must be declared as bytesc>T[;a[R"ST-5e[R"UTTTS9[T'U$)Ns+%s command already registered for version 1)r3 transports permission)r/r ProgrammingErrorr commandentry)r1r3namerMrLs r register"wireprotocommand..registersL 8 ((>E (44 t z  r")r TRANSPORTSitemsr rN isinstancebytes)rPr3rMr=rErQrLs``` @r wireprotocommandrWs %//5577da1Z=A;M7J++$$ 13= >   | dE " "$$ I     O;s BBsbatchscmds *rJ)rMc [Rn/nURS5GHnURSS5upx0n URS5H/n U (dM U RS5upU"U 5X"U 5'M1 [Uup[URnUS;deUR U5 U(awUR5n0nUHAnUS:Xa00nU R 5HnUU;dM U UUU'M UUS'M9U UUU'MC U "X/UVs/sHnUUPM snQ76nOU "X5n[U[R5(aUs $[U[R[45(de[U[R5(a URnUR[R"U55 GM [R"SRU55$s snf)N; rr=rI*)runescapebatchargrr/rM checkpermr:rUooberror bytesresponserVdataappendescapebatchargr8)r)rcmdsr; unescapeargrespairopr3valsanrEr1r2permr:rar=starkeyresults r batchrps 11K C 4 ::dA&D!Aqwwt}'21~[^$"b\ |&&))))  ::#?#?"GHHHH fn:: ; ;[[F >0089K!N  ' ' # 77)@s!H sbetweenspairscFURS5Vs/sHn[R"US5PM nn/nURU5H+nUR [R "U5S-5 M- [R "SRU55$s snf)NrZ- r")rr decodelistbetweenrb encodelistr`r8)r)rpairsprbs r rurus9>T9J K9JA^ & &q$ /9JE K A \\%  **1-56!  ' ' 44 Ls!B branchmapcJUR5n/nUR5HYupE[R[R "U55n[ R"U5nURSXg4-5 M[ [ R"SRU55$)Ns%s %srs) branchmaprTurlreqquoter fromlocalrrvrbr`r8)r)rr}headsbranchnodes branchname branchnodess r r}r}s I E"* \\("4"4V"<= $//6  X 99:+  ' ' 5(9 ::r"sbranchesnodesc[R"U5n/nURU5H+nUR[R"U5S-5 M- [R "SR U55$)Nrsr")rrtbranchesrbrvr`r8)r)rrryrzs r rrsa  % %e ,E A ]]5 ! **1-56"  ' ' 44r"sget_cached_bundle_inlinespathc[R"URS5(a"[R"URUSSUS9 URRSS5nURR U5nURR X25nURR U5(d[R"SU-5e[RRU5n[RRU5RU5(d[R"SU-5eSnU"URU5n[R"USS 9$) z4 Server command to send a clonebundle to the client spretransmit-inline-clone-bundleT)throwclonebundlepathr$speer-bundle-cache-rootsclonebundle %s does not exists'clonebundle %s is using an illegal pathc3 # U"USS9n[R"UR55Sn[R"U5v [R "U5ShvN SSS5 gN !,(df  g=f7f)NF) auditpath)osfstatfilenor uvarintencode filechunkiter)vfs bundle_pathflengths r generator+get_cached_bundle_inline..generator%sd  .!XXahhj)!,F$$V, ,))!, , ,/ . -/ .s/BAA3#A1$A3( B1A33 B=Bgenprefer_uncompressed)rhashookr%r&rr8existsr Abortrpathrealpathrr streamres) r)rr bundle_rootbundle_root_dirrclonebundles_dirrstreams r get_cached_bundle_inliner s  ||DGG?@@ GG  .  ''..,EFKhhmmK0OhhmmK6O 88??? + +kk:TABBww''8 77  O , 7 78H I IkkDtKLL-txx 1F  # #D IIr"s clonebundlesr"c:[R"U5n/nUR5H:nUR[R5(aM)UR U5 M< UR S5 [ R"SRU55$)zA legacy version of clonebundles_manifest This version filtered out new url scheme (like peer-bundle-cache://) to avoid confusion in older clients. r"rs) r get_manifest splitlinesrCLONEBUNDLESCHEMErbrr`r8)r)rmanifest_contentsmodified_manifestlines r clonebundlesr0s%11$7!,,. ??<99 : :   &/S!  ' ' 3D(E FFr"sclonebundles_manifestr\cZ[R"U5n[R"U5$)aServer command for returning info for available bundles to seed clones. Clients will parse this response and determine what bundle to fetch. Extensions may wrap this command to filter or dynamically emit data depending on the request. e.g. you could advertise URLs for the closest data center given the client's IP address. The only filter on the server side is filtering out inline clonebundles in case a client does not support them. Otherwise, older clients would retrieve and error out on those. )rrrr`)r)rr3rs r clonebundles_2rBs'%11$7  ' '(9 ::r")lookupr{pushkeyknown getbundles unbundlehashcR[[5n[RSU5(aUR S5 [ R "U5(aURRSS5(aUR S5 [ R"U5nU[R1- (dUR S5 O,UR SSR[U55-5 URRSS 5(aP[R"[R "USS 95nUR S ["R%U5-5 UR S SR[R&5-5 URRSS 5(a_UR [(R*5 URRSS5(aUR [(R,5 UR/X5$)areturn a list of capabilities for a repo This function exists to allow extensions to easily wrap capabilities computation - returns a lists: easy to alter - change done here will be propagated to both `capabilities` and `hello` command without any other action needed. changegroupsubsetr$spreferuncompressedsstream-preferredsstreams streamreqs=%srs experimentalsbundle2-advertise)rolesbundle2=s unbundle=%ssnarrowsnarrowservebrokenellipses)list wireprotocapsr/commandavailablerbrallowservergenerationr%rBstreamed_requirementsr@REVLOGV1_REQUIREMENTr8sortedr encodecaps getrepocapsr~rbundlepriorityr NARROWCAP ELLIPSESCAPaddcapabilities)r)rcapsrequiredformatscapsblobs r _capabilitiesr^s  D  !5u== ()((.. 77  i)> ? ? KK+ ,%;;DA/"F"F!GG KK " KK(499VO5L+MM N ww/+?@@%%g&9&9$Y&OP K&,,x"889KK7+A+A!BBC ww/955 N,,- 77  o/K L L KK22 3   ,,r"s capabilitiesct[X5n[R"SR[ U555$)NrZ)rrr`r8rr)rrs r capabilitiesrs*  %D  ' ' &,(? @@r"s changegroupsrootsc^[R"U5n[R"XUR 5S9n[ R "XSS5m[U4SjS5n[R"US9$)N missingroots ancestorsof01servec&>TRS5$Nireadcgsr changegroup.. rwwu~r"r"r) rrtr outgoingrchangegroupmodmakechangegroupiterr)r)rrootsrrrrs @r r r sb  % %e ,E!! djjlH  ' 'x HB %s +C  # # ,,r"rs bases headsc^[R"U5n[R"U5n[R"XUS9n[R "XSS5m[ U4SjS5n[R"US9$)Nrrrc&>TRS5$rrrsr r#changegroupsubset..rr"r"r)rrtr rrrrr)r)rbasesrrrrs @r changegroupsubsetrsg  % %e ,E  % %e ,E!!$NH  ' 'x HB %s +C  # # ,,r" debugwireargss one two *c [SSS/U5n[R"UR"X#40[R "U5D65$)Nrsthreesfour)r>rr` debugwireargsr strkwargs)r)ronetwor;r<s r rrsI #h%8& AD  ' ' 3@x'9'9$'?@ r"c^^^SnURRS5nU(dg[R"X5n[R"XSS9nU(dgUR 5R mTRUV s/sHn TRU 5PM sn SS9mTRUV s/sHn TRU 5PM sn SS9m[U5n UGH#n U RS5n [RRRU 5n U (a X;aX;aMQSU ;a_U"U S5nURU5(aM{[!UU4S jU55(aM[#UUU4S jU55(aMS U ;a)U"U S 5n[!UU4S jU55(dMU S nUR$R'SU-5 URR)U5s $ gs sn fs sn f![a GMAf=f![a GMSf=f![*a# UR$R'SU-5 GMf=f)ayReturn a file object for the first matching pullbundle. Pullbundles are specified in .hg/pullbundles.manifest similar to clonebundles. For each entry, the bundle specification is checked for compatibility: - Client features vs the BUNDLESPEC. - Revisions shared with the clients vs base revisions of the bundle. A bundle can be applied only if all its base revisions are known by the client. - At least one leaf of the bundle's DAG is missing on the client. - Every leaf of the bundle's DAG is part of node set the client wants. E.g. do not send a bundle of all changes if the client wants only one specific branch of many. cxURS5Vs1sHn[R"U5iM sn$s snf)NrY)rbinascii unhexlify)shs r decodehexstring(find_pullbundle..decodehexstrings-/0wwt}=}!""1%}===s 7spullbundles.manifestNT) pullbundles) inclusives COMPRESSIONheadsc3L># UHnTRU5T;v M g7fNrev.0rcl common_ancs r "find_pullbundle..sE 266#;*, !$c3># UH4nTRU5T;=(a TRU5T;v M6 g7frr)rrrr heads_ancs r rrs:'Cs 9,NJ1NN's# UHnTRU5T;v M g7frrrs r rrsILSrvvc{j0LrsURLssending pullbundle "%s" spullbundle "%s" not accessible )rtryreadrparseclonebundlesmanifestfilterclonebundleentries unfiltered changelog ancestorsrr!getr compengines _bundlenames TypeErrorissubsetallanyr%debugopenOSError)r)rr<clheadsrcommonrmanifestrfr compformatsentrycompaltcomp bundle_heads bundle_basesrrrrs @@@r find_pullbundlers- >xx 78H   0 0 @C  / /t LC    $ $B U;UcbffSkU;t LIf=fsrvvc{f=NJ*51Kyy(""//33D9 D+0J  u  .uX? $$V,,E EEE' u  .uX? ILIIIV}  2T9: 88==& &CJ Q<=      GGMM=D E  sBH 6H< H! H)-H; H&%H&) H87H8;(I('I(rc[S[RR5U5nUR 5HupE[RUnUS:Xa[R "U5X4'M8US:Xa[ URS55X4'M\US:Xa[URS55X4'MUS:XaUS:XaSX4'M[U5X4'MUS :wdM[S U-5e [US 5(dq[R"URS 55(dGURS :Xa[R "["5$[$R&"[([*S9e[UR,R/55n[URS[555n[URS[555n U R1UR25 UR4R7SS5(aQSUR95;a=[;XX7X5n U (a)[R<"[>R@"U 5SS9$UR4R7SS5(aLURSS5n U (a3U (d,Xx:Xa'[$R&"[CS5[CS5S9e[RD"US40[FRH"U5D6upU RSS5n[R<"X(+S9$![$R&Gan[R"URS 55(d9URS :Xa([R "URJS-5sSnA$e[LRN"UR45nSURJ4/n/nURPbURSSURP45 URU[LRV"SUU55 URY5n SnSnAGN+SnAff=f) Nrrscsvrsscsvsboolean0Fsplains unknown getbundle option type %srJs bundlecapshttp-v1hintrscommonr$s pullbundles partial-pullTrsdisablefullbundlescgs%server has pull-based clones disableds/remove --pull if specified or upgrade Mercurialrsprefercompressedrsmessagehint error:abort)-r>rGETBUNDLE_ARGUMENTSr:rTrtrrsetboolKeyErrorrFr bundle2requestedr rPr_bundle2requiredr rbundle2requiredmainbundle2requiredhintr rdiscardnullidr%rBrrrrrrgetbundlechunksrrmessagerbundle20r$rbaddpart bundlepart getchunks)r)rr;r<r=rEkeytyperrrbundler infochunksprefercompressedexcbundlermanargsadvargss r getbundlerAsh n88==? D  44Q7 h $//2DG  1774=)DG  !''$-(DG  "Dyq'  >HI I!$ $ ( (((-)@AAzzZ'%..??++18KL L+!dnn**,-DHHXsu-.TXXi/0t{{# GG  y- 8 85#5#5#77%T$OF%//**62 77  i)= > >((5$/K6g.>kk>?MN  // ( &006  88$7>"  # # (< ! ;;!((-)@AAzzZ'%..s{{U/BCC ""477+ ,- 88  NNGSXX. /**>7GLM""$ !s.6C5L2,B-L22Q AQ#Q )BQQ rc|UR5n[R"[R"U5S-5$)Nrs)rrr`rv)r)rrs r rrBs. A  ' '(A(A!(Du(L MMr"shelloc^[X5Rn[R"SU-5$)aNCalled as part of SSH handshake to obtain server info. Returns a list of lines describing interesting things about the server, in an RFC822-like format. Currently, the only one defined is ``capabilities``, which consists of a line of space separated tokens describing server abilities: capabilities: scapabilities: %s )rrarr`rs r hellorDHs+  $ ) )D  ' '(=(D EEr"slistkeys namespacec[UR[R"U55R 55n[ R "[R"U55$r) rlistkeysr tolocalrTrr` pushkeymod encodekeys)r)r namespaceds r rGrGXsEt}}X--i89??ABA  ' ' (=(=a(@ AAr"rkeyc[R"U5nURU5n[U5nSn[R"SXe4-5$![a"n[ R "U5nSnSnANASnAff=f)Nrrs%d %s ) r rHlookupr Exceptionr forcebytestrrr`)r)rrnr=rkrysuccessinsts r rOrO^ss   S ! KKN F  ' ' g\(A BB   # #D )s4A A<A77A<rsnodes *cSRSUR[R"U5555n[R"U5$)Nr"c3H# UHo=(a S=(d Sv M g7f)1r!N)rrzs r rknown..ms$Pq dd$Ps ")r8knownrrtr`)r)rrr;rEs r rYrYksD $(JJ~/H/H/O$P A  ' ' **r"s protocapsscapscUR[R:Xa[UR S55Ul[R "S5$)NrZsOK)rPrSSHV1r)r _protocapsr`rs r protocapsr]ss; zz^)))tzz$/0  ' ' ..r"rsnamespace key old newcr[U5S:XaC[R"U5U:wa)URS5 [R "U5nO[R "U5nUR5nUR[R "U5[R "U5[R "U5U5=(d SnSSS5 W(aUR5OSn[R"S[W5U4-5$![ a Nf=f!,(df  N[=f)Nzutf-8Fr"s%d %s) lenr escapestrdecoder rHUnicodeDecodeErrormayberedirectstdiorgetvaluerr`int)r)rrKrnoldnewoutputrys r rrzs 3x2~*..s3s:  JJw ""3'Cs#  ! ! #v LL  +  %  %      $#)V__ cF  ' ' SVV4D(D EE#"    $ #s'D9AD( D%$D%( D6s stream_outcV[R"[R"U55$)zIf the server supports streaming clone, it advertises the "stream" capability with a value representing the version and flags of the repo it is serving. Client checks to see if it understands the format. )rstreamreslegacyrgeneratev1wireproto)r)rs r rrs  ) )+*I*I$*O PPr"sunbundlec ^^^[R"U5nUR5n[R"XS5 SnUR 5mUR RSS5(aU4Sjn[R"T5mOSummUU4Sjn[R"SS 9unmUR RS T-5 [R"U[R"S 55mTHnTR!U5 M TR#S 5 [R$"UR TS5n['U[(R*5(ah[-US 5(dWUR.S:Xa*[R0"[25U"5 sSSS5 $[4R6"[8[:S9e[R<"XUSUR?55n [AU S5(a2[RB"U RE5S9U"5 sSSS5 $[RF"X(aURI5OS5U"5 sSSS5 $!U"5 f=f![4RJ[4R6[4RL4Ga8n [OU SS5(Gde![4R6an [PRRR!U RU55 [PRRRW5 [RF"S U(aURI5OS5sSn A sSn A sSSS5 $Sn A f[4RLaS [RX"[RZ"U 5U(aURI5OS5ssSn A sSSS5 $f=f[\R^"UR 5n [OU SS5Hn U RaU 5 M e![4RbGa'n [OU SS5n U bSU ReSS5;aeU RgS5nURiSU Rj5 U RlbURiSU RlSS9 U RnbURiSU RnSS9 U RpbURiS U RpSS9 U RrbURiS!U RrSS9 U RtbURiS"U RtSS9 Sn A GObSn A ff=f![4RJan U RgS#5nU RvbURiS$U Rv5 U Rx(a+URiS%S&R{U Rx55 Sn A OSn A f[4R6aln S'U R|4/n/nU R~bURS(U R~45 U Ra[\R"S)UU55 Sn A OMSn A f[4RLa3n U RgS*S'[R"U 54/5 Sn A OSn A ff=f[RB"U RE5S9sSn A sSSS5 $Sn A ff=f!,(df  g=f)+Nspreparing changescgrrWrWr"r runbundle..sdr"r$sstreamunbundlec>THnM grrW)rxpayloads r cleanupunbundle..cleanups")A ")r")NNcp>T(aTR5 T(a[R"T5 ggr)closerunlink)fptempnamesr rrrss#HHJ#IIh/$r"s hg-unbundle-)prefixs"redirecting incoming bundle to %s swb+rrGr"r#rr5rr"duringunbundle2F_bundle2salvagedoutputrW _replycapsrserrors error:pushkeys in-reply-torE) mandatoryrMsnewsoldsretserror:unsupportedcontentsparttypesparamsr%r&r'serror:pushraced)Drrtrdr check_heads getpayloadr%rBr chunkbufferrmkstemprrfdopensysstrr7seek readbundlerUr cg1unpackerrFrPr_r-r rr.r/unbundleclienthasattrrkr7pushresreBundleValueError PushRacedgetattrrr6formatflushpusherrbytestrrr4r5 PushkeyFailedr newpartaddparampartidrKrnrhrgretparttypeparamsr8r3r$rbr6rrQ)r)rr their_headsrirrfdrxrryr=r>out remotecapsparterrpartr?r@rwrqrxs @@@r rrs ++E2K  ! ! #vB K  4H I"G8 **,77%%i1BCC! ))'2B$.LB0 $,#3#3?#KLBGGMM>I2xv'>?B$ %GGAJ))$''2t<33(w77zzZ/ .66G" y $ #X +++2E%%{Helln1i((*99akkmL  y $ #n&--Fv(  y $ #x && U__EE K3 1599{{  OO))#**,7OO))+)116??,CU $ #Z)11 ((--3)] $ #Z &&tww/Gs$?@  "11g6G6G6IJ JG $ #|E K} $ #s&[7JE I<'J8A6I<.J?,I<+J< JJ4[4<[/KO%A8M1O[/"[4#[71AO [/ [4 [7OA[/%P&&U";DUU%[/U""U%%Z<9A6W4/[/4Z< A"Y2-[/2Z< )Z72[/7Z<<$[/ [4![7/[44[77 \)F)NrG)A __future__rrri18nrnoderrrr rr r r r rrrIrrrr@rrrutilsrrurlerrr~r.r/r-r!r-r4r>rF commanddictr/rWrprur}rrrrrrrrrrrArrDrGrOrYr]rrrWr"r rs6# $  JK@ #68K"LL  %*$ 0<  % % ',`(I':*8;*8Z*h7;5<5,73;4;+xG<5=5-w7K JL JF/37;G<G"*DWE;F;" &-V/g6A7A .(w?-@-&7K-L-"LWEFCL,9K:K\(w/N0N (w/ F0 F+|@BAB )V8 C9 C(J7;+<+,G</=/ *67KFLF8-G4Q5Q+xG<FK=FKr"