Ë ûi/zlÌß‹ãóæ—dZddlZddlZddlmZddlmZmZddlm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZ Gd „d ej0«Z!Gd „d e!e j«Z"Gd „de!ejF«Z$Gd„dej"«Z%Gd„dejL«Z'Gd„dejP«Z)d„Z*Gd„d«Z+dd„Z,d„Z-Gd„d«Z. dd„Z/y)z�Repository class for viewing uncompressed bundles. This provides a read-only repository interface to bundles as if they were part of the actual repository. éNé)Ú_)ÚhexÚnullrev)Úbundle2Ú changegroupÚ changelogÚcmdutilÚ discoveryÚencodingÚerrorÚexchangeÚfilelogÚ localrepoÚmanifestÚmdiffÚpathutilÚphasesÚpycompatÚrevlogÚ revlogutilsÚutilÚvfs)Úurlutil)Ú constantscóL‡—eZdZd„Zd d„Zd„Zd ˆfd„ Zd„Zd„Zd„Z d„Z ˆxZ S) Ú bundlerevlogc óF—tj|«}tjj||||¬«||_t |«}|dz |_t«|_|j«D�]ª}|\}} } } } } }}t | «}|j«|z }|jj|«r5|jj|jj|««Œ}| |k(rt}n|| «}| | fD]G}|jj|«rŒt!j"||j$t'd««‚|jj| «s*t!j"| |j$t'd««‚|j| «}t)j*||||||j| «|j| «|¬«}|jj-|«|jj|«|dz }�Œ­y)N)ÚtargetÚradixrsunknown parentsunknown delta base)ÚflagsÚ data_offsetÚdata_compressed_lengthÚdata_delta_baseÚlink_revÚ parent_rev_1Ú parent_rev_2Únode_id)ÚvfsmodÚ readonlyvfsrÚ__init__ÚbundleÚlenÚ repotiprevÚsetÚ bundlerevsÚ deltaiterÚtellÚindexÚhas_nodeÚaddÚrevrr Ú LookupErrorÚ display_idrrÚentryÚappend)ÚselfÚopenerrr Ú cgunpackerÚ linkmapperÚnÚ deltadataÚnodeÚp1Úp2ÚcsÚ deltabaseÚdeltar!ÚsidedataÚsizeÚstartÚlinkrevÚpÚbaserevÚes ú8usr/lib/python3.12/site-packages/mercurial/bundlerepo.pyr+zbundlerevlog.__init__7sÓ€ô×#Ñ# FÓ+ˆÜ� ‰ ×јt V°FÀ%ÐÔHØ ˆŒ Ü �‹IˆØ˜a™%ˆŒÜ›%ˆŒØ#×-Ñ-×/ˆIØBKÑ ?ˆD�"�b˜"˜i¨°°xä�u“:ˆDØ—O‘OÓ%¨Ñ,ˆEà�z‰z×"Ñ" 4Ô(à—‘×#Ñ# D§J¡J§N¡N°4Ó$8Ô9ØØ�TŠzÜ!‘á$ R›.�à˜"“X�Ø—z‘z×*Ñ*¨1Õ-Ü×+Ñ+ؘ4Ÿ?™?¬AÐ.?Ó,@óððð —:‘:×&Ñ& yÔ1Ü×'Ñ'ؘtŸ™´Ð2GÓ0Hóðð—h‘h˜yÓ)ˆGä×!Ñ!ØØ!Ø'+Ø 'Ø Ø!ŸX™X b›\Ø!ŸX™X b›\Øô ˆAð �J‰J× Ñ ˜aÔ Ø �O‰O× Ñ  Ô "Ø �‰FŠAñQ0ócó—||jkr tjj||«S|jj |j |««|jj |j|««S©N)r.rÚ_chunkr,ÚseekrIÚreadÚlength)r;r6Údfs rNrRzbundlerevlog._chunkos_€ð �$—/‘/Ò !Ü—=‘=×'Ñ'¨¨cÓ2Ð 2Ø � ‰ ×јŸ™ C›Ô)Ø�{‰{×Ñ § ¡ ¨CÓ 0Ó1Ð1rOcót—||jkDr7||jkDr(|j|d}||k(rP|j|«S||jkr0||jkr!tjj |||«St j |j|«|j|««S)z1return or calculate a delta between two revisionsé)r.r3rRrÚrevdiffrÚtextdiffÚrawdata)r;Úrev1Úrev2Úrevbs rNrYzbundlerevlog.revdiffxs•€à �$—/‘/Ò ! d¨T¯_©_Ò&<à—:‘:˜dÑ# AÑ&ˆDØ�tŠ|Ø—{‘{ 4Ó(Ð(Ø �T—_‘_Ò $¨°·±Ò)@Ü—=‘=×(Ñ(¨¨t°TÓ:Ð :ä�~‰~˜dŸl™l¨4Ó0°$·,±,¸tÓ2DÓEÐErOcó•—|€|j|«}d}d}g}|}||jkDra|jr"|jd|k(r|jd}n3|j|«|j|d}||jkDrŒa|t k(rd}n-|€+t t|�#|j|«||¬«}|\} }}|rd}|r9|j|j««} tj|| g«}|rŒ9|||fS)NFrérXrO)Ú_df)r6r.Ú_revisioncacher:r3rÚsuperrÚ_rawtextrArRÚpoprÚpatches) r;rAr6raÚ validatedÚrawtextÚchainÚiterrevÚrÚ__rFÚ __class__s €rNrdzbundlerevlog._rawtext„sø€Ø ˆ;Ø—(‘(˜4“.ˆC؈ ØˆØˆØˆà˜Ÿ™Ò'Ø×"Ò" t×':Ñ':¸1Ñ'=ÀÒ'HØ×-Ñ-¨aÑ0�ØØ �L‰L˜Ô !Ø—j‘j Ñ)¨!Ñ,ˆG𠘟™Ó'ð ”gÒ Ø‰GØ ˆ_Ü”l DÑ2Ø— ‘ ˜'Ó" G°ð3óˆAð&'Ñ "ˆB�˜Ù ؈IÙØ—K‘K § ¡ £ Ó,ˆEÜ—m‘m G¨e¨WÓ5ˆGòð�G˜YÐ&Ð&rOcó—t‚rQ©ÚNotImplementedError©r;ÚargsÚkwargss rNÚ addrevisionzbundlerevlog.addrevision ó€Ü!Ð!rOcó—t‚rQrorqs rNÚaddgroupzbundlerevlog.addgroup£rurOcó—t‚rQrorqs rNÚstripzbundlerevlog.strip¦rurOcó—t‚rQro©r;s rNÚ checksizezbundlerevlog.checksize©rurOrQ) Ú__name__Ú __module__Ú __qualname__r+rRrYrdrtrwryr|Ú __classcell__©rms@rNrr6s-ø„ò6óp2ò Fõ'ò8"ò"ò"ö"rOrcó—eZdZd„Zy)Úbundlechangelogcó²—tjj||«d„}tj||tjdf|j ||«y)Ncó—|SrQ©)Úxs rNÚz*bundlechangelog.__init__..°s€™qrO)r r+rÚrevlog_constantsÚKIND_CHANGELOGr )r;r<r=r>s rNr+zbundlechangelog.__init__®sL€Ü×Ñ×$Ñ$ T¨6Ô2Ù ˆ Ü×ÑØ Ø Ü × ,Ñ ,¨dÐ 3Ø �J‰JØ Ø õ  rON©r}r~rr+r†rOrNrƒrƒ­s„ó  rOrƒcó*‡—eZdZ dd„Zˆfd„ZˆxZS)ÚbundlemanifestcóF—tjj||||¬«tj||tj |f|j j||«|€0i}|jjdk(rt|j«}||_ ||_ y)N)Útrees03) rÚmanifestrevlogr+rr‰ÚKIND_MANIFESTLOGÚ_revlogr r,ÚversionÚ_getfilestartsÚ _dirlogstartsÚ _linkmapper)r;Ú nodeconstantsr<r=r>Ú dirlogstartsÚdirs rNr+zbundlemanifest.__init__¼s“€ô ×Ñ×(Ñ(¨¨}¸fÈ3Ð(ÔOÜ×ÑØ Ø Ü × .Ñ .°Ð 4Ø �L‰L× Ñ Ø Ø ô  ð Р؈LØ�{‰{×"Ñ" eÒ+Ü-¨d¯k©kÓ:� Ø)ˆÔØ%ˆÕrOcó•—||jvrk|jj|j|«t|j|j |j|j |j|¬«Stt|�#|«S)N)r™) r•r,rSr�r—r<r–rcÚdirlog)r;Údrms €rNr›zbundlemanifest.dirlogÕs{ø€Ø �×"Ñ"Ñ "Ø �K‰K× Ñ ˜T×/Ñ/°Ñ2Ô 3Ü!Ø×"Ñ"Ø— ‘ Ø— ‘ Ø× Ñ Ø×"Ñ"Øô ð ô”^ TÑ1°!Ó4Ð4rO)NrO)r}r~rr+r›r€r�s@rNr�r�»sø„ðØ ó&÷2 5ð 5rOr�có—eZdZd„Zy)Ú bundlefilelogcó¸—tjj|||«t|tj|f|j j ||¬«|_y)N)rr r=r>)rr+rr‰Ú KIND_FILELOGr’r )r;r<Úpathr=r>s rNr+zbundlefilelog.__init__äsH€Ü�‰× Ñ   v¨tÔ4Ü#Ø ä$×1Ñ1°4Ð8Ø—,‘,×$Ñ$Ø!Ø!ô  ˆ� rONr‹r†rOrNržržãs„ó  rOržcó—eZdZd„Zy)Ú bundlepeercó—y©NFr†r{s rNÚcanpushzbundlepeer.canpushñó€ØrON)r}r~rr¦r†rOrNr£r£ðs„órOr£có0‡—eZdZˆfd„Zd„Zd„Zd„ZˆxZS)Úbundlephasecachec󢕗tt|� |i|¤Žtj|d«r%t j |j«|_yy)Nr<)rcr©r+rÚ safehasattrr)r*r<)r;rrrsrms €rNr+zbundlephasecache.__init__ösCø€Ü Ô Ñ.°Ð?¸Ò?Ü × Ñ ˜D (Ô +Ü ×,Ñ,¨T¯[©[Ó9ˆD�Kð ,rOcó—t‚rQror{s rNÚwritezbundlephasecache.writeûrurOcó—t‚rQro)r;Úfps rNÚ_writezbundlephasecache._writeþrurOcóP—||j|<|j«d|_y)NT)Ú phaserootsÚ invalidateÚdirty)r;ÚphaseÚnewrootsÚtrs rNÚ _updaterootszbundlephasecache._updaterootss!€Ø!)ˆ�‰˜ÑØ �‰Ô؈� rO)r}r~rr+r­r°r¸r€r�s@rNr©r©õsø„ô:ò "ò"örOr©c󚇗i}t‰ji«D].}|d}‰j«||<tˆfd„i«D]}ŒŒ0|S)Nsfilenamecó&•—‰jd«SrQ)Ú deltachunk)r=s€rNrˆz _getfilestarts.. sø€ *×"7Ñ"7¸Ô"=rO)ÚiterÚ filelogheaderr2)r=ÚfilesposÚ chunkdataÚfnameÚchunks` rNr”r”sVø€Ø€Hܘ*×2Ñ2°BÖ7ˆ ؘ+Ñ&ˆØ$Ÿ/™/Ó+ˆ�‰ÜÓ=¸rÖBˆEØ ñCð8ð €OrOcó.‡—eZdZdZd„Zd„Zd„Zd„Zdd„Ze jd„«Z e jd„«Z d „Z e jd „«Zd „Ze jd „«Ze jd „«Zd„Zˆfd„Zd„Zd„Zdd„Zd„Zdˆfd„ ZˆxZS)Úbundlerepositorya%A repository instance that is a union of a local repo and a bundle. Instances represent a read-only repository composed of a local repository with the contents of a bundle file applied. The repository instance is conceptually similar to the state of a repository after an ``hg unbundle`` operation. However, the contents of the bundle are never applied to the actual base repository. Instances constructed directly are not usable as repository objects. Use instance() or makebundlerepository() to create instances. cóJ—||_||_|jjdddd«i|_d|_d|_d|_tj|d«}tj|j||«}t|tj«r´||_d}|jd¬«D]U}|j dk(r|j#||«Œ%|j d k(sŒ5|r t%d «‚|}|j'||«ŒW|st)j*t-d ««‚|j/d t0j2«yt|t4j6«r|j9||«yt)j*t-d «t!|«z«‚)NóphasesspublishFs bundlerepoórbT)Úseekableó phase-headsó changegroups#can't process multiple changegroupssNo changegroups foundrsbundle type %r cannot be read)Ú _tempparentÚ_urlÚuiÚ setconfigÚ _cgfilesposÚ _bundlefileÚ _cgunpackerÚtempfilerÚ posixfilerÚ readbundleÚ isinstancerÚ unbundle20Ú iterpartsÚtypeÚ_handle_bundle2_phase_partrpÚ_handle_bundle2_cg_partr ÚAbortrrSÚosÚSEEK_SETrÚ cg1unpackerÚ_handle_bundle1)r;Ú bundlepathÚurlÚ tempparentÚfr,ÚcgpartÚparts rNr+zbundlerepository.__init__sj€Ø%ˆÔ؈Œ à �‰×ј) Z°¸ ÔFðˆÔØˆÔØˆÔ؈Œ Ü �N‰N˜: uÓ -ˆÜ×$Ñ$ T§W¡W¨a°Ó<ˆä �fœg×0Ñ0Ô 1Ø%ˆDÔ àˆFØ×(Ñ(°$Ð(Ö7�Ø—9‘9 Ò.Ø×3Ñ3°F¸DÕAØ—Y‘Y .Ó0ÙÜ1ØBóðð"�FØ×0Ñ0°¸Õ>ð8ñÜ—k‘k¤!Ð$<Ó"=Ó>Ð>ð �K‰K˜œ2Ÿ;™;Õ 'ä ˜¤ × 7Ñ 7Ô 8Ø × Ñ  ¨Õ 4ä—+‘+ÜÐ2Ó3´d¸6³lÑBóð rOc ó¸—|j«rJ|j|jdd¬«}tj|j |||j «}||_||_|jjdz|_ tj|dtj||jdD�cgc]}|j«‘Œc}«ycc}w)Ns.hg10unóHG10UN)Úheaderr)Ú compressedÚ_writetempbundlerTrrÓrÌrrÏrÐr r.Ú firstnewrevrÚretractboundaryÚdraftrA)r;r,rßrâÚctxs rNrÞz bundlerepository._handle_bundle1Ls¶€Ø × Ñ Ô Ø×%Ñ% f§k¡k°:ÀiÐ%ÓPˆAÜ×(Ñ(¨¯©°!°ZÀÇÁÓJˆFà!ˆÔØ!ˆÔàŸ>™>×4Ñ4°qÑ8ˆÔÜ×ÑØ Ø Ü �L‰LØ#'¨×(8Ñ(8Ð(:Ñ#;Ó <Ñ#;˜CˆS�X‰X�ZÐ#;Ñ <õ  ùò =sÂ8Cc ó8—|jdk(sJ‚|}|jjd«} t|«}|€t j }|t jvr%td«}||z}tj|«‚|jjdd«}tj|«}||vr#td«}tj||z«‚|j«r|j|jd|z«}tj ||d«|_|j$j&d z|_t j*|d|||j(dD� cgc]} | j-«‘Œc} «y#t$rY�ŒXwxYwcc} w) NrÉs targetphasesunsupported targetphase: %dsversions01s#Unsupported changegroup version: %ss.cg%sunsUNr)r×ÚparamsÚgetÚintÚ TypeErrorrrìÚ allphasesrr rÚrÚsupportedincomingversionsrèrérTÚ getunbundlerrÐr r.rêrërA) r;r,räÚcgstreamÚ targetphaseÚmr“Ú legalcgversÚmsgrís rNrÙz(bundlerepository._handle_bundle2_cg_part\sr€Ø�y‰y˜NÒ*Ð*Ð*؈ؗk‘k—o‘o nÓ5ˆ ð ܘkÓ*ˆKð Ð Ü Ÿ,™,ˆKØ œf×.Ñ.Ñ .ÜÐ0Ó1ˆAØ �Ñ ˆAÜ—+‘+˜a“.Ð Ø—+‘+—/‘/ *¨eÓ4ˆÜ!×;Ñ;¸DÓAˆ Ø ˜+Ñ %ÜÐ:Ó;ˆCÜ—+‘+˜c G™mÓ,Ð ,Ø × Ñ Ô Ø×,Ñ,¨T¯Y©Y¸ ÀWÑ8LÓMˆHä&×3Ñ3°G¸XÀuÓMˆÔàŸ>™>×4Ñ4°qÑ8ˆÔÜ×ÑØ Ø Ø Ø#'¨×(8Ñ(8Ð(:Ñ#;Ó <Ñ#;˜CˆS�X‰X�ZÐ#;Ñ <õ  øô'ò Ú ð üò. =s° FÅ(FÆ FÆFcó —|jdk(sJ‚|j«}tj|«}tj|d„|«y)NrÈcó—yrQr†r†rOrNrˆz=bundlerepository._handle_bundle2_phase_part..�s€¨$rO)r×Ú unfilteredrÚ binarydecodeÚ updatephases)r;r,räÚunfiÚ headsbyphases rNrØz+bundlerepository._handle_bundle2_phase_part|sB€Ø�y‰y˜NÒ*Ð*Ð*à�‰Ó ˆÜ×*Ñ*¨4Ó0ˆ Ü×јD¡,° Õ=rOcóT—|jjd|¬«\}}||_tj|d«5}|j |« |d«}|sn|j |«Œ ddd«|jj |jd¬«S#1swYŒ0xYw)zWrite a temporary file to disks hg-bundle-)ÚprefixÚsuffixÚwbiNrÆ)Úmode)rÚmkstemprÑrÛÚfdopenr­Úopen)r;ÚreadfnrrçÚfdtempÚtempÚfptemprÁs rNréz!bundlerepository._writetempbundleƒs•€à—x‘x×'Ñ'¨}ÀVÐ'ÓL‰ ˆ�؈Œ ä �Y‰Y�v˜tÔ $¨Ø �L‰L˜Ô ØÙ˜w›�ÙØØ— ‘ ˜UÔ#ð ð÷ %ð�x‰x�}‰}˜TŸ]™]°ˆ}Ó7Ð7÷%Ð $ús ¾0BÂB'có.—t||j«SrQ)r©Ú_phasedefaultsr{s rNÚ _phasecachezbundlerepository._phasecache’s€ä  d×&9Ñ&9Ó:Ð:rOcó¸—|jj«t|j|j«}|jj «|_|SrQ)rÐÚchangelogheaderrƒÚsvfsr2Úmanstart)r;Úcs rNr zbundlerepository.changelog–sG€ð ×Ñ×(Ñ(Ô*Ü ˜DŸI™I t×'7Ñ'7Ó 8ˆØ×(Ñ(×-Ñ-Ó/ˆŒ ؈rOcó—yrQr†r{s rNÚ_refreshchangelogz"bundlerepository._refreshchangelogžs€ð rOcó¾—|jj|j«|jj«|j «j j }t|j|j|j|«}|jj«|_ tj|j|||j««SrQ)rÐrSrÚmanifestheaderrýr r6r�r—rr2Ú filestartrÚ manifestlogÚ narrowmatch)r;r>Ú rootstores rNrzbundlerepository.manifestlog£s¨€à ×Ñ×јdŸm™mÔ,à ×Ñ×'Ñ'Ô)Ø—_‘_Ó&×0Ñ0×4Ñ4ˆ Ü"Ø × Ñ  § ¡ ¨4×+;Ñ+;¸Zó ˆ ð×)Ñ)×.Ñ.Ó0ˆŒä×#Ñ#Ø �I‰I�t˜Y¨×(8Ñ(8Ó(:ó ð rOcóþ—|jj|j«|jj«|jj «D]}Œ|jj «|_y)zgConsumes the manifest portion of the bundle, setting filestart so the file portion can be read.N)rÐrSrrr1r2r)r;rFs rNÚ_consumemanifestz!bundlerepository._consumemanifest²s`€ð ×Ñ×јdŸm™mÔ,Ø ×Ñ×'Ñ'Ô)Ø×%Ñ%×/Ñ/Ö1ˆEØ ð2à×)Ñ)×.Ñ.Ó0ˆ�rOcó2—|j|jSrQ)r rr{s rNrzbundlerepository.manstart»s€à �ŠØ�}‰}ÐrOcón—|jd|jvr|j«|jS)Nr)rÚ__dict__rrr{s rNrzbundlerepository.filestartÀs/€à ×Òð ˜dŸm™mÑ +Ø × !Ñ !Ô #à�~‰~ÐrOcó—|jSrQ)rËr{s rNràzbundlerepository.urlÍs €Ø�y‰yÐrOc󸕗|js?|jj|j«t |j«|_||jvrn|jj|j|«|j «j j}t|j||j|«Stt|�3|«SrQ) rÎrÐrSrr”rýr r6ržrrcrÃÚfile)r;râr>rms €rNr%zbundlerepository.fileÐsªø€Ø×ÒØ × Ñ × !Ñ ! $§.¡.Ô 1Ü-¨d×.>Ñ.>Ó?ˆDÔ à �× Ñ Ñ Ø × Ñ × !Ñ ! $×"2Ñ"2°1Ñ"5Ô 6ØŸ™Ó*×4Ñ4×8Ñ8ˆJÜ  §¡¨A¨t×/?Ñ/?ÀÓLÐ LäÔ)¨4Ñ5°aÓ8Ð 8rOcóô—|jj«|j�%|jj |j«|j r!t j|j d«yy)z'Close assigned bundle file immediately.NT)rÏÚcloserÑrÚunlinkrÊÚshutilÚrmtreer{s rNr'zbundlerepository.closeÜsT€à ×Ñ×ÑÔ Ø �=‰=Ð $Ø �H‰H�O‰O˜DŸM™MÔ *Ø × Ò Ü �M‰M˜$×*Ñ*¨DÕ 1ð rOcó—yr¥r†r{s rNÚcancopyzbundlerepository.cancopyär§rOcó—t|||¬«S)N)r¡Ú remotehidden)r£)r;r¡r.s rNÚpeerzbundlerepository.peerçs€Ü˜$ T¸ ÔEÐErOcó*—tj«SrQ)r Úgetcwdr{s rNr1zbundlerepository.getcwdês€Ü�‰Ó Ð rOcóÊ•—|€ |j}|jj|«}|jj|«}td«}|jj|kr'|j j |t|«z«|jj|kr'|j j |t|«z«tt|�+||«S)Ns9setting parent to node %s that only exists in the bundle ) Únullidr r6rr.rÌÚwarnrrcrÃÚ setparents)r;rBrCÚp1revÚp2revrúrms €rNr5zbundlerepository.setparentsîs­ø€Ø ˆ:Ø—‘ˆBØ—‘×"Ñ" 2Ó&ˆØ—‘×"Ñ" 2Ó&ˆÜÐMÓNˆØ �>‰>× $Ñ $ uÒ ,Ø �G‰G�L‰L˜œs 2›w™Ô 'Ø �>‰>× $Ñ $ uÒ ,Ø �G‰G�L‰L˜œs 2›w™Ô 'ÜÔ% tÑ7¸¸BÓ?Ð?rO)rOr¥rQ)r}r~rÚ__doc__r+rÞrÙrØrérÚunfilteredpropertycacherr rrrrrràr%r'r,r/r1r5r€r�s@rNrÃrÃsÚø„ñ ò,ò\ ò  ò@>ó 8ð×&Ñ&ñ;ó'ð;ð×&Ñ&ñó'ðò ð ×&Ñ&ñ  ó'ð  ò1ð×&Ñ&ñó'ðð×&Ñ&ñ ó'ð òô 9ò2òóFò!÷ @ñ @rOrÃcóJ—|rtjtd««‚|jdd«}|s+t j t j««}|€d}|rPt j«}||k(rd}n4tj|«}|j|«r|t|«d}tj|«}|j«}|jdk(r.|j!dd«}t|«dk(r||d} } n |\} } n||} } t#|| | «S)Ns#cannot create new bundle repositorysbundles mainreporootrOó+rr)r rÚrÚconfigr Úfindrepor r1rÚ normasprefixÚ startswithr-rràÚ localpathÚschemeÚsplitÚmakebundlerepository) rÌr¡ÚcreateÚintentsÚ createoptsÚ parentpathÚcwdÚuÚsÚrepopathÚ bundlenames rNÚinstancerMûs €Ù Ü�k‰kœ!ÐBÓCÓDÐDà—‘˜9 oÓ6€JÙ ä×%Ñ%¤h§o¡oÓ&7Ó8ˆ Ø Ð ØˆJÙô�o‰oÓˆØ ˜Ò ؉Jä×'Ñ'¨Ó,ˆCØ×$Ñ$ SÔ)Ø'¬¨C«¨ Ð3� Ü� ‰ �DÓ€AØ �;‰;‹=€D؇x�x�9ÒØ �J‰J�t˜QÓ ˆÜ ˆq‹6�QŠ;Ø#-¨q°©t�j‰Hà#$Ñ ˆH‘jà)¨4�*ˆä   H¨jÓ 9Ð9rOcóì—|rdtj|«|fz}nd|z} tj||d¬«}d}Gd„dt|j«}||_ tj||||«|S#tj $r‚tj $rTtj«} tj||d¬«}n##t$rtj|«‚wxYwYŒ´wxYw) z?Make a bundle repository object based on repo and bundle paths.s bundle:%s+%ss bundle:%sF)rDNTcó —eZdZy)ú5makebundlerepository..derivedbundlerepositoryN)r}r~rr†rOrNÚderivedbundlerepositoryrP<s„Ø rOrQ)rÚ expandpathrrMr ÚRequirementErrorÚ RepoErrorrÚmkdtempÚ Exceptionr)r*rÃrmr+)rÌrKrßràÚreporárQs rNrCrCsê€áؤ§¡°Ó!:¸JÐ GÑG‰à˜ZÑ'ˆð Ü×!Ñ! " h°uÔ=ˆØˆ ô Ô"2°D·N±Nô ð-€D„NÜ×јd J°°ZÔ@à €Køô! × !Ñ !òØ Ü �?‰?òÜ×%Ñ%Ó'ˆ ð Ü×%Ñ% b¨*¸TÔB‰DøÜò Ü �M‰M˜*Ô %Ø ð úñ ðús)¤A9Á9:C3Â4C à C3à C-Ã-C3Ã2C3có—eZdZd„Zd„Zd„Zy)Úbundletransactionmanagercó—yrQr†r{s rNÚ transactionz$bundletransactionmanager.transactionFs€ØrOcó—t‚rQror{s rNr'zbundletransactionmanager.closeIrurOcó—t‚rQror{s rNÚreleasez bundletransactionmanager.releaseLrurON)r}r~rr[r'r^r†rOrNrYrYEs„òò"ó"rOrYc ór‡‡‡—tj|‰||¬«}|\}}} |s' |rtj|«|g‰j fSt |«} | D� cgc] } | | vsŒ| ‘Œ } } dŠdЉj«} |s| �sû|jdd«} d| vxrd| v}| xr$‰jd«xr‰jd«}|r|‰j«5}|jdd|| tj|d ¬ «d d œ«j«}tj ||j#«|«x}Šddd«nÿ‰jd«r>‰j«5}|jdd|| d œ«j«}ddd«n�|€P‰jd«s?‰j«5}|jd|ddœ«j«}ddd«d} n=‰j«5}|jd|| ddœ«j«}ddd«| rd}nd}t%j&|||«x}Š|rdŠ| s3t)|j*|j,«x} Š|j/«}| r| j0«} | j2j5|| «}‰r£‰‰j6dD�cgc]}|j9«‘Œ}}‰j«5}|jdddi«j«}ddd«tj:‰‰d|¬«}t=«|_tj@|«ˆˆˆfd„}| ||fS#t$rY�Œ.wxYwcc} w#1swY�Œ8xYw#1swY�ŒfxYw#1swY�Œ³xYw#1swY�Œ€xYwcc}w#1swYŒ¡xYw)aDobtains a bundle of changes incoming from peer "onlyheads" restricts the returned changes to those reachable from the specified heads. "bundlename", if given, stores the bundle to this file path permanently; otherwise it's stored to a temp file and gets deleted again when you call the returned "cleanupfn". "force" indicates whether to proceed on unrelated repos. Returns a tuple (local, csets, cleanupfn): "local" is a local repo from which to obtain the actual incoming changesets; it is a bundlerepo for the obtained bundle when the original "peer" is remote. "csets" lists the incoming changeset node ids. "cleanupfn" must be called without arguments when you're done processing the changes; it closes both the original "peer" and the one returned here. )ÚheadsÚforceNsdevelslegacy.exchangesbundle2sbundle1s getbundlesincomingsclient)ÚroleT)ósourceócommonóheadss bundlecapsscg)rcrdreschangegroupsubsetrÉ)snodesrc)sbasesrercsHG10BZræslistkeyss namespacerÅ)r¡r`cóx•—‰r‰j«‰rtj‰«‰j«yrQ)r'rÛr()r,Ú bundlerepor/s€€€rNÚcleanupz!getremotechanges..cleanupßs*ø€Ù Ø × Ñ Ô Ù Ü �I‰I�fÔ Ø � ‰ � rO)!r ÚfindcommonincomingrÛr(ÚOSErrorr'r/ÚlocalÚ configlistÚcapableÚcommandexecutorÚ callcommandrÚ caps20to10ÚresultrÚ writechunksÚ_forwardchunksrÚ writebundlerCÚbaseuiÚrootr`rýr Ú findmissingrêrAÚ pulloperationrYÚ trmanagerÚ_pullapplyphases)rÌrWr/Ú onlyheadsrLraÚtmpÚcommonÚincomingÚrheadsÚ commonsetr‡rÚlegexcÚ forcebundle1Ú canbundle2rMÚb2rÀÚcgÚ bundletypeÚcsetsríÚ reponodesÚ remotephasesÚpulloprhr,rgs ` @@rNÚgetremotechangesr‹PsÛú€ô, × &Ñ & t¨T¸È%Ô P€CØ"Ñ€FˆH�fÙ ð ÙÜ— ‘ ˜*Ô%ð�R˜Ÿ™Ð#Ð#ä�F“ €IÙÓ 6™�A 1¨IÒ#5Ša˜€FÐ 6à €FØ€JØ— ‘ “ €Iٚ𗑘xÐ);Ó<ˆØ!¨Ð/ÒH°JÀ&Ð4Hˆ àÐ ò )Ø— ‘ ˜\Ó*ò )à— ‘ ˜ZÓ(ð ñ Ø×%Ñ%Ô'¨1Ø—]‘]Ø à#.Ø#)Ø"(Ü'/×':Ñ':Ø  yô(ð $ñó ÷‘&“(ðô"-×!8Ñ!8ؘ×)Ñ)Ó+¨Zó"ð�˜÷(Ð'ð$�|‰|˜LÔ)Ø×)Ñ)Ô+¨qØŸ™Ø$à'2Ø'-Ø&,ñó÷‘f“hð÷,Ð+ðÐ"¨4¯<©<Ð8LÔ+Mð×)Ñ)Ô+¨qØŸ™Ø&à&.Ø'2ñó÷ ‘f“hð ÷,ð‘à×)Ñ)Ô+¨qØŸ™Ø,à&.Ø&,Ø'2ñó÷‘f“hð÷,ñØ&‘ à&� Ü$×0Ñ0°°R¸ÀZÓPÐ PˆE�Fá ØˆFÙä%9Ø— ‘ ˜TŸY™Y¨ó&ð ˆI˜ ð —Z‘Z“\ˆFÙð)�I×(Ñ(Ó*ˆ à × Ñ × +Ñ +¨F°FÓ ;€EáØ+5°j×6LÑ6LÐ6NÑ+OÓPÑ+O C�S—X‘X•ZÐ+Oˆ ÐPà × !Ñ !Ô # qØŸ=™=Øà  )ðó÷ ‰f‹hð ÷$ô×'Ñ'Ø ˜ 4¨yô ˆô4Ó5ˆÔÜ×!Ñ! &¨,Ô7öð �u˜gÐ &Ð&øôuò Ú ð üò 7÷"(Ñ'ú÷&,Ñ+ú÷,Ñ+ú÷,Ñ+üòFQç #Ð #ús`¦MÁ M/Á%M/ÃA#M4Å(%NÆ9$NÇ8%NËN(Ë*#N-Í M,Í+M,Í4M>ÎN ÎNÎN%Î-N6)NN)NNF)0r8rÛr)Úi18nrrArrÚrrr r r r r rrrrrrrrrrrrr)Úutilsrrr‰rrƒr�r�ržÚ localpeerr£Ú phasecacher©r”rÃrMrCrYr‹r†rOrNÚr‘sèðñó Û å÷÷ ÷÷÷÷ñõ*õô t"�6—=‘=ôt"ôn  �l I×$7Ñ$7ô  ô%5�\ 8×#:Ñ#:ô%5ôP  �G—O‘Oô  ô�×$Ñ$ôô �v×(Ñ(ôò$÷g@ñg@óT:òD%÷P"ñ"ð