[ ]ddlZddlZddlmZddlmZmZddlmZ m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlm Z m!Z!m"Z"ddl#m$Z$ejJZ%ejLZ&dZ'dnd Z(d Z)d Z*d Z+d Z,dZ-GddZ.ededfededfededfdZ/ dodZ0gZ1iZ2dZ3dZ4dZ5e3ddZ6e3ddZ7e3d d!Z8e3d"d#Z9d$Z:d%Z;gZd'Z?d(Z@e>d)d*ZAe>d+d,ZBe>dd-ZCe>dd.ZDd/ZEd0ZFe>d1d2ZGe>d"d3ZHd4ZId5ZJd6ZKd7ZLe>d8d9d:ZMd;ZNd<ZOd=ZPejfd>ZRd?ZSd@ZTGdAdBZUGdCdDejZWdEZXdFZYdGZZ dpdHZ[gZ\iZ]dIZ^dJZ_e^dKdLZ`e^dMdNZadOZbdPZcdQZddRZedSZfdTZgdUZhdVZidndWZjdXZkgZliZmdndYZndZZo dqd[Zpend\d]ZqendM drd^Zrend" dsd_Zsend` dsdaZtend1 dtdbZuendc dtddZvende dqdfZwendg dqdhZxdiZydjZzdkZ{dlZ|dmZ}y)uN)_)hexnullrev) bookmarksbundle2 bundlecaches changegroup discoveryerrorlock logexchange narrowspecobsoleteobsutilphasespushkeypycompat requirementsscmutil streamcloneurlutilwireprototypes)hashutil stringutilurlutil) repositorys narrowaclcrtj|d}d}|s?d}|jds?|jdr.tj||}d}d}n|r|j |}|dd|dd}}|dk7r!t j td |z|d k(r.|tj|d}tj||S|jd rtj||||z S|d k(rtj|St j td||fz)NstreamsHGsHG10sUNrs%s: not a Mercurial bundles102) magicstringsS1s%s: unknown bundle version %s) r readexactly startswithheaderlessfixupjoinr Abortr cg1unpackerr getunbundlerrstreamcloneapplier)uifhfnamevfsheaderalgmagicversions 6usr/lib/python3.12/site-packages/mercurial/exchange.py readbundler74s4  $ $R +F C   'F,=,=e,D,,R8BFC Aa[&1+7E ~kk!9:UBCC% ;))"a0C&&r3//   D !##BHH E --b11kk . /5'2B B  cg}t|jD]0\}}tj|}|j d||fz2dj |S)Ns%s=%s;)sorteditemsurlreqquoteappendr))paramspartskeyvalues r6_format_paramsrDSsT EV\\^, U U# Xe ,-- 99U r8cd}i}t||d}t|tjrC|j}|dk(rd}||}|s!t j td|zd|zSt|tjrd|jvr8||jd}|s#t j td|zd}d}|jD]I}|jd k(rN|jd } | d vrd })| d vrd }| |d<5t j td|ztd|jdk(rQ|Otj|jd} | j} tj | }d|zcS|jdk(rQ|Otj|jd} | j} tj | }d|zcS|jdk(s2d|d<|j"rEd|d<L|st j tdd||fz} |r| dz } | t%|z } | St|t&j(r2t'j*|d} tj | } d | zSt j td!|z)"zInfer the bundlespec from a bundle file handle. The input file handle is seeked and the original seek position is not restored. c tjj|jdS#t$rYywxYwNr)r compengines forbundletype bundletypeKeyError)r3s r6speccompressionz&getbundlespec..speccompressionbs> ##11#6AACAF F  s /2 >>Ns _truncatedBZsBZs!unknown compression algorithm: %ss%s-v1s Compressionsnone changegroupversion)01s02sv2)s03s cg.versions7changegroup version %s does not have a known bundlespecs#try upgrading your Mercurial clienthintsstream2s requirementssnone-v2;stream=v2;%ss stream3-expsnone-v2;stream=v3-exp;%s obsmarkerssyess obsolescencesnosobsolescence-mandatorys0could not identify changegroup version in bundles%s-%sr:r#snone-packed1;%ssunknown bundle type: %s)r7 isinstancer r+_typer r*rr unbundle20r@ iterpartstyper=unquotesplit_formatrequirementsparams mandatoryrDrr-readbundle1header)r.r/rLr@br3compr5part cgversionrsplittedspec formatteds r6 getbundlespecrd[s F2r4 A![,,-gg / !Cs#++a DEKL L$ Aw)) * QXX %"188N#;ICD++c- - "r8c|jj}|jdd}d|vxrd|v}|xs|jj d S)zsreturn true if a pull/push must use bundle1 This function is used to allow testing of the older bundle versiondevellegacy.exchangebundle2sbundle1)rkr. configlistrzcapable)opr.exchange forcebundle1s r6 _forcebundle1rsU B}}X'9:HX-H*2HL  z.pushoperation.fallbackheads..ts/1affh) r|rj commonheadsrk unfilteredrlrfindexrevrmissingextend)runfirlrrcheadsrevsets r6 fallbackheadszpushoperation.fallbackheadsUs 99 ==,, ,yy##%%%ii!!''++#'99D94D V0C$9D * MM % % MM ! !   /// Es C6C6cJ|jr |jS|jS)z3set of all common heads after changeset bundle push)rrrrs r6rzpushoperation.commonheadsws# ==## #%% %r8FNFFN) __name__ __module__ __qualname____doc__rr propertycacherrpropertyrrr8r6rrsk IV )) B&&r8rsupdating bookmark %s supdating bookmark %s failed sexporting bookmark %s sexporting bookmark %s failed sdeleting remote bookmark %s s#deleting remote bookmark %s failed )updateexportdeletec 2|i}t|||||||fitj|}|jj rt |j j|jj jz } | r;tddjt| z} tj| |jjstjtd|jjdstjtdtt!j"|jD]j} |j$j'D]\} } | j)| s7tjtdtj*| zdx}} |j,j/dd }t1|s1|r/t3j4|s|j j7}|j j9}t;|j d |jj=|_|xstIjJ5|xstIjJ5|j>xstIjJ5|j jM|tO|tQ||jRs tU|t1|s tW|tY|t[|t]|t_|ddddddddd|j,j/dd rtajb|||S#tj@$r>}d tCjD|z} |j,jG| Yd}~wd}~wwxYw#1swYxYw#1swYxYw#1swYxYw) aWPush outgoing changesets (limited by revs) from a local repository to remote. Return an integer: - None means nothing to push - 0 means HTTP error - 1 means we pushed and remote head count is unchanged *or* we have outgoing changesets but refused to push - other values as described by addchangegroup() N:required features are not supported in the destination: %s, s!destination does not support pushunbundlesLcannot push: destination does not support the unbundle wire protocol commandsJcannot push: required sidedata category not supported by this client: '%s'rqbundle2.pushbacks push-responses"cannot lock source repository: %s remotenames)2rr strkwargsrzlocalrrkr supportedrr)r;r r*canpushrrread_remote_wanted_sidedata_sidedata_computersr<r{bytestrr. configboolrbookmodbookmarksinstorewlockr transactionmanagerrrLockUnavailabler forcebytestrdebugrnullcontextmanager checkpushr_pushdiscoveryr_checksubrepostate _pushbundle2_pushchangeset_pushsyncphase _pushobsolete _pushbookmarkrpullremotenames)rkrzrr|rrrxopargsrrrcategorykind computersrr maypushbackerrs r6pushrsi$~        V $ F}}  (( )FMM,?,?,A,K,K K  F7O, .C ++c" " == "kk!@ABB ==  -kk 2   7>>v}}MN $77==?OD)}}X& @++-""8, - OEDii**?   +$))+ +  .T,,. .!!>T%<%<%>> %%f-f%v&||&v.$V, (v&v&f%f%?/ , ww/>:##D&1 M7  5z7N7N 8    ?>/ . , +sVB&N!P '#P B O5PP !O243O--O25O> :PP P  Pcfd}|S)a|decorator for function performing discovery before push The function is added to the step -> function mapping and appended to the list of steps. Beware that decorated function will be added in order (this may matter). You can only use this decorator for a new step, if you want to wrap a step from an extension, change the pushdiscovery dictionary directly.cXtvsJ|t<tj|Sr)pushdiscoverymappingpushdiscoveryorderr?funcstepnames r6deczpushdiscovery..dec03333)-X&!!(+ r8rrrs` r6 pushdiscoveryr  Jr8c<tD]}t|}||yzRun all discovery stepsN)rr)rrsteps r6rr&#H- V 'r8c|j}t|jdrt|jdsy|jjD]j}||}d|j vsd|j vs.t|jD]%}|j|}|jd'ly)zDEnsure all outgoing referenced subrepo revisions are present locallys.hgsubs .hgsubstateNT)onpush) rkrfilerjrmanifestfilesr;substatesubverify)rrkrnctxsubpathrs r6rr$s ;;D tyy# $C .0I,J __ $ $1g   &>SYY[+H!#,,/ggg& $ '0 %r8s changesetctj}|jr5||j|j|j |j}n)||j|j|j }|\}}}tj }||j|j|j||j }||_||_||_ y)z-discover the changeset that need to be pushed)rr)r) onlyheads commonincrN) r findcommonincomingr|rkrzrfindcommonoutgoingrjrr)rfcir rlincrfcorjs r6_pushdiscoverychangesetr7s  & &C {{ KK MM,,   V]]&,,G (FC  & &C  ++ll HFO$FFOr8sphasec|j}|jj}t|jd}|j j ddr9|r7|jjs!|jddrg|_ g|_ ytj|j|j||_|jj}d}|jj sd}d |z}t#|j%|||j}|jj s3|j&r't#|j%d |j(|}nx|js|}nit#|j%d |j|} | D cgc]} | j+} } t#|j%|| |j(}||_ ||_ ycc} w) zpdiscover the phase that needs to be pushed (computed for both success and failure case for changesets push)ruui_usedassubreporvFNr8s and public()sheads((%%ln::%%ln) %s)s%ln and (not public() or %ln::)sroots(%ln + %ln::))rjrkrryrzr.rrr{rrrremotephasessummaryrr draftroots publishinglistrrxrr) rrjrrdroots extracondrfallbackfuturefdrootsfs r6_pushdiscoveryphaser!Rs H ;; ! ! #DFMM95L  U$56 ''   ]E 2!#(*% 44 V))<F + +FI    ) )$ & 2FDHHVVV-A-ABCH    ) )fnn HH2F4F4F       HH+X-=-=v F &--W1668W-dhhvw0B0BCD"F$,F!.sG-s obsmarkercttj|jtjsy|jjsydt |j dvry|j}d|jd|jD}|jjj||_ y)Nobsoletes namespacesc3<K|]}|jywrrrs r6rz+_pushdiscoveryobsmarkers..s FE!QVVXEr::%ln) r isenabledrk exchangeoptobsstoreryrzrrrelevantmarkersr)rrknodess r6_pushdiscoveryobsmarkersr+s   fkk8+?+? @ ;;  (6==-@@ ;;D Gtxx&2D2DE FE!;;//??FFr8 bookmarkscR|j}|jj}|j}|j dd}|j rQt j|jj|j }|jj|d}tjt|d}|jDchc]}|jj!|}}tj"||j|} t%||||| Scc}w)Nschecking for updated bookmarks rT) inclusiver,)r.rkrrzrr|rmaplistrfr ancestorsrunhexlifybookmarksryr _bookmarks expandnamecomparebookmarks_processcompared) rr.rkrzr0revnumsremotebookmarkbookmarkexplicitr^s r6_pushdiscoverybookmarksr:s B ;; ! ! #D ]]FHH 01I {{""4>>#5#5v{{CNN,,W,E //0NON>D=M=M=M""8,=M   # #D$//> JD FIx NN s"D$c|\}}}}} } } } |j} |D]Q\}}}||vr|j||r| |j|vs4|jj |||fS|D]~\}}}||vs |j|t j |r/|jjtd|zd|_ a|jj |d|ft|t| zt| zD]:\}}}||vs |j||jj |||f<|D]:\}}}||vs |j||jj ||df<| D]\}}}||vs |j||rbookmark %s does not exist on the local or remote repository! rN)rkremoverrr?r isdivergentr.r~rrrr;sort)rpushedr9 remotebmsr^addsrcadddstadvsrcadvdstdivergedifferinvalidsamerkr]sciddcids r6r5r5s FJBFFFFGVWd ;;D 4 = OOA d)V3    & &4 7   4 = OOA ""1% q!HIAMN"###**AsD>: fW 5V D 4 = OOA     & &4 7E  4 = OOA     & &4~ 6   4 = OOA (#  + qk    r8cn|j}|jj}|js,t j |j ||jy|js|jrtd}td}td}td||d}|jD]k}||}|jrtj||z|jsAtj||j!d|zt#j$|y) NFs%push includes obsolete changeset: %s!s,push includes phase-divergent changeset: %s!s.push includes content-divergent changeset: %s!s#push includes orphan changeset: %s!)sorphansphase-divergentscontent-divergentrT)rjrkrrrnochangesfoundr.excludedrr(rrrr r* isunstable instabilitiesr checkheads) rrjrmsomspdmscdmstrr s r6_pushcheckoutgoingrUs H ;; ! ! #D   twwh.?.?@ << ==<=CDEDFGDCD$(&*C!,,4j<<>++cCi00^^% ++c#*;*;*=a*@&AC&GHH- V$ r8cfd}|S)awdecorator for function generating bundle2 part The function is added to the step -> function mapping and appended to the list of steps. Beware that decorated functions will be added in order (this may matter). You can only use this decorator for new steps, if you want to wrap a step from an extension, attack the b2partsgenmapping dictionary directly.ctvsJ|t<tj|Stj|Sr)b2partsgenmappingb2partsgenorderr?insertridxrs r6rzb2partsgenerator..dec'sN0000&*(# ;  " "8 ,   " "3 1 r8rrr\rs`` r6b2partsgeneratorr^ Jr8c|js|jjrd|jj ddv}|j du}|r|r'|j dt|jyt}|j jD]<\}}|\}}} } |t|} |t| | zz}|| t|z z}>|r(tt|} |j d| yyyy)zdGenerate race condition checking parts Exists as an independent function to aid extensions srelateds checkheadsrNs check:headsdatascheck:updated-heads) rrjr capabilitiesr{rnewpartiterrrr<r;) rbundlerallowunrelated emptyremoteaffectedbranchrirnewheads unsyncedheadsdiscardedheadsrzrbs r6_pushb2ctxcheckheadsrn3s < F8,- 6TB8rtrd)rrfru hasphaseheadspchecksphaserzs r6_pushb2checkphasesrhs  F v||   /F 9b 99M &=!'!1!12!1A!R%!12v}}$$V%8%8%D%DEv||##F$7$7$B$BC v}} u ""$ ++F3I OOO)O < ,9&2s, Ec djvryjjdtsyjj t |t jj}d}|jd}|r[|Dcgc]%}|tjjvr|'}}|stjtdt|}t j j}tj"jj$|d||}|j'd| |r j)d |t+j,jr j)d d t.j0jj2vr j)d d  fd }|Scc}w)zwhandle changegroup push through bundle2 addchangegroup result is stored in the ``pushop.cgresult`` attribute. changesetsNrOrMno common changegroup versionpush bundlecapsremote_sidedatararN treemanifest1 exp-sidedatac|jjj}t|ddk(sJ|ddd_y)z0extract addchangegroup returns from server replyrMrrreturnN)records getrepliesidrr)r cgrepliescgpartrs r6 handlereplyz_pushb2ctx..handlereplysIJJ))&))4 9^,-222#N3A6yAr8)raddrUrkprepushoutgoinghooksrnrrsrzr{r supportedoutgoingversionsr r*rmaxr makestreamrjrdaddparamristreemanifestrREPO_FEATURE_SIDE_DATAfeatures) rrfrur5 cgversionsvrcgstreamrrs ` @r6 _pushb2ctxr{s ((( ' f % KK$$V,)   /FGN+J  K99&++FF   ++a @AB Bj/99&--HO%% ' H__^(_ ;F G,fkk*.((FKK,@,@@.B A s*Gc d|jvrytj|j}|jj }d|j ddv}d|v}d|jddv}|r|s t||S|r t||Sy)z!handle phase push through bundle2ruNrrpushkeyr}r) rrrsrzrkr.rr{_pushb2phaseheads_pushb2phasespushkey)rrfrur. legacyphase haspushkeyrs r6 _pushb2phasesrsF$$$   /F Br}}X7IJJKv%J 9b 99M[ 11 #FG44 r8c4|jjd|jrltjDcic]}|g}}|dj d|jDtj |}|jd|yycc}w)z6push phase information through a bundle2 - binary partrurc3<K|]}|jywrr)rhs r6rz$_pushb2phaseheads..sB,Aq!&&(,Ar phase-headsraN)rrrrr~rrtrd)rrfrupdates phasedatas r6rrs # "("2"23"2Q1b5"23 BF,A,ABB''0 Y7 3s BcJjjdgfd}tj}jD]}|j d}|j d|d|j d||j|j d|dtjz|j d|dtjzj|j|f|j|j<fd }|S) z7push phase information through a bundle2 - pushkey partruct|j}D]+\}}||k(s tjt d|zy)Nsupdating %s to public failed)intpartidr r*r)rexctargetidrr part2nodes r6 handlefailurez+_pushb2phasespushkey..handlefailures@szz?%LFD!kk!$C"Dt"KLL&r8r namespacekeyold%dnewcD]\}}|jj|}|d}t|dksJd}|std|z}nt |ddstd|z}|kj j |y)Nrrs'server ignored update of %s to public! rrupdating %s to public failed! )rrrrrr.r~)rrrpartrepresultsrrrs r6rz)_pushb2phasespushkey..handlereplys%LFDjj++F3Gj)Gw<1$ $$CCDtKI./:;dB s#&r8)rrrencoderrdrrrrrr?rr)rrfrenc newremoteheadr_rrs` @r6rrs #IM ..C.. z* lC N3 fc-"3"3"567 fc%&,,"678 fc%&--"789$''=12#0 / $ r8rRcFd|jvrytj|j}t j |y|jj d|jr6tj|j}tj||yy)NrR) rrobsmarkersversionrcr commonversionrrr sortedmarkersbuildobsmarkerspart)rrfremoteversionsmarkerss r6_pushb2obsmarkersrs(((..w/C/CDNn-5 ' ''(<(<=##GW5r8cd|jvrytj|j}|jj j dd}d|v}|sd|vr t||Sd|vr t||Sy)z$handle bookmark push through bundle2r,Nrrr) rrrsrzrkr.r_pushb2bookmarkspart_pushb2bookmarkspushkey)rrfrulegacy legacybookss r6_pushb2bookmarksrsv'''   /F [[^^ & &x1C DF&(K <61#FG44 v &vw77 r8c|sy|syy)z"small utility for bookmark pushingrrrr)rxrys r6 _bmactionrs   r8c|rP|j|jtjk(r!t j t d|zyy)z6abort if a given bookmark points to a secret changesets:cannot push bookmark %s as it points to a secret changesetN)rkrrsecretr r*r)rrr]s r6_abortonsecretctxrsH  D!'')V]]:kk K Lq P  ;tr8cxjjdjsygg}jD]C\}}}t|||j ||fj |t ||fEt jj|}|jd|fd}|S)Nr,racnj}D]#\}}|jt|d|z%yrG)r.status bookmsgmap)rr.rwaction allactionsrs r6rz)_pushb2bookmarkspart..handlereply/s5 YY&LD& IIj(+d2 3'r8) rrrrr?rrrtrkrd) rrfrbrwrxryrzrrs ` @r6rr!s &   J D --c3&#t, T3K 43!456.$$V[[$7I OOLyO14 r8c H jjdg tj} fd}jD]\}}}t |||j d}|jd|d|jd|||jd|t||jd|t|d}|sd }n|sd } j|j||f|j|j< fd } | S) Nr,ct|j}D];\}}}||k(s tjt|dj |zJ)Nr)rrr r*rrstrip)rrrrrwr part2books r6rz._pushb2bookmarkspushkey..handlefailure=sWszz?$- FD&!kk*V"4Q"7">">"@4"GHH%. ur8rrrrrrrrc j}D]\}}}|jj|}|d}t|dksJ|s( jj t d|zat |dd}|r|jt|d|z|j t|d|z jd _ y)Nrrs"server ignored bookmark %s update rr) r.rrrr~rrrrr) rr.rrwrrrretrrs r6rz,_pushb2bookmarkspushkey..handlereplyTs YY$- FD&jj++F3Gj)Gw<1$ $$ q!GH4OP'!*Y/0IIj03d:;GGJv.q1D892*+%.r8) rrrrrrrdrrr?rr) rrfrrrwrxryr_rrrs ` @r6rr8s &I ..C!--c3&#t,z* lC $56 fc$i( fc#c(m, fc#c(m,FF$''401#0 .," r8pushvars)r\c|j}|ri}|D]:}d|vrd}tj||z|jdd\}}|||<<|j d}|j D]\} } |j | | dyy)zsend shellvars via bundle2=sIunable to parse variable '%s', should follow 'KEY=VALUE' or 'KEY=' formatrrFr[N)rr r*rYrdr<r) rrfr shellvarsrawrkrr_rBrCs r6_getbundlesendvarsrhsH C34kk#),,99T1%DAqIaL{+#//+JC MM#uM 6,r8ctj|jtj|j}|j xr|jj dd}tjtj|j|d}|jd|g}tD]1}t|}|||}t|s!|j|3|jdkryt!j"|j%} |jj'5} | j)d |d g|jj+d j-} ddd d} |r|j j6} tj8|j | |j } |D] }|  y#1swYbxYw#t.j0$r&} t/j2t5d | zd} ~ wwxYw#t.j0$r&} t/j2t5d | zd} ~ wtj:$r} |jj/t5d| z| j<4|jj/t5dd| j<zzt/j2t5dd} ~ wwxYw#t.j>$rE} tA| jB}||jDvr|jD||| Yd} ~ d} ~ wwxYw)zpush data to the remote using bundle2 The only currently supported type of data is changegroup but this will evolve in the future.rqrclient) allowpushbackroles replycapsrarNrforce)sbundler}urlmissing support for %srzs remote: %s s(%s)spush failed on remote)#rbundle20r.rsrzrr encodecaps getrepocapsrkrdrYrXcallabler?nbpartsr chunkbuffer getchunkscommandexecutor callcommandrresultr BundleValueError RemoteErrorr transaction processbundle AbortFromPartrQ PushkeyFailedrrr)rrfpushbackcapsblob replyhandlers partgennamepartgenrstreamereplyrtrgetterrrrephands r6rr~s vyy'*=*=fmm*LMGFII$8$8,%H !!FKKxiPH OOLxO0M& #K0fg& C=   % ' !   g//1 2F"- H..0A #)#+* & 1 1 3&(1 AH!++77&& }} B$! !C10%% H##A&?$@3$FG G H%% H##A&?$@3$FG G$$ A IIOOAo.4 5xx# / 2g6H IJ##A&>$?@ @  A   -SZZ  ( ,, -st!G&;>G9G&AH"G#G&&H9!HHK9"K65!IK6,BK11K66K99M :M  Mcd|jvry|jjdt|sy|jj dsJ|j j ||j}d}|jR|jsF|j jjs&tj|j |ddd|}n$tj|j |dd|}|jrd g}n |j}|jj!|||j j#|_y) z7Make the actual push of changeset bundle to remote reporNrrOrT)fastpathrrr)rrrUrzrrkrrjr|rMrf filteredrevsr makechangegrouprrunbundlerr)rrjrcgrs r6rrs((( ' f % ==  -- - KK$$V,HJ {{V[[22?? ( ( KK   !   ( ( KK5'j ||j (( mm,,Rfkkoo>OPFOr8c |j}t|jd}|jj ddr$|r"|j |j ddrddi}|s t||ytj|j||}|\}}|j ddr t||n't||t||tj|j rd|jvry|j}n |j}|jjd|Dcgc]}|j!|vs|}}|D]}|jj#5} | j%dd|j'd tjzd tj(zd j+} ddd r~|jj-t/d |zycc}w#1swY;xYw) z2synchronise phase information locally and remotelyrurrNrvFsTruerrrrrrr)rryrzr.rrr{_localphasemoveranalyzeremotephasesrkrrrrrrrrrrrr~r) rrranapheadsroutdatedrrrrs r6rrs   FFMM95L U$56  OO #   ]E 2&w/ '((flK   M5 1 FF + FF + FFFLL 9 ??F,,,,,H44HY' (Bx!16686+AAxB%M..0AMM&/ - 1 1 3 % 4 % 5 &(1 89MI&C10s1G9 G9.AG>>H cv|jr;tj|j|jj ||y|Dcgc]%}||j|j ks$|'}}tj |}|r(|jjtd|zyycc}w)z0move to in the local source repos8cannot lock source repo, skipping local %s phase update N) rradvanceboundaryrkrr phasenamesr.rr)rr*rrn actualmovesphasestrs r6rr0s  KK))557 #(J%Q56;;q>3G3G3I+Iq% J$$U+  II  /   Ks %B62B6c 6d|jvry|j}|j}|jjd|jr|j j dg}tj|j}tj|}t|dD]*}||}|j|jd|d|,|Dcgc]}|r| c}r'td} |j j| yyycc}w) z5utility function to push obsolete markers to a remoterRNs'try to push obsolete markers to remote Treverser#r8s&failed to push some obsolete markers! )rrkrzrrr.rrrr_pushkeyescaper;r?rrr~) rrkrzrsltsr remotedatarBrbr rs r6rrFs((( ;;D ]]F '  CD''(<(<=,,W5 *d3Cc?D LL S#tD E4 &u!AAu &>?C GGLL  ' 's D&Dc D|jdk(sd|jvry|jjd|j}|j}|j D]\}}}d}|sd}n|sd}|j 5}|jdd|t|t|dj}dddr|jt|d|z|jt|d |z|jd |_ y#1swY_xYw) z"Update bookmark position on remoterr,Nrrrrrr)rrrr.rzrrrrrrrr~r) rr.rzr]rxryrrr s r6rr[s  !|v/?/?? & B ]]F** 3FF  # # % ".HH fh & IIj(+a/ 0 GGJv&q)A- .*"#1+& %s 8DD ceZdZdZ ddZej dZej dZej dZ dZ y) pulloperationzA object that represent a single pull operation It purpose is to carry pull related state and very common operation. A new should be created at the beginning of each pull and discarded afterward. Nc h||_||_| |_||_|D cgc]} |jj | c} |_||_||_d|_ d|_ d|_ d|_ ||_ d|_t|_d|_||_| |_| |_ycc} w)NF)rkrz remote_pathrir2r3explicitbookmarksrstreamclonerequestedrrlrheadsfetchremotebookmarksrrrclonebundleattempted includepats excludepatsdepth) rrkrzrirrr5r2r7r8r9pathr8s r6rzpulloperation.__init__s    BK" AJXDOO & &x 0"  $8!   . $)!&& 9" s"B/c|jSt|j}t|j}|jD]}||vs|j ||S|jS)z0heads of the set of changeset target by the pull)rirrlrr3r?)rrrrns r6 pulledsubsetzpulloperation.pulledsubsets_ :: DKK At{{#C[[A:JJqM!J:: r8ct| Sr)rrs r6 canusebundle2zpulloperation.canusebundle2s &&&r8c@tj|jSr)rrsrzrs r6remotebundle2capszpulloperation.remotebundle2capss""4;;//r8c6|jjSr)rrrs r6gettransactionzpulloperation.gettransactions~~))++r8) NFrNNNNNN) rrrrrrrr<r>r@rBrr8r6r.r.~s}! 5n " '' 00,r8r.c(eZdZdZdZdZdZdZy)rzAn object to manage the life cycle of a transaction It creates the transaction on demand and calls the appropriate hooks when closing the transaction.c<||_||_||_d|_yr)rksourcer_tr)rrkrErs r6rztransactionmanager.__init__s  r8cZ|jsd|jtj|jfz}|j j ||_|j|jjd<|j|jjd<|jS)z.headsofdiffs4hh+R4&)*cs c***3cpjd||}|Dchc]}|jc}Scc}w)zReturns heads((h1 + h2) - null)sheads((%ln + %ln - null))rUrVs r6 headsofunionz&_fullpullbundle2..headsofunions4hh3R<&)*cs c***r[c3@K|]}j|ywr)rg)rrnunficls r6rz#_fullpullbundle2..%s8-Qv~~a -s) rrfrir _pullbundle2rNARROW_REQUIREMENTallr3rlr) rkpulloprZr] old_headsclstart new_headsrr_s @@r6_fullpullbundle2rgs ?? D ^^F+ + LLN f+V  * *d.?.? ?  c&k !  8&--8 8   : $Y > FMM*V]]: ! r8c|jj}tj||ddt j |j fd}|jd|y)zadds a finalize callback to transaction which can be used to show stats to user and confirm the pull before committing transactionpullT)txnname as_validatorc}td}|jj|rtjdy)Ns+accept incoming changes (yn)?$$ &Yes $$ &Nos user aborted)rr.rr r*)trrkcmreporefs r6promptz$add_confirm_callback..prompt6s;y = > 77   #++o. . $r8s900-pull-promptN)rrrregistersummarycallbackweakrefrefr addvalidator)rkrcrmrpros @r6add_confirm_callbackru,s]    % % 'B ## b'kk$//+,G/ OO&/r8c F|i}|| |xs t}| xs t} n|j\}} tj|tj| t ||f||||||| | dt j |} | jj} | rit| j| jjz }|r;tddjt|z}tj ||j"D]j}|j$j'D]\}}|j)|s7tj*tdt j,|zt/|d|j1| _t5j6}t9j:|s|j=}|5|j?5| j25| s6|j@jCddr&|j@jEs tG|| tI| tKjL| tO| | jPr tS|| tU| tW| tY| t[| ddddddddd|j@jCdd rt]j^||| S#1swYMxYw#1swYQxYw#1swYUxYw) aFetch repository data from a remote. This is the main function used to retrieve data from a remote repository. ``repo`` is the local repository to clone into. ``remote`` is a peer instance. ``heads`` is an iterable of revisions we want to pull. ``None`` (the default) means to pull everything from the remote. ``bookmarks`` is an iterable of bookmarks requesting to be pulled. By default, all remote bookmarks are pulled. ``opargs`` are additional keyword arguments to pass to ``pulloperation`` initialization. ``streamclonerequested`` is a boolean indicating whether a "streaming clone" is requested. A "streaming clone" is essentially a raw file copy of revlogs from the server. This only works when the local repository is empty. The default value of ``None`` means to respect the server configuration for preferring stream clones. ``includepats`` and ``excludepats`` define explicit file patterns to include and exclude in storage, respectively. If not defined, narrow patterns from the repo instance are used, if available. ``depth`` is an integer indicating the DAG depth of history we're interested in. If defined, for each revision specified in ``heads``, we will fetch up to this many of its ancestors and data associated with them. ``confirm`` is a boolean indicating whether the pull should be confirmed before committing the transaction. This overrides HGPLAIN. Returns the ``pulloperation`` created for this pull. N)r:rirrr2r7r8r9rrsDsidedata category requested by local side without localsupport: '%s'rirsrqr)0r narrowpatsrvalidatepatternsr.rrrzrrrkrrr)r;r r*_wanted_sidedatarr<r{ProgrammingErrorrrrrrrrrrr r.rplainru_maybeapplyclonebundlermaybeperformlegacystreamclone_pulldiscoveryr>rg_pullchangeset _pullphase_pullbookmarks _pullobsoleterr)rkrzr:rirrrr2r7r8r9confirmrc peerlocalrrrrrrs r6pullr?sT~+"9!*SU !*SU #'?? [ , ,   1    V $ F ##%Ii,,- 0E0EE F7O, .C ++c" ")) $77==?OD)}}X& @ ((%""8, - *"*$FF  # # %E  # #D )   V--  GG  w 3DGGMMO v . v&11&9v    T6 *v6vf!. & ww/>:##D&1 M-.- s=!L2 L ?B4K?3L ;L?L L  L LL cfd}|S)a|decorator for function performing discovery before pull The function is added to the step -> function mapping and appended to the list of steps. Beware that decorated function will be added in order (this may matter). You can only use this decorator for a new step, if you want to wrap a step from an extension, change the pulldiscovery dictionary directly.cXtvsJ|t<tj|Sr)pulldiscoverymappingpulldiscoveryorderr?rs r6rzpulldiscovery..decrr8rrs` r6 pulldiscoveryrrr8c<tD]}t|}||yr)rr)rcrrs r6r~r~rr8s b1:bookmarksc|jy|jrd|jvryt|jd}t j ||_y)zfetch bookmark data in bundle1 case If not using bundle2, we have to fetch bookmarks before changeset discovery to reduce the chance and impact of race conditions.NrQr,)r5r>r@ryrzrr1)rcbookss r6_pullbookmarkbundle1rsQ )  v/G/G G  V]]L 1E$77>Fr8rMctj|j|j|j|j }|\}}}|jj jjj}|rX|rVt|}|D]!}||s ||vs|j|#t|jt|rg}||_ ||_||_y)z~discovery phase for the pull Current handle changeset discovery only, will change handle all discovery at some point.)rirN)r rrkrzrirrrfrhas_noderr?issubsetrlr4r3)rctmprlr4r3rscommonrns r6_pulldiscoverychangegrouprs  & & V]]&,,fll C FE6{{%%'1177@@H f+A{G#MM!$ v;  F ,EFMFLFMr8c dt|jdi}|jj}tj|dd}|j |d<|j xs |j|d<|jjtj}|r|jr|j|d <|r|jr|j|d <|rAd |d <d|d <|jjd|jjdn|jjd|j |d <d|j#ddv}d|j$j'ddv}|s"|r d|d<|jjdd|j$vrd|jvrdg|d<d }d|j#ddv}d|j$v} |j(|jjdd|jvr|j( |s | rd|d<d}d|j$vrJd|jvr<|jjd|j+dgj-d|jjdrH|j rTtAjB|j$} t;jD|  d|d<|jjdtG||tAjH|j} | r| |d<|jjK5} tM|} d| d<| jOd | jQ} tAjR|j|jTd|j!}d"|jVd<tAjX|j|||j# ddd|j rtAjd|_jfdD]\}}|dk(s ti|||r)i}|jfdD] }|d(||d)<||_n7|jfdD]%\}}|dk(s tkjl||_'|j( to|yy#t@jZ$r`}|jjj]t7d$|zt]j^t7d%|j`&d}~wt\jb$r&}t]j^t7d'|zd}~wwxYw#1swYxYw)*zNpull data using bundle2 For now, the only supported data are changegroup.s bundlecapsrrT)rrcommonr}s includepatss excludepatsFcgr!rMrurrrrQr,Nsrequest-bookmarks clonebundless cbattemptedsstreaming all changes no changes found requesting all changes rRsremote_sidedatarirH getbundle)rErzsrecords)rrzsremote: abort: %s spull failed on remoterPrsnodesbookmark)8 caps20to10rkr.rcanperformstreamclonerlrir3rzrr NARROWCAPr7r8rrr4rr@r{r5 setdefaultr?rrhr6rrrrr&r'rrr_pullbundle2extrapreparerrdictrrbundleoperationrBmodesrrr rrQrcombinechangegroupresultsr_pullapplyphasesrr1r)rckwargsr. streaming servernarrowrhasbinaryphasebookmarksrequestedlegacybookmark hasbinarybookrrrargsbundlerrrRrCrrecords r6r`r`sZ )D EF B11&$GJI F9||4v}}F8==(()A)ABL**!'!3!3~**!'!3!3~u  y^,Y' ^, u 2==;M#NN !V%=%=%A%A)R%PP~ $F9      + &22 2 0 00'0k{#!R]]8=O%PPN F$<$<$?chhO O%% H##A&?$@3$FG G H- ) (s81Z6A3X  Z3AY77Z3 !Z..Z33Z66[cy)z>hook function so that extensions can extend the getbundle callNr)rcrs r6rrsr8cd|jvry|jjd|js6|jjj t dd|_y|j}|j\t|j|jjgk(r/|jjj t dn8|j,|jjdr|j|_ |jjdrA|jj!d|j|jxs |j }n|jQ|jj#5}|j%d|jdd j'}dddn|jjdst)j*t d |jj#5}|j%d|j|jdd j'}dddt-j.|j|d|jj1|j }t-j2||_y#1swYkxYw#1swYwxYw)z0pull changeset from unbundle into the local reporMNrrrschangegroupsubsetrrirlri)snodesrHsWpartial pull cannot be done because other repository doesn't support changegroupsubset.)sbasesr}rHr)rrr4rkr.rrrrBrirrlrhrzrr3 getbundlerrrr r*r applybundlerr)rcrmrrbundleops r6rrsB ))) ( << a 567    B ||V]] 3 8J8J7K K a ;<=  &--"7"78L"M}}  }}\* ]] $ $ FMM1N%    ]] * * ,$ll& fh - ,]] " "#7 8kk &   ]] * * ,$$ll$ll&fh -""    }} H77AFOI- ,$- ,s.K )9K KK!cfd|jvryt|jd}t||y)Nru)rryrzr)rcrs r6rrs-F$$$FMM95LV\*r8c vd|jvry|jjdt|jdd}|r=|s;t j |j |j|\}}|j}n|j}g}|j j}|jj}|jjj}tj} tj} |D cgc]} |||| | kDs| }} |r2|j!} t j"|j | | ||D cgc]} |||| | kDs| }} |r3|j!} t j"|j | | |yycc} wcc} w)z/apply phase movement from observed remote stateruNrvF)rrrpr{rrrkr<r _phasecacherrfrget_revrrrBr") rcrrr_drdheadsrrrrrpnrms r6rrsF$$$ #l&&}e<=JJ00 KK,,l $$$$ ;; ! ! #D    " "E ..   & &C ]]F LLE" C6RU4R%9F%Bb6F C  " " $v{{B?" B6RU4R%9E%Ab6F B  " " $v{{Bv>D CsF1F1F65F6c td|jvry|jjd|j}|j}d}|j|jj }t j|j|||jj|j|j|y)z?process the remote bookmark information to update the local oner,N)r9mode) rrrkr5r0bookmarks_moderupdatefromremoter.rzrrBr1)rcrkr5rs r6rrsv''' & ;;D,,ON %++::    )) r8cd|jvry|jjdd}tj|jtj r|jj jdt|jd}d|vr|j}g}t|dD]I}|jdstj||}tj|\}}||z }K|r&|jj j|||jj#|S) aVutility function to pull obsolete markers from a remote The `gettransaction` is function that return the pull transaction, creating one if necessary. We return the transaction to inform the calling code that a new transaction have been created (when applicable). Exists mostly to allow overriding for experimentation purposerRNs!fetching remote obsolete markers r#sdump0Tr'sdump)rrrr&rkr'r.rryrzrBr;r'r b85decode _readmarkersr(invalidatevolatilesets)rcrm remoteobsrrBrbr5newmarkss r6rr,s ((( ' B&++x';';< BCV]]K8 y &&(BGi6>>'*>>)C.9D(0(=(=d(C%GXx'G 7  $$((W5 KK . . 0 Ir8c~|j}|j|jjdxs|j }|j t |dz|j t d}|j t |dz|j t d}|s'tjtdt |fz|Dcgc]}|dk(rdnd |z}}|Dcgc]}|dk(rdnd |z}}t|jd g}t|jd g}tj||||\}}} | r6tjtd |tj| fzi} | j|d | d<d | d<|| d <|r|| d <| Scc}wcc}w)zApply narrow fetch access control. This massages the named arguments for getbundle wire protocol commands so requested data is filtered through access control rules. s REMOTE_USERs .includessdefault.includess .excludessdefault.excludess%%s configuration for user %s is empty*spath:.spath:r7r8s4The following includes are not accessible for %s: %sTnarrow narrow_acl)r. shortuserenvironr{usernamer_NARROWACL_SECTIONr r*rrrrestrictpatternsrpprintupdate) rkrr.r user_includes user_excludesr req_includes req_excludesinvalid_includesnew_argss r6applynarrowaclrIs B||BJJNN>:KbkkmLHMM< (*=>M MM< (*=>M kk 6 7!8, -  ;H:GQQ$Y HqL0-;H:GQQ$Y HqL0-vzz-45Lvzz-45L3=3N3NlM=40L, 0kk E F**+;<= >  H OOFHX!H\*H]". O9s F5+F:c "#$j}j}|j}|D chc] } ||  c} thz} |D chc] } ||  } } |r| D cic]} | d} } t j t }t j t ""#$fd}"fd$"fd#t|j| | }t|}t }|Dcgc]}|j|}}t | |z}|D]}|j|}|j|Dcgc]}|tk7s |}}|1 |}|D]'}t|dz| j||dz| |<)d}|duxs ||k}|r||jj!}|r||j|djj!}t#|j%||}|sst'|dkDre||j|djj!}t#|j%||}nt)|j+|}|rM||D] } || | |D]}|j-||j-|j||stg}||vr0||D] } || | |D]}||j-||D]}||xx||zcc<| D]}!||!D] } || |! ||"fScc} wcc} wcc} wcc}wcc}w) aCompute the shape of a narrowed DAG. Args: repo: The repository we're transferring. common: The roots of the DAG range we're transferring. May be just [nullid], which means all ancestors of heads. heads: The heads of the DAG range we're transferring. match: The narrowmatcher that allows us to identify relevant changes. depth: If not None, only consider nodes to be full nodes if they are at most depth changesets away from one of heads. Returns: A tuple of (visitnodes, relevant_nodes, ellipsisroots) where: visitnodes: The list of nodes (either full or ellipsis) which need to be sent to the client. relevant_nodes: The set of changelog nodes which change a file inside the narrowspec. The client needs these as non-ellipsis nodes. ellipsisroots: A dict of {rev: parents} that is used in narrowchangegroup to produce ellipsis nodes with the correct parents. rc|j|t|dkDr*|\}}||||}t|dkDr)yy)z=Add a root to an ellipsis head, splitting heads with 3 roots.r#N)rr)head curchangechildroots ellipsisroots splithead splitrootss r6addrootz!_computeellipsis..addroots\d * -%&*$T?LE5 tUE *D-%&*r8c|j||j||j||j|yr)difference_updaterrdiscard)rrrrs r6rz$_computeellipsis..splitrootssOd--e4d&e##E*e$$U+r8c,t|\}}}||f||f||ffD]O\}} jd||||}|D]0}||k(r |||ffccS|vst|dks(|||ffccSQtjt d||||fz)Ns%sort(merge() & %d::%d & %d::%d, -rev)r#s;Failed to split up ellipsis node! head: %d, roots: %d %d %d)r;r|rr r*r) rr1r2r3nr1nr2midjrrks r6rz#_computeellipsis..splitheadsM$/0 BbB8b"X6HC))8#tS$C8c ?*M)Sq1A-BQ-FsCj=(  7kk # RR  !  r8rNrF)rf manifestlogrr collections defaultdictrrfindmissingrevsreversedrchangelogrevision parentrevsminr{rreadrpdiffrrwalkr)%rkrlriknownmatchr9rmmflclrevrn commonrevs headsrevsrrevdepth ellipsisheadsrrvisitrelevant_nodesm visitnodesrequiredrprevpscurdepthrneededshallow_enoughcurmfp1mfp2mfrrrrrs%` @@@r6_computeellipsisrsM. B   C FFE$*+Fq%(F+wi7J#()5aq5I) "+,)QAqD),++C0M++C0M ,  &2%%Zy%IJG W EUN&-.g"''!*gJ.9~%H$$S)!}}S1 E1tTW_d1 E  }H!(Q, Q 0JK $@(3-5*@ ',,.E2//16??@EEGejju56#b'A+ r33BqE:CCDIIKD!%**T5"9:FUZZ./ %c*c"+ Q   rwws| ,Yh)#.DD#&/A!!$((-A!!$ c(::$Y`!!$D D! % ~} 44M,)-Z/Fs#L6 L;" M'M9M M cdh}tjtj||}|jdtj |z|S)zFreturn a set with appropriate options to use bundle20 during getbundlesHG20rbundle2=)rrrrr=r>)rkrcapsr s r6rr sE 9D!!'"5"5d"FGHHH[6<<1 12 Kr8cfd}|S)adecorator for function generating bundle2 part for getbundle The function is added to the step -> function mapping and appended to the list of steps. Beware that decorated functions will be added in order (this may matter). You can only use this decorator for new steps, if you want to wrap a step from an extension, attack the getbundle2partsmapping dictionary directly.ctvsJ|t<tj|Stj|Sr)getbundle2partsmappinggetbundle2partsorderr?rZr[s r6rz%getbundle2partsgenerator..dec! sN5555+/x( ; ' ' 1  ! ' 'X 6 r8rr]s`` r6getbundle2partsgeneratorr r_r8c,|td|DSy)Nc3>K|]}|jdyw)sHG2N)r')rcaps r6rz#bundle2requested../ s@Zc3>>&)ZsF)rrs r6bundle2requestedr- s@Z@@@ r8c Btj|}i}t|}|s|r&|jddst t d|r=t t ddj t|jzt|||} d|d<|tj|| d||| fSd |d<i} |D]Y} | jd stj| td d } | j!t#j$| [t#j&|j(| } ||d <||d<t*D]-}t,|}|| ||f|| |dtj.|/| j0|d<|| j3fS)aReturn chunks constituting a bundle's raw data. Could be a bundle HG10 or a bundle HG20 depending on bundlecaps passed. Returns a 2-tuple of a dict with metadata about the generated bundle and an iterator over raw chunks (of varying sizes). rTs-request for bundle10 must include changegroups#unsupported getbundle arguments: %srrs bundleversionrOrr#rNr}r)rrursprefercompressed)r byteskwargsrr{ ValueErrorrr)r;keysror rr'r=rXrrr decodecapsrr.rrrprefercompressedr)rkrErirlrrrinfo usebundle2rjrubcapsblobrfnamers r6getbundlechunksr'3 s" ! !& )F D!*-J  fjj5BC  89**VFKKM234 $D%8!"    " "% /    D  F   K (>>%K(8(:";? 9D j'*MM,H,<,<(= =MOd# ot,((DMM9 ot,88> ,h7  8U# JJ|U + !)?@' JJw  JJw +     , $[ s I/c |jddsy|rd|vrtjtdt j |}t j ||}|r|jd|yy)z+add a bookmark part to the requested bundlerFNr,s#no common bookmarks exchange methodra)r{r r*rrlistbinbookmarksrtrd)rfrkrErrurrrbs r6_getbundlebookmarkpartr8 sn ::k5 ) \/kk!BCDD  $ $T *E   e ,D  40 r8rQc |jdd}|D]^}|jd}|jd||j|j } t j | |_`y)z@add parts containing listkeys namespaces to the requested bundleryrrQrN)r{rdrryr<r encodekeysrb) rfrkrErrurryrRr_rs r6_getbundlelistkeyspartsr; sc zz*b)H {+ lI.}}Y'--/&&t, r8c >|jddr||j}|jd|Dcgc]}|j}}|jj |} t j| } tj|| yycc}w)z8add an obsolescence markers part to the requested bundle obsmarkersFNr%) r{rirrr(r)rrrr) rfrkrErrurirrsubsetrs r6_getbundleobsmarkerpartr? s zz,& =JJLE$(HHXu$=>$=q!&&($=>--//7''0##GW5 '?sBruc R|jddr|rd|jdvrtjtd||j }t j t}|jr||tj<n9|jj}|jj} |jj} |D]#} |||| | j!| %t#|j%} | rt'| tj(ksJ|jtj(t} | rl|jtjt}d}|j+|| |}|D]*}|tjj!| |,tj,Dcic]}|t/||}}tj0|}|j3d| yycc}w) z,add phase heads part to the requested bundlerFr}rus no common phases exchange methodNs"heads(only(%ln, %ln) and public())rra)r{r r*rrirrrrrrrrrfrrrrrrrr|r~r;rtrd)rfrkrErrurir headsbyphaserrrr seenphases draftheadsrr extraheadsr  phasemappingrs r6_getbundlephasespartrF s zz(E"I)>>++a CDE E =JJLE"..s3 ?? */L '$$**E>>&&D..$$CU4Q0155a8l//12J:&,,666&))&,,>J*..v}}ceD >!YYvz;G #A /33DG<$ =C* &**T40_5NeV4H ""4(;r8scache:rev-branch-cachec |jddr7|r5d|vs1|jdds|jjtryt |||}t j |||y)zTransfer the rev-branch-cache mapping The payload is a series of data related to each branch 1) branch name length 2) number of open heads 3) number of closed heads 4) open heads nodes 5) closed heads nodes rTsrev-branch-cacherFN)r{r. has_sectionrroraddpartrevbranchcacherJs r6_getbundlerevbranchcacherOF sa4 JJtT " f , ::h & 77  1 2eV4H !!$:r8c|j}tjdjt |j }|dgk(s&||k(s |d|gk(st jd|zyyy)zVcheck if the heads of a repo have been modified Used by peer for unbundling. r8rshasheds.repository changed while %s - please try againN)rirsha1r)r;digestr PushRaced)rk their_headscontextri heads_hashs r6 check_headsrWl s| JJLEsxxu 67>>@Jz! %  9j1 1oo = G  2  "r8c  dgd d}jjdd}jdsjdrd} t|d t |t j sd jtjg}j5j|5}t j||} t j| ddddddnd fd } jjdd s| t j| |d } t j|| } | j |r%#jj#ddfd} d dj%t/j0 d d d| |jj3S#1swYxYw#1swYZxYw#| j |r&#jj#ddfd}wwwxYw#t&$r-} d| _|rj+x | _ fd}d} ~ wwxYw#t/j0 d d d|!|jj3wwxYw)aApply a bundle to a repo. this function makes sure the repo is locked during the application and have mechanism to check that no push race occurred between the creation of the bundle and its application. If the push was raced as PushRaced exception is raised.rNNNNrqsbundle2-output-captures remote:http:s remote:https:Tsuploading changesr/c"dstjsjd<jd<j d<dj d<dj d<ddj d<dS)Nr#rrrHrrr)rrrr rrJ) lockandtrrkrErsr6rBz unbundle..gettransaction s$Q<&77=+/::.recordout sIIifINr8r#cXtjd|d}j|yr_)r bundlepartr?)r`r_rAs r6razunbundle..recordout s(&11%Fe  T*r8r)r.rr'rWrSrrUr)rrIr rrrrrr pushbufferrM BaseExceptionduringunbundle2 salvageoutput_bundle2salvagedoutputlockmodrO popbuffer)rkrrirErrar\rjrmrrBrr[rAr s` `` @@@r6rr s A#IIGG&&2M ~~o&#..9I*J B+ D%!56"g001jj&'*>*>s*C!DEGd..w72((r2vsC55b98A1  (ww))#%:#$,,""/"  O ..tRB?BA$**t*DOQ<+aL&&(  ! ilIaLA  dgg'') * Hw87DA$**t*DO*7}! &*# Q]9:9JJEC6+    ! ilIaLA  dgg'') * !svAI9-G;?/G..G;6 I9AIHA I.G8 3G;;HI96H==I I6 (I11I66I99AJ>c|j}|j}|jjddsyt |ry|j ry|j dsy|j5}|jdij}dddd|_ tj|}|s%|jjtdytj|||j }|sI|jj#td|jj#tdytj$|j|}|d d }|jj'td |zt)|j|||r%|jj'td y|jjdd r%|jj#tdyt+j,tdtd#1swYxYw)z0Apply a clone bundle from a remote, if possible.rrNTsDno clone bundles available on remote; falling back to regular clone )r2sOno compatible clone bundles available on server; falling back to regular clone s5(you may want to report this to the server operator) rsURLsapplying clone bundle from %s sfinished applying clone bundle sclonebundlefallbacksfalling back to normal clone serror applying bundles}if this error persists, consider contacting the server operator or disable clone bundles via "--config ui.clonebundles=false"rP)rkrzr.rrrirrrrr6r parseclonebundlesmanifestnoterfilterclonebundleentriesr2r~sortclonebundleentriesrtrypullbundlefromurlr r*)rcrkrzrrYentriesrs r6r|r| s ;;D ]]F 77  e_ 5 4y || >>/ *    !QmmOR0779 " #'F44T3?G   3  33 gF,G,GG   3   G H  11$''7CG !*V CGGNN1783>?DGGT37 q<=>   E#9 :  Q89:kk & '4  i " !s 1!II c|s!tjtd|z|ttj d}|j |}tj|S)Ns$no remote repository supplied for %s) r r*rrr CLONEBUNDLESCHEMEget_cached_bundle_inlinerr)r.rpeer clonebundleidpeerclonebundles r6inline_clone_bundle_openrx* sX kk!CcIJKKL::;=>M33MBO   O ,,r8c H|j5|jd5} |jtjrt |||}nt j||}t||d}t|tjr|j|ntj|||d| ddddddy#tj $r:}|j#t%dt'j(|zYd}~n]d}~wtj*$rD}|j#t%dt'j(|j,zYd}~nd}~wwxYw ddddddy#1swYnxYwdddy#1swYyxYw) z%Attempt to apply a bundle from a URL.s bundleurlr!rNTsHTTP error fetching bundle: %s serror fetching bundle: %s F)r rr'r rsrxurlmodopenr7rSrr-applyrrurlerr httperrorr~rrrurlerrorreason)r.rkrrurmr/rrs r6rprp2 s; d&&|4 ~~l<<=-b#t<[[S)BI.B"k<<=##D"b/3G5  GG56))!,-    GG01))!((34    1544s^FFBC ;F E.0DFE.*:E)$F)E..F2FF FF!rr) NNFrNNNNNN)NNNN)NNNNN)NNrY)~rrri18nrrrrrrrr r r r r rirrrrrrrrrrrrzrrutilsrrr interfacesrr}r=rr7rDrdrorrrrrrrrrrrr!r+r:r5rUrYrXr^rnrqr{rrrrrrrrrrrrrrrrrrrr. transactionalrryrgrurrrrr~rrr`rrrrrrrrrrrrrr'r*r5r8r;r?rFrKrOrWrr|rxrprr8r6rs, #  ! >T=n3(#.L = A&A&N #$ *+ $% +, *+ 12  &    mb &(&|4x;-;-||GG"|OO(3l#N ,C6$% 8& 8/"=#=$,3 3l(55"8"J-  6! 6, 8  8 .-`+1%7&7*=@-Q`?D*0,* $F\,\,~++@N ';T0,      |@ & ?  ?~@RjI=B@+!?H*:5pB5J ,   H%V)$A%A.)    H *H V,'37 1( 1+&37 -' --(?C 6) 6)$?C-8%-8`/*    <+<634    ";5";J &V rO d-r8