!nWddlZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZddlmZmZddlmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z(m)Z*m+Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3mZm4Z4m5Z5m6Z7m8Z8m9Z9m:Z:m;Z;mm?Z?m@ZAmBZBmCZCmDZDmEZFmGZGdd lHmIZImDZJdd lKmLZLmMZMmNZNmOZOdd lPmQZRmSZTmUZVe(jZWeDjZXeDjZYejd Z[e\Z]Gd de;jZ_Gdde_Z`Gdde_ZaGddeaZbGddeaZcGdde_ZddZeGddeDjZgGddeDjZhdZidZjhd Zkekjd!hZmeJjeIjGd"d#ZpeJjeIjGd$d%eIjZseJjeIjGd&d'esZue\Zvd(Zwd)ZxdMd*eyfd+Zz dMd,eFjd-eFjd.e eFjfd/Z{d0Z|d1Z}d2Z~d3Zd4Zd5Zd6Zd7ZeJjeIjGd8d9ZeJjeIjGd:d;Zd<ZeIjd=feIjd>fgZeJjeIjGd?d@ZdAeydBeyfdCZdNd*eyfdDZd*eydBefdEZdMdFZdGZdHZdIZdJZdNd*eyfdKZdLZy)ON)futures)Optional)_)binhexnullrevsha1nodeconstantsshort)delattrgetattr)+ bookmarks branchmapbundle2 bundlecaches changegroupcolorcommitcontextdirstate discoveryencodingerrorexchange extensionsfileloghooklockmatch mergestate mergeutil namespaces narrowspecobsoletepathutilphasespushkeypycompatrcutilrepoview requirementsrevlogrevset revsetlangscmutilsparsestore subrepoutiltags transactiontxnutilutilvfswireprototypes) repositoryr6)hashutilprocutil stringutilurlutil)concurrency_checker constantssidedatas+^((dirstate|narrowspec.dirstate).*|branch$)c.eZdZdZdfd ZfdZxZS)_basefilecachezHAll filecache usage on repo are done for logic that should be unfilteredc||S|j} |j|jS#t$rYnwxYwtt |||SN) unfiltered__dict__snameKeyErrorsuperrB__get__selfrepotypeunfi __class__s 7usr/lib/python3.12/site-packages/mercurial/localrepo.pyrJz_basefilecache.__get__tsW <K  ==, ,   ^T24>>s 0 <<cHtt| |j|SrD)rIrBsetrE)rLrMvaluerPs rQrSz_basefilecache.sets^T.t/@%HHrD)__name__ __module__ __qualname____doc__rJrS __classcell__rPs@rQrBrBqsR ?IIrUrBc(eZdZdZfdZdZxZS) repofilecachez3filecache for files in .hg but outside of .hg/storecbtt| ||D]}tj |dfy)Nplain)rIr]__init__ _cachedfilesaddrLpathspathrPs rQr`zrepofilecache.__init__s/ mT+U3D   dH- .rUc8|jj|SrD)r7joinrLobjfnames rQrgzrepofilecache.joinsww||E""rUrVrWrXrYr`rgrZr[s@rQr]r]s=/ #rUr]c(eZdZdZfdZdZxZS) storecachez filecache for files in the storecbtt| ||D]}tj |dfy)NrU)rIrmr`rarbrcs rQr`zstorecache.__init__s. j$(%0D   dC[ )rUc$|j|SrD)sjoinrhs rQrgzstorecache.joinsyyrUrkr[s@rQrmrms**  rUrmc(eZdZdZfdZdZxZS)changelogcachezfilecache for the changelogc~tt| tj dtj dy)N 00changelog.irU) 00changelog.nrU)rIrrr`rarbrLrPs rQr`zchangelogcache.__init__s. nd,.0101rUc|j|dg}|jjjj ddr!|j |j|d|S)Nrupersistent-nodemapFrvrgr1openeroptionsgetappendrLrirds rQ tracked_pathszchangelogcache.tracked_pathssT3 012 99   # # ' '(=u E LL3(89 : rUrVrWrXrYr`rrZr[s@rQrrrrs%2 rUrrc(eZdZdZfdZdZxZS)manifestlogcachezfilecache for the manifestlogc~tt| tj dtj dy)N) 00manifest.irU) 00manifest.nrU)rIrr`rarbrws rQr`zmanifestlogcache.__init__s/ .0/0/0rUc|j|dg}|jjjj ddr!|j |j|d|S)NrryFrrzrs rQrzmanifestlogcache.tracked_pathssR301 99   # # ' '(=u E LL38 9 rUrr[s@rQrrs'1 rUrc(eZdZdZfdZdZxZS)mixedrepostorecachez2filecache for a mix files in .hg/store and outsidecPtt| |tj |yrD)rIrr`raupdate)rLpathsandlocationsrPs rQr`zmixedrepostorecache.__init__s% !413DE-.rUc|\}}|dk(r|jj|S|dk7rtjd|z|j |S)Nr_rUsunexpected location: %s)r7rgrProgrammingErrorrp)rLrifnameandlocationrjlocations rQrgzmixedrepostorecache.joinsY*x x 77<<& &3,,.999U# #rUrkr[s@rQrrs</ $rUrcx|jjj|d}|sy|jdfS)z{check if a repo has already cached "name" filecache-ed property This returns (cachedobj-or-None, iscached) tuple. NNFT)rE _filecacher}ri)rMname cacheentrys rQ isfilecachedrs8 "--11$=J  >>4 rUc$eZdZdZdfd ZxZS)unfilteredpropertycachez0propertycache that apply to unfiltered repo onlyc~|j}||urtt||St ||j SrD)rErIrrJr rrKs rQrJzunfilteredpropertycache.__get__s:  4<0$?E EtTYY''rUrD)rVrWrXrYrJrZr[s@rQrrs:((rUrceZdZdZdZy)filteredpropertycachez1propertycache that must take filtering in accountcFtj||j|yrD)object __setattr__r)rLrirTs rQ cachevaluez filteredpropertycache.cachevalues3 51rUN)rVrWrXrYrrUrQrrs ;2rUrc8|t|jvS)z?check if a repo has an unfilteredpropertycache value for )varsrE)rMrs rQhasunfilteredcachers 4)* **rUcBtjfd}|S)z@decorate method that always need to be run on unfiltered versionc8|jg|i|SrD)rE)rMargskwargsorigs rQwrapperz!unfilteredmethod..wrappersDOO%7777rU) functoolswraps)rrs` rQunfilteredmethodrs'__T88 NrU>knownlookupunbundle branchmap getbundlepushkeyschangegroupsubsetc0eZdZdZdZdZdZdZdZy)localcommandexecutorc.||_d|_d|_yr)_peer_sent_closed)rLpeers rQr`zlocalcommandexecutor.__init__s   rUc|SrDrrLs rQ __enter__zlocalcommandexecutor.__enter__  rUc$|jyrD)close)rLexctypeexcvalueexctbs rQ__exit__zlocalcommandexecutor.__exit__s  rUc|jrtjd|jrtjdt |j t j|}tj} |dit j|}|j||S#t$r/t j|tjddY|SwxYw)Ns1callcommand() cannot be used after sendcommands()s*callcommand() cannot be used after close()rr)rrrrr rr(sysstrrFuture strkwargs set_result Exceptionfuture_set_exception_infosysexc_info)rLcommandrfnfresults rQ callcommandz localcommandexecutor.callcommands ::((D  <<((=  TZZ!9 : NN  !3(,,T23F LL   F  . .q#,,.2D E  FsB//4C'&C'cd|_yNT)rrs rQ sendcommandsz!localcommandexecutor.sendcommands+s  rUcd|_yr)rrs rQrzlocalcommandexecutor.close.s  rUN) rVrWrXr`rrrrrrrUrQrrs  4rUrceZdZdZdfd ZdZdZdZdZdZ dZ d Z d Z dd Z dd Zd ZdZdZdZdZdZdZdZxZS) localpeerz8peer for a local repo; reflects only the most recent APIcftt| |j|||tj }|r|j d|_n|j d|_|jr)tj|}|jd|z|j||_ y)Nre remotehidden served.hiddenservedsexp-wanted-sidedata=)rIrr`ui moderncapscopyfiltered_repo_wanted_sidedatarformat_remote_wanted_sidedatarb_restrictcapabilities_caps)rLrMcapsrer formattedrPs rQr`zlocalpeer.__init__6s i' GG$\ (  <??$D '78DJy1DJ  ==dCI HH,y8 9//5 rUc6|jjSrD)rurlrs rQrz localpeer.urlIszz~~rUc|jSrD)rrs rQlocalzlocalpeer.localL zzrUcyrrrs rQcanpushzlocalpeer.canpushOrUc8|jjyrD)rrrs rQrzlocalpeer.closeRs rUc6|jjSrD)rrrs rQrzlocalpeer.branchmapYszz##%%rUc|jSrD)rrs rQ capabilitieszlocalpeer.capabilities\rrUctrD)NotImplementedError)rLres rQget_cached_bundle_inlinez"localpeer.get_cached_bundle_inline_s!!rUc@tj|jSrD)r get_manifestrrs rQ clonebundleszlocalpeer.clonebundlescs((44rUcd||tj|tj|tj|fzS)z+Used to test argument passing over the wire%s %s %s %s %sr(bytestrrLonetwothreefourfives rQ debugwireargszlocalpeer.debugwireargsfD     U #   T "   T " $   rUc tj|j|f||||d|d}tj|}tj |r t j|j|Stjd|dS)N)headscommon bundlecapsremote_sidedatar01) rgetbundlechunksrr6 chunkbufferbundle2requestedr getunbundlerrr) rLsourcerrr r rchunkscbs rQ getbundlezlocalpeer.getbundleps)) JJ  !+       f %  $ $Z 0''4 4++E2t< |jj||||SrD)rr')rLrroldnews rQr'zlocalpeer.pushkeyszz!!)S#s;;rUc>tjtd)Ns.cannot perform stream clone against local peer)rAbortrrs rQ stream_outzlocalpeer.stream_outskk!MNOOrUch tj|j|d}tj|j||d|}t j |drCt j|j}tj|j|}|S#t$r}t|dd}|rtj|jj}|D]} |j| t j|j}tj|j|} tj|j| d}~wwxYw#t j"$r7}t!j$t'dt)j*|d}~wwxYw)zPapply a bundle on a repo This function handles the repo locking itself.Nspush getchunks_bundle2salvagedoutputrs push failed:)r readbundlerunbundlerr6 safehasattrr r'rrrr bundle20addpart processbundler PushRaced ResponseErrorrr< forcebytestr) rLbundlerrretstreamexcoutputbundleroutbs rQr*zlocalpeer.unbundlesX  !,,TWWfdC'' FE7CP##C5"--cmmo>F!..tww?C  !&>C%..tzz}}=G%, &!--g.?.?.ABF,,TWWf=A))$**a8! " %%/"J$;$;C$@  s1BB"" E$+B4EE$$E''F1:2F,,F1ct|SrD)rrs rQcommandexecutorzlocalpeer.commandexecutors #D))rUNNFNNN)NNNN)rVrWrXrYr`rrrrrrrrrrrrrrr'r%r*r;rZr[s@rQrr2suB6& &"5  =8"'.&<P#R*rUrc<eZdZdZdfd ZdZdZdZdZxZ S)locallegacypeerzcpeer extension which implements legacy methods too; used for tests with restricted capabilitiesc<tt| |t||y)N)rrer)rIr?r` legacycaps)rLrMrerrPs rQr`zlocallegacypeer.__init__s  ot- z< . rUc8|jj|SrD)rbetween)rLpairss rQrCzlocallegacypeer.betweenszz!!%((rUc8|jj|SrD)rbranchesrs rQrFzlocallegacypeer.branchesszz""5))rUctj|j||jj}t j |j|d|SN) missingroots ancestorsofr )routgoingrrrmakechangegroup)rLrrrKs rQrzlocallegacypeer.changegroupsG%% JJU 8H8H8J **4::xOOrUctj|j||}tj|j|d|SrH)rrKrrrL)rLbasesrrrKs rQchangegroupsubsetz!locallegacypeer.changegroupsubsets:%% JJU **4::xOOrUr) rVrWrXrYr`rCrFrrOrZr[s@rQr?r?s# )*P PrUr?cV|jdjd}tj|vr$t j |j |}tj|d}|js+tjtd|jz|S)zreturns the vfs object pointing to root of shared source repo for a shared repository hgvfs is vfs pointing at .hg/ of current repo (shared one) requirements is a set of requirements of current repo (shared one) sharedpath T)realpaths1.hg/sharedpath points to nonexistent directory %s)readrstriprequirementsmodRELATIVE_SHARED_REQUIREMENTr6normpathrgvfsmodr7existsr RepoErrorrbase)hgvfsr+ sharedpath sharedvfss rQ _getsharedvfsr`sM*11%8J22lB]]5::j#9:  :5I    oo B Cnn    rUct|r |jn |j}t|djS)zreads the require file present at root of this vfs and return a set of requirements If allowmissing is True, we suppress FileNotFoundError if raisedrequires)tryreadrTrS splitlines)r7 allowmissingrTs rQ _readrequiresrfs.'3;;CHHD tK ++- ..rUrec |j}|j|_tj|dd}|jd}tj|d}d}d}|j s2 |j tjtd|zt|d} tj | vxstj"| v}d} |r1t%|| }tj|jd } n$tj|jd } td } tj&| vr|rtj&t|dvr|j)d d } |j+d d }|j)d d}|dvrddlm}|j1|||| || |n|dk(r tjtd| tjtd|z| | t| dz} n|rt|d}tj&|vr|j+d d}|j)d d} |j)d d}|dvrddlm}|j3||| | || |nH|dk(r tjtd| tjtd|z| t5|||| |r8t7|||| t9j:|t9j<|t9j8|Dchc]\}}|j>}}}tA|}tC| |tE|| tG}|r=|jH}|jd}|jKtLjNn|jH}|jd}|jd}tQ| |d}|jR|_)|j} tU|| || _+tjX| vstjZ| vr>|jKtLj\|j_tLj`tj|d}|jR|_)tj|d}|jR|_)g}i}tbD]c\}} | ||| ||||| | jV|||||}!te|!tfstjhd |z|jk|!etmjnd!|jHd"jtq| fz}"tg|"ts|i}#|#|||||| |||||||# S#t $rYz%makelocalrepository.. sVZZ48rU)rintentsr+featureswdirvfsr]r1storevfs storeoptionscachevfs wcachevfsextensionmodulenames extrastate baseclassessunable to construct type for %ssderivedrepo:%s<%s>,) baseuirorigrootrzr]r+supportedrequirementsr^r1r}r~ryrx):rrYr7rgisdirstatFileNotFoundError ValueErrorrr$rr<r1r[rfrVSHARED_REQUIREMENTrWr`SHARESAFE_REQUIREMENT configboolconfigrpdowngrade_share_to_non_safeupgrade_share_to_safeloadhgrc afterhgrcloadrloadall populateuirVgathersupportedrequirementsensurerequirementsrecognizedensurerequirementscompatiblerSr\rbr9REPO_FEATURE_SHARED_STORAGE makestore createmoderesolvestorevfsoptionsr|REVLOGV2_REQUIREMENTCHANGELOGV2_REQUIREMENTREPO_FEATURE_SIDE_DATAdiscardREPO_FEATURE_STREAM_CLONEREPO_INTERFACES isinstancerNrr~r(rsortedtuple)$rrerxrrzhgpathr]sharedr_er+r{rs mismatch_warnmismatch_configmismatch_verbose_upgraderpsourcerequiresnmrrry storebasepath cachepath wcachepathr1r}r~rNrifacertyprclss$ rQmakelocalrepositoryrs > BkkBGjj$>G\\& !F JJvD 1E FI ;;=  JJLooa :;dBCC -L**l: G  6 6, F H !%6 ::innX67::ejj23 O PD,, < 55 D12MM?M!ii:O(*}}J( $# &33 #!,!H,kkMN kk! & &  M(E: :L &y%8  0 0N B ii2NOOMM;M(*}}F( $# &-- #!,!H,kkK kkQ& &  GUL)<b'5,72b!4>3H3H3LM3L41aAJJ3LM7;!/DE!\2$uH ! NN8,  Z;;< JJx( I&J 8 E ''EyyH-b,IH ,, <  2 2l B Z667==>zz)$7H**H :D9I ++I EJ$ rbd%!))!5! "#t$((2U:   S3%< ??tyy 9M/N OO D tU5\2 &C  !3  u!   ++()T:3J3J13M,NN  NNs$7V7>X 7 XX 6XXrzr]r_ctjsyd}tj|vr1|r/ |j |j d|j d} |j |j d|j d} |j |j d|j d}|S#t$rYkwxYw#t$rYKwxYw#t$rY|SwxYw)aLoad hgrc files/content into a ui instance. This is called during repository opening to load any additional config files or settings relevant to the current repository. Returns a bool indicating whether any additional configs were loaded. Extensions should monkeypatch this function to modify how per-repo configs are loaded. For example, an extension may wish to pull in configs from alternate files or sources. sharedvfs is vfs object pointing to source repo if the current one is a shared one FhgrcrootTshgrc-not-shared)r) use_repo_hgrcrVr readconfigrgr\IOError)rrzr]r+r_r3s rQrr]s*    ! C,, <  MM)..1 M GC  ejj) =  ejj!347<< H J         J s5.B;.C .C; CC CC C&%C&cdgdgdgd}t|jD]9\}}||vr |D]*}|jd|r|jd|dd,;y ) aQPerform additional actions after .hg/hgrc is loaded. This function is called during repository loading immediately after the .hg/hgrc file is loaded and before per-repo extensions are loaded. The function can be used to validate configs, automatically add options (including extensions) based on requirements, etc. git largefileslfs)rrrs extensionsrUsautoload)rN)ritems hasconfig setconfig)rrzr]r+autoextensions requirementnamesrs rQrrsp%N %^%9%9%;< U l * D<< t4 ]D#k J =rUcttj}tj|Dchc]\}}|j}}}t D]}|j |vs|||tjD]~}tj|}|js'|js8|jd|z|jdk(s`|jtj|Scc}}w)z6Determine the complete set of recognized requirements.exp-compression-%szstd)rSlocalrepository_basesupportedrrVfeaturesetupfuncsrWr6 compengines available revlogheaderrbrrVREVLOG_COMPRESSION_ZSTD)r supportedrrmodulesrrengines rQrrsO223I'1&;&;B&?@&?daqzz&?G@ ==G # r9    !!$'    &"5"5"7 MM/$6 7{{}' oEEF ! AsDcDt}|D]K}||vr|r|ddjstjt d|j |M|rDtjt ddj t|zt dy) aValidate that a set of local requirements is recognized. Receives a set of requirements. Raises an ``error.RepoError`` if there exists any requirement in that set that currently loaded code doesn't recognize. Returns a set of supported requirements. rrs.hg/requires file is corrupts:repository requires features unknown to this Mercurial: %s sJsee https://mercurial-scm.org/wiki/MissingRequirement for more informationrrN)rSisalnumrRequirementErrorrrbrgr)r+rmissingrs rQrrseG# ) # +a"2":":"<((+J)KL L K $$$ K Liiw( )(  rUctj|vr/tjst j t dyy)aValidates that a set of recognized requirements is mutually compatible. Some requirements may not be compatible with others or require config options that aren't enabled. This function is called during repository opening to ensure that the set of requirements needed to open a repository is sane and compatible with config options. Extensions can monkeypatch this function to perform additional checking. ``error.RepoError`` should be raised on failure. sfrepository is using sparse feature but sparse is not enabled; enable the "sparse" extensions to accessN)rVSPARSE_REQUIREMENTr0enabledrr[r)rr+s rQrrsA **l:oo 1    ;rUctj|vrQtj|vr)tj|v}t j |||St j ||St j||S)z,Construct a storage object for a repository.)rVSTORE_REQUIREMENTFNCACHE_REQUIREMENTDOTENCODE_REQUIREMENTstoremod fncachestore encodedstore basicstore)r+revfstype dotencodes rQrrsi((L8  . ., >'==MI((w B B$$T733   tW --rUcbi}tj|vrd|d<|jdd}|||d<tj|vstj|vr|j t |||nd|d<tj|vrd|d<|S|jdd }d }||vrd |d<|S) zResolve the options to pass to the store vfs opener. The returned dict is used to influence behavior of the storage layer. T treemanifestformatsmanifestcachesizesrevlogv0changeset-sidedatascopies-storage experimentalscopies.write-to)schangeset-onlys compatibilitysextra) rVTREEMANIFEST_REQUIREMENT configintREVLOGV1_REQUIREMENTrrresolverevlogstorevfsoptionsCOPIESSDC_REQUIREMENTr)rr+ryr|manifestcachesize writecopiestocopiesextramodes rQrrs G//<?#'  Y0DE$(9$% ,, <  / /< ?3B hOP# ,, <%:!" N  /3EF ? O +)1G% & NrUc i}i|d<tj|vrd|d<tj|vrd|d<tj|vrd|d<|j dd}||d<tj |vrd|d <|j d d }|||d <|j d d}||d<|j d d}||d<|j dd|d<|j d d}||d<|j d d} d} | r|j d d} | tj| } | |d<| |d<|jdd} d| kr| |d<|jdd} | | |d<|j dd} t|jdd }|jdd!}| |d"<||d#<||d$<tj|v}||d%<|rd|d <d }|rtj}|j d d&|}|||d&<|D]7}|j}|d's |d(s |j!d)d*d*|d+<9|j d d,|d-<|d-6d|d-cxkrd.ks(nt#d/}t%j&||d-z|j d d0|d1<|d16d|d1cxkrd2ks(nt#d3}t%j&||d1ztj(|vrd|d4<|j dd5rd|d5<tj*|vr|jd d6}|d7vr\|j-d d6}t#d8}|j/||z|j0s|j/t#d9|z|}t#d:}t#d;}t2j4s_|dd=|zd>z}|j/||j0sd?|zd@z}|j/||dAk(rt%j&||Bd|dC<tj6|vr|jd dD}|d7vr\|j-d dD}t#dE}|j/||z|j0s|j/t#d9|z|}t#dF}t#dG}t8j:s_|dd=|zd>z}|j/||j0sd?|zd@z}|j/||dAk(rt%j&||B|j d dHrd|dI<|j dJdCrd|dK<|S)Lz+Resolve opener options specific to revlogs.sflagprocessorsTrevlogv1revlogv2s changelogv2rschangelog-v2.compute-rankschangelogv2.compute-ranks generaldeltarschunkcachesizeNstorages#revlog.optimize-delta-parent-choicesdeltabothparentss5revlog.delta-parent-search.candidate-group-chunk-sizes.delta-parent-search.candidate-group-chunk-sizesdebugsrevlog.debug-deltas debug-deltasrevlog.issue6528.fix-incomingsissue6528.fix-incomingsrevlog.reuse-external-deltaFs"revlog.reuse-external-delta-parents lazydeltas lazydeltabasesmaxdeltachainspanrsmmapindexthresholds sparse-readssparse-read.density-thresholdssparse-read.min-gap-sizeswith-sparse-readssparse-read-density-thresholdssparse-read-min-gap-size sparse-revlogs maxchainlensrevlog-compression-sexp-compression--s compenginesrevlog.zlib.levels zlib.level s8invalid value for `storage.revlog.zlib.level` config: %dsrevlog.zstd.levels zstd.levels8invalid value for `storage.revlog.zstd.level` config: %dsenableellipsiss rust.indexs#revlog.persistent-nodemap.slow-path)rnwarnrqsMunknown value for config "storage.revlog.persistent-nodemap.slow-path": "%s" s"falling back to default value: %s sQaccessing `persistent-nodemap` repository without associated fast implementation.s@check `hg help config.format.use-persistent-nodemap` for detailsrs warning: rR(s) rqrrrysdirstate-v2.slow-paths7unknown value for config "dirstate-v2.slow-path": "%s" sJaccessing `dirstate-v2` repository without associated fast implementation.s9check `hg help config.format.use-dirstate-v2` for detailssrevlog.persistent-nodemap.mmapspersistent-nodemap.mmapdevelsdevel-force-nodemap)rVrrrrGENERALDELTA_REQUIREMENTrr/ gddeltaconfig configbytesfloatrSPARSEREVLOG_REQUIREMENT revlogconstSPARSE_REVLOG_MAX_CHAIN_LENGTH startswithsplitrrr$NARROW_REQUIREMENTNODEMAP_REQUIREMENTconfig_defaultwarnquietr,HAS_FAST_PERSISTENT_NODEMAPDIRSTATE_V2_REQUIREMENTrHAS_FAST_DIRSTATE_V2)rr+ryr|cmp_rankchunkcachesizedeltabothparentsdps_cgds issue6528 lazydelta lazydeltabase chainspanmmapindexthresholdwithsparsereadsrdensitythres srmingapsize sparserevlog maxchainlenrprefixmsg slow_pathdefaultrss rQrr,sG!#G ++|;# ++|;# ..,>"&==2NO/7+,//<?#' \\)->?N!%3!"}}:$4G  ||@HBJG => mmH6KLGN j*JKI)2G %& j*HIIM = #11"55 %GL -G 0DEII~(1$%9NO%);%&]]?NCN /#CDN>>/3NOL#1G  0>G ,-+7G '(";;|KL ,G #' K!@@ ,,y.+FK"-   ( )V4G-H%&WWT1%5a%8GM " \\*6JKGM})W]+0q0OPC++cGM$::; ;\\*6JKGM})W]+1r1OPC++cGM$::; ;))\9%)!" }}_m4!% **l:II >  9 9''BGIC GGC)O $88@AGKLI $   11G#"S(50 xx$;/DGGDMH$kk#D11)-%&..,>IIj*BC 9 9'' 4LMGOPC GGC)O $88@AGKLI $  L ,,G#"S(50 xx$;/DGGDMH$kk#D11 }}Z!BC.2*+ }}X45*.&' NrUc tS)z6Produce a type conforming to ``ilocalrepositorymain``.)r)rs rQmakemainr#s rUceZdZdZdZy)revlogfilestoragez File storage when using revlogs.c|jdr|dd}|jduxstj|j}t j |j ||SN/r) try_split)rcurrenttransactionr5mayhavependingrrsvfsrLrer)s rQfilezrevlogfilestorage.filesa ??4 8D  # # %T 1 1%%dii0  tyy$)DDrUNrVrWrXrYr.rrUrQr%r%s * ErUr%ceZdZdZdZy)revlognarrowfilestoragez1File storage when using revlogs and narrow files.c|jdr|dd}|jduxstj|j}t j |j||j|Sr') rr*r5r+rr narrowfilelogr,_storenarrowmatchr-s rQr.zrevlognarrowfilestorage.filesp ??4 8D  # # %T 1 1%%dii0 $$ IItT33y  rUNr/rrUrQr1r1s ;  rUr1c |jtj|jtjtj |vrt StS)z=Produce a type conforming to ``ilocalrepositoryfilestorage``.)rbr9 REPO_FEATURE_REVLOG_FILE_STORAGErrVrr1r%)r+ryrs rQmakefilestorager7s@ LL<<= LL556))\9&&  rUctSrD)r#rrUrQrwrwshrUctSrD)r7rrUrQrwrws_rUceZdZdZej ej ejejejejejejejejejej ej"ej$ej&ej(ej*ej,ej.ej0hZhdZ ddedej:dej:dedej:d ej:f d Zd Zd Z e!d Z"dZ#dZ$dZ%e!dZ&e!dZ'dZ(ddZ)dZ*ddZ+e,dddddZ-dZ.e!dZ/e0ddd Z1e0d!d"Z2e3d#Z4e5d$Z6e7d%Z8d&Z9d'Z:e0e;jxd(Z=e0e;jxd)Z>e0e;jxd*Z?dd+Z@d,ZAe7d-ZBe7d.ZCeDd/ZEe!d0ZFd1ZGd2ZHd3ZIeIZJd4ZKd5ZLd6efd7ZMd6efd8ZNdd9efd:ZOd;efd<ZPdd=ZQeRd>ZSd?ZTd@ZUdAZVdBZWdCZXdDZYdEZZeDdFZ[dGZ\ddHZ]dIZ^dJZ_dKZ`dLZadMZbdNZcdOZddPedQed;efdRZeddSZfddTefdUZgd;efdVZhddPedWeied;efdXZjdYZkdZZle7d[Zme7d\Znd]Zod^ed;efd_Zp dd^ed`edaed;eqfdbZrd^ed`ed;efdcZsddZtddeZudfZvdgZweDdhZxdiZyddjZzeDdkZ{dlZ|eDddmZ}dnZ~doZdpZddqZdrZeDdsZdtZduZddvZddwZdxZdyZdzZd{ZeD dd|ZeDdd}ZeDd~ZeDdZ ddZdZdZdZddZddZdZdZdZe7dZdZdZddZdZdZ ddZy)raQMain class for representing local repositories. All local repositories are instances of this class. Constructed on its own, instances of this class are not usable as repository objects. To obtain a usable repository object, call ``hg.repository()``, ``localrepo.instance()``, or ``localrepo.makelocalrepository()``. The latter is the lowest-level. ``instance()`` adds support for creating new repositories. ``hg.repository()`` adds more extension integration, including calling ``reposetup()``. Generally speaking, ``hg.repository()`` should be used. > bisect.statercache/rbNrrzr]r^r}r~c||_||_||_||_|j|_||_|j|_||_t|_ |jj|_ ||_ ||_ | |_| |_| |_| |_d|_|jj'dds|jj'ddr4|j)|j j*|j _g|_t/j0|j|jj|_|jj |_|jj6|_|jj'dds|jj'ddrt;j<|j4drI|j?|j4j j*|j4j _n4|j?|j4j*|j4_d|_ tCjD|_#d|_$i|_%i|_&dx|_'x|_(|_)i|_*i|_+d|_,g|_-d|_.d|_/taj`|_1i|_2i|_3tijj||_6d|_7tpjr|jvrd|_7tu|_;i|_<t{j||y)aCreate a new local repository instance. Most callers should use ``hg.repository()``, ``localrepo.instance()``, or ``localrepo.makelocalrepository()`` for obtaining a new repository object. Arguments: baseui ``ui.ui`` instance that ``ui`` argument was based off of. ui ``ui.ui`` instance for use by the repository. origroot ``bytes`` path to working directory root of this repository. wdirvfs ``vfs.vfs`` rooted at the working directory. hgvfs ``vfs.vfs`` rooted at .hg/ requirements ``set`` of bytestrings representing repository opening requirements. supportedrequirements ``set`` of bytestrings representing repository requirements that we know how to open. May be a supetset of ``requirements``. sharedpath ``bytes`` Defining path to storage base directory. Points to a ``.hg/`` directory somewhere. store ``store.basicstore`` (or derived) instance providing access to versioned storage. cachevfs ``vfs.vfs`` used for cache files. wcachevfs ``vfs.vfs`` used for cache files related to the working copy. features ``set`` of bytestrings defining features/capabilities of this instance. intents ``set`` of system strings indicating what this repo will be used for. Nr all-warnings check-locksr7Fr)?rrrwvfsr\rr7rer+r nodeconstantsnullidrr^r1r}r~ry filternamer _getvfswardaudit_phasedefaultsrsetupspathr,rgrpr6r+ _getsvfsward_dirstatevalidatewarnedrBranchMapCache _branchcaches_revbranchcache _filterpats _datafilters _transref_lockref _wlockrefrfilteredrevcache _dirstate _postdsstatus_pending_narrow_pats_pending_narrow_pats_dirstater"r_sparsesignaturecache_sparsematchercacher* extrafilter_extrafilteridfilecopiesmoderVrrSr_sidedata_computers sidedatamodset_sidedata_spec_for_repo)rLrrrrzr]r+rr^r1r}r~ryrxs rQr`zlocalrepository.__init__MsH    LL JJ (.((// .$   "   77  h 8DGG>> !#$(!-1* **, &("#% &2226"  0 0D4E4E E"7D  ##% ..t4rUcFtjdfd }|S)zbuild a ward for self.vfsc|}}|,tj|drtj|dsy|dvryj|jrt |jdzdjdr#d}|j j |zdd d }tfd |Dr>|j|j!|j j d zdd |S|j|jE jD]}j|sy|j j dzdd |S)NmoderRrQNrsrbrr<s2accessing cache with vfs instead of cachevfs: "%s"s cache-vfs) stacklevelr)sjournal.sundo.s strip-backup/r<c3@K|]}j|ywrD)r).0rres rQ z@localrepository._getvfsward..checkvfs..sK9Jv4??6*9Jswrite with no lock: "%s"r?swrite with no wlock: "%s") r6r+rrelenr develwarnany _currentlockrQrR_wlockfreeprefix) rercr3rMrvfs_path_prefixesrorigfuncrrefrLs ` rQcheckvfsz-localrepository._getvfsward..checkvfssb4d+C6D ''k:''j9**tyy)C NQ.01y)K!!#*<!P!  K9JKK$$T]]3;GG%%3d:#$-&"J""4>>2:#33Fv.4!!047 )" JrUrDweakrefref)rLrrrtrss`` @rQrDzlocalrepository._getvfswards{{4 + ZrUcBtj|dfd }|S)zbuild a ward for self.svfscH||}}|tj|dsy|dvry|j|jr|t |jdzd}|j |j  |jjd|zd|S)NrbrQrdrrk)rg) r6r+rr^rlrorQrrm)rercr3rMrrrss rQ checksvfsz/localrepository._getsvfsward..checksvfs#s4d+C6D|4#3#3D*#E**t/C01467  /7!!/$61"JrUrDru)rLrrr{rss ` @rQrIzlocalrepository._getsvfswards{{4   rUcJ|j|j|jdS)N)rUr_rmr,r7rs rQvfs_mapzlocalrepository.vfs_map5s#hhii  rUc$|jyrD) _writecachesrs rQrzlocalrepository.close=s rUcR|jr|jjyyrD)rMwriters rQrzlocalrepository._writecaches@s"     & & ( rUcl|jjddr\t|}tjtj |d}|j dtj|z|jjddr|j tj|S)Nrsbundle2-advertisesclient)rolesbundle2=snarrow) rrrSr encodecaps getrepocapsrburlreqquoter8 NARROWCAP)rLrcapsblobs rQrz%localrepository._restrictcapabilitiesDs 77  o/C Dt9D))##Dy9H HH[6<<#99 : 77  oy 9 HH^-- . rUcXtj|j|jS)N)callbackr% pathauditorr _checknestedrs rQauditorzlocalrepository.auditorRs!##DII8I8IJJrUc\tj|j|jddS)NFT)rrealfscachedrrs rQ nofsauditorzlocalrepository.nofsauditorXs*## II 1 1%  rUc|j|jsy|t|jdzd}tj|}|d}tj |}|ridj |}||jvr7||k(ry|j|}|j|t|dzdS|j|riy)z/Determine if path is a legal nested repository.FrNr(T) rrrlr6pconvert splitpathrgsubstatesub checknestedpop)rLresubpath normsubpathctxpartsrrs rQrzlocalrepository._checknested`styy)s499~)+,mmG, &4jw'YYu%F%[(''&/C??73v;?3D+EFF rUct|||S)Nr)r)rLrers rQrzlocalrepository.peers t,  rUc|S)zaReturn unfiltered version of the repository Intended to be overwritten by filtered repo.rrs rQrEzlocalrepository.unfiltereds  rUc|jd|vr|dz|jz}tj|jj}||||S)aReturn a filtered version of a repository The `name` parameter is the identifier of the requested view. This will return a repoview object set "exactly" to the specified view. This function does not apply recursive filtering to a repository. For example calling `repo.filtered("served")` will return a repoview using the "served" view, regardless of the initial view used by `repo`. In other word, there is always only one level of `repoview` "filtering". %)r[r*newtyperErP)rLrvisibilityexceptionsrs rQrzlocalrepository.filteredsX    *t4/?$;!4!44Dt0::;4344rU) bookmarksr_)sbookmarks.currentr_)rrUrtcL|jtj|SrD)_refreshchangelogrbmstorers rQ _bookmarkszlocalrepository._bookmarkss"n    &&rUcFdt|vr|j|`yyy)z7make sure the in memory changelog match the on-disk one changelogN)rr*rrs rQrz!localrepository._refreshchangelogs* $t* $)@)@)B)J*K $rUc.|jjSrD)ractivers rQ_activebookmarkzlocalrepository._activebookmarks%%%rUs phaserootsrucBtj||jSrD)r& phasecacherFrs rQ _phasecachezlocalrepository._phasecaches  t':':;;rUsobsstorecBtj|j|SrD)r$rrrs rQobsstorezlocalrepository.obsstores!!$''400rUc|jj|jjt j |j tj|jdS)N changelog)concurrencychecker) rprefetch_parentsr1rr5r+r revlogchecker get_checkerr)rMs rQrzlocalrepository.changelogsV &&(zz##  " "499 -,88,O$  rUcN|jj||jSrD)r1 manifestlogr4rs rQrzlocalrepository.manifestlogszz%%dD,B,BCCrUc|j!|j|_|jS|jj|jSrD)rT _makedirstaterefreshrs rQrzlocalrepository.dirstatesD >> !!//1DN~~ NN " " $~~rUc Rd}tjrfd}tj}tj}|j v}|j v}t j jjjj|j||S)z3Extension point for wrapping the dirstate per-repo.Nc.tjSrD)r0matcherrsrQrwz/localrepository._makedirstate.. sFNN4$8rU)use_tracked_hint) r0 use_sparserVr DIRSTATE_TRACKED_HINT_V1r+rr7rr_dirstatevalidaterA)rL sparsematchfnv2_reqthuse_dirstate_v2rs` rQrzlocalrepository._makedirstates   T "8M 88  5 5 D$5$55!2!22  HH GG II  " "     -  rUcd} |jj||r|S|j s7d|_|jjtdt|z|jS#tj$r]|j H|j  |jj|n#tj$rd}YnwxYwd}YwxYw)NTFs-warning: ignoring unknown working parent %s! ) rrevr LookupError currentlock invalidaterJrr rr rB)rLnodeokays rQrz!localrepository._dirstatevalidates  NN  t $$ K///3, GHDk";; 5   !)!!NN&&t,((! D!! s5A223C"&CC"CC"CC"!C"cL|j}|tj|}|S)zdmatcher patterns for this repository's narrowspec A tuple of (includes, excludes). )rVr#load)rLvals rQ narrowpatszlocalrepository.narrowpats;s''' ;//$'C rUctj|jvrtjS|j \}}t j|j||SN)includeexclude) rVrr+matchmodalwaysrr#rrrLrrs rQr4z!localrepository._storenarrowmatchGsJ  - -T5F5F F??$ $?? 7GLLrUctj|jvrtjSt j ||j\}}t j|j||Sr) rVrr+rrr#checkworkingcopynarrowspecrrrrs rQ _narrowmatchzlocalrepository._narrowmatchNsX  - -T5F5F F??$ $--d3?? 7GLLrUcJ|r|rt|jjsZtj|j }tj |j|g}tj ||Stj ||jS|jS)amatcher corresponding the the repo's narrowspec If `match` is given, then that will be intersected with the narrow matcher. If `includeexact` is True, then any exact matches from `match` will be included even if they're outside the narrowspec. )rrrexactfiles unionmatcherintersectmatchers)rLr includeexactemnms rQ narrowmatchzlocalrepository.narrowmatchVs D$5$5$<$<$>^^EKKM2**D,=,=r+BC11%<<--eT5F5FG G   rUcVtj||||jdyNT)clearfilecache)r#saver)rL newincludes newexcludess rQ setnarrowpatszlocalrepository.setnarrowpatsis k;7 t,rUcdt|jjftt|jjf|jt|jfiS)Nnull)r rArBrs rQ_quick_access_changeid_nullz+localrepository._quick_access_changeid_nullmsL gt11889 gt11889 KK'4;;/  rUc|jj}|jj}|jj D]}}||j k(r|jj|}|1||f}|||<|||<|j|D]+}|tk(r |j|}||f}|||<|||<-|jj}||j k7r|||d<|S)N.) rrrErrparentsrBindexget_rev parentrevsr rp1) rLquickclrrpairrrp1nodes rQ_quick_access_changeid_wcz)localrepository._quick_access_changeid_wcus00557 __  ( (MM))+Dt{{"((""4(C{;DE#JE$K]]3'<GGAJ1vaa (,(!!# T[[ -E$K rUc:dt|vr|jd=yy)Nr)rrFrs rQ!_quick_access_changeid_invalidatez1localrepository._quick_access_changeid_invalidates &$t* 4 9: 5rUcj|jtjvr |jS|jS)zan helper dictionnary for __getitem__ calls This contains a list of symbol we can recognise right away without further processing. )rCr* filter_has_wcrrrs rQ_quick_access_changeidz&localrepository._quick_access_changeids. ??h44 411 1///rUc |tj|St|tjr|St|trIt |j t|Dcgc]}||jjvr||!c}S|jj|}||\}}tj|||dS|dk(rL|jj}|jj|}tj|||S t|tr|jj!|}|}n |dk(rD|j"j%}|j'jj|}nt||j(j*k(r |}|jj|}nt|d|j(j*zk(r't?|}|jj|}n6t-j@d|tCjDtG|fztj|||Scc}w#t,j.$r t1|}t2$rs|j5rV||j'j"j7vr,t9d}t-j:|t=|zt1|}wxYw#t,jHt,j.f$r5t-jJt9dtCjD|ztLt2f$r5t-jNt9d tCjD|zt,jP$rtj|cYSwxYw) NF)maybe_filteredtiprs*working directory has unknown parent '%s'!rs$unsupported changeid '%s' of type %ssfiltered revision '%s'unknown revision '%s'))r workingctxrbasectxslicerangeindicesrlr filteredrevsrr} changectxtiprintrrrrErAnodelenrFilteredLookupErrorrrrrrr$r rrr(rrNFilteredIndexErrorFilteredRepoLookupError IndexErrorRepoLookupErrorWdirUnsupported)rLchangeidi quick_accessrrrs rQ __getitem__zlocalrepository.__getitem__sT  %%d+ + h 0O h & 0 0T ;<>%%'D..$$T*C$$T35 52 ,(C(~~**84T!}}'')oo'1155d;X$"4"4"<"<<#D..,,X6C$X!d&8&8&@&@"@@8}nn((.,,;!1!1$x.!ABC $$T35 5q<00"8}H"   $(9(B(B(J(J(LL MN#kk#h*?@@"8}H 2((%*C*CD //+,x/?/?/II K( ''*+h.>.>x.HH $$ ,%%d+ + ,s4&$I,BL5I1BL1BL  LCOOcB ||y#tj$rYywxYw)z!True if the given changeid existsTF)rr)rLrs rQ __contains__zlocalrepository.__contains__s)  N$$  s cyrrrs rQ __nonzero__zlocalrepository.__nonzero__rrUcL|j}t|jSrD)rErlrrLrOs rQ__len__zlocalrepository.__len__s 4>>""rUc,t|jSrD)iterrrs rQ__iter__zlocalrepository.__iter__sDNN##rUexprcdtj|g|}tj||S)aFind revisions matching a revset. The revset is specified as a string ``expr`` that may contain %-formatting to escape certain types. See ``revsetlang.formatspec``. Revset aliases from the configuration are not expanded. To expand user aliases, consider calling ``scmutil.revrange()`` or ``repo.anyrevs([expr], user=True)``. Returns a smartset.abstractsmartset, which is a list-like interface that contains integer revisions. )r.spectreer- makematcher)rLr&rtrees rQrevszlocalrepository.revss1""4/$/'v!!$'--rUc'JK|j|g|D] }|| yw)aVFind revisions matching a revset and emit changectx instances. This is a convenience wrapper around ``revs()`` that iterates the result and is a generator of changectx instances. Revset aliases from the configuration are not expanded. To expand user aliases, consider calling ``scmutil.revrange()``. N)r+)rLr&rrs rQrSzlocalrepository.sets+4'$'Aq'M(s!#specscl|dgk(rtjtgS|dgk(r6|jj d}|tj|dgS|r7tj |j |tj||}ntj d||}||S)a<Find revisions matching one of the given revsets. Revset aliases from the configuration are not expanded by default. To expand user aliases, specify ``user=True``. To provide some local definitions overriding user aliases, set ``localalias`` to ``{name: definitionstring}``. rrNr)r localalias)r/)r-basesetr rr}matchanyrlookupfn)rLr-userr/ quick_datars rQanyrevszlocalrepository.anyrevs$s WI >>7), , TF?4488>J%~~z!}o66 t,% Ae CAwrUreturnc d|jzS)Nsfile:rrs rQrzlocalrepository.url=s$))##rUc Htj|j|||fi|S)zCall a hook, passing this repo instance. This a convenience method to aid invoking hooks. Extensions likely won't call this unless they have registered a custom hook or are replacing code that is expected to call a hook. )rr)rLrthrowrs rQrzlocalrepository.hook@s"yy$e.tagscachec<dx|_|_dx|_|_yrD)r3tagtypes nodetagscachetagslistrs rQr`z6localrepository._tagscache..tagscache.__init__Qs! -10 DM599"T]rUN)rVrWrXr`rrUrQ tagscacher<Ps :rUrA) _findtagsr3r>)rLrAcaches rQ _tagscachezlocalrepository._tagscacheIs/ : : %)^^%5" EN rUc@i}|jjr|j\}}n|jj}|jj }|j D]\}} |||||<|S#tjtf$rY3wxYw)zreturn a mapping of tag to node) rr rBrDr3rrrrr)rLtr3ttrkvs rQr3zlocalrepository.tags`s  >> & &~~'HD"??''Dnn  JJLDAq A! !%%z2  s0 BBBctj|j|}|Dcic]}|d}}tj|j|||i}|j D]0\}\}}||j k7s||t j|<2|jj|d<|j Dcic]\}}t j||}}}||fScc}wcc}}w)auDo the hard work of finding tags. Return a pair of dicts (tags, tagtypes) where tags maps tag name to node, and tagtypes maps tag name to a string like 'global' or 'local'. Subclasses or extensions are free to add their own tags, but should be aware that the returned dicts will be retained for the duration of the localrepo object.sglobalr) tagsmodfindglobaltagsr readlocaltagsrrBrtolocalrr) rLalltagstagr>r3rrhistrTs rQrBzlocalrepository._findtagsqs(($7.56gsCNg6dggtWh? ")--/ D,4t{{"/3X%%d+,#2~~))+V ?G~~?O ?OmtUH  T "E )?O  h!7 s C/ C4cL|jjj|S)z return the type of the given tag. result can be: 'local' : a local tag 'global' : a global tag None : tag does not exist )rDr>r})rLtagnames rQtagtypezlocalrepository.tagtypes''++G44rUcv|jjsg}|jjD]2\}}|j |j j |||f4t|Dcgc] \}}}||f c}}}|j_|jjScc}}}w)z)return a list of tags ordered by revision)rDr@r3rr~rrr)rLlrFrrs rQr@zlocalrepository.tagslists''A ))+1$..,,Q/A67,>DQi'Hi71aAi'HDOO $'''(Is;B4c|jjsi}|jjjD]&\}}|j |gj |(|j D]}|j||j_|jjj|gS)z&return the tags associated with a node) rDr?r3r setdefaultr~valuessortr})rLrr?rFrr3s rQnodetagszlocalrepository.nodetagss,,M,,2241((B/66q95%,,. /,9DOO ),,00r::rUc8|jj|S)z;return the list of bookmarks pointing to the specified node)rr)rLrs rQ nodebookmarkszlocalrepository.nodebookmarkss$$T**rUc |j|S)zkreturns a dictionary {branch: [branchheads]} with branchheads ordered by increasing revision number)rLrs rQrzlocalrepository.branchmaps!!$''rUc|js(tj|j|_|jSrD)rMrrevbranchcacherErs rQr`zlocalrepository.revbranchcaches1###,#;#;DOO>#--f5 5  ++A.D,E,NOO  s!,AActj||j}|!tjt d|z|S)Nr)r/ revsymbolrrrr)rLrrs rQrzlocalrepository.lookupsC  s+002 <''*B(Cc(IJ J rUc|jj|r|Stj||j SrD)r hasbranchr/rjrgrs rQ lookupbranchzlocalrepository.lookupbranchs8 >>  % %c *J  s+2244rUc|j}|jj}|j}g}|D]&}||}|duxs||v }|j |(|SrD)rrrr r~) rLrrrrrrrresps rQrzlocalrepository.knownsc ^^((""??A AT 2Q(]3D MM$  rUc|SrDrrs rQrzlocalrepository.localrrUc>|jjdddS)NphasesspublishT) untrusted)rrrs rQ publishingzlocalrepository.publishings ww!!)Z4!HHrUc|jsy|jsy|jdjj S)NFTvisible)rrtrrr rs rQcancopyzlocalrepository.cancopys9zz| ==,66CCCCrUc8|j|jk7ryy)z2the type of shared repository (None if not shared)rmN)r^rers rQrzlocalrepository.shareds ??dii 'rUrinsidefcR|jj|j|g|SrD)r7reljoinr)rLrrys rQwjoinzlocalrepository.wjoin s$txx 17w77rUcj| |j}|dj|||jyrD)rB setparentsr)rLrp2s rQr~zlocalrepository.setparents s0 :B T b"% ..0rUrec6tj|||||S)zcchangeid must be a changeset revision, if specified. fileid can be a file revision or node.)r)rfilectx)rLrerfileidrs rQrzlocalrepository.filectx s  $&I  rUc6|jjSrD)rgetcwdrs rQrzlocalrepository.getcwd s}}##%%rUcwdc:|jj||SrD)rpathto)rLrrs rQrzlocalrepository.pathto s}}##As++rUcJ||jvrg}|jj|D]\}}|dk(r tj|j d|g}d}|}|j jD]6\}} |j|s| }|t|dj}n|s d}d|_ tj|ds|} | fd}d| jz|_ |j|||f||j|<|j|S)N!rUc.tj||SrD)r;filter)scrs rQrwz-localrepository._loadfilter..) s10ErU commandfilterrc|||SrDr)rroldfnrs rQrwz-localrepository._loadfilter... s U1a[rUzcompat-)rNr configitemsrrrrOrrrllstriprVr( getargspecr~) rLrrVpatcmdmfrparamsrfilterfnrs rQ _loadfilterzlocalrepository._loadfilter s  )) )A GG//7S$;^^DIIsSE:&*&7&7&=&=&?ND(~~d+%!$SY[!1!8!8!: '@ EB"1BK**2.q1E,1HB"+enn">(+D||D22HdCCrUrflagsc z|j|j||}d|vr'|jj||t |S|jj||fd|i|d|vr(|jj |ddt |S|jj |ddt |S)zwrite ``data`` into ``filename`` in the working directory This returns length of written (maybe decoded) data. lbackgroundclosexFT)rrr@symlinkrsetflagsrl)rLrrrrrs rQwwritezlocalrepository.wwriteR s||D22HdC 5= II  dH -4y DIIOO$ 0? CI u} ""8UD94y ""8UE:4yrUc<|j|j||SrD)rrrs rQ wwritedatazlocalrepository.wwritedatak s||D22HdCCrUcj|jr|j}nd}|r|jr|Sy)z4return the current transaction or None if non existsN)rPrunning)rLtrs rQr*z"localrepository.currenttransactionn s- >>!BB "**,IrUc V|jjdds|jjddr0|j|jt j d|j jS|jjdr)t jtdtd |jjrd }t j |d tjtjfz}t!t#j$|j'}d |z}|j)d d||j+|r|}n|jj,}|j.}t1j2|d|jjdd} dk7r"| r |j4j7fdfd} fd} t9j8||j|ddd|j:j<| | t> |jAD]\} } jC| | tE|jFd<tIjFd<gjFd<ijFd<|jJd<jJd<jFjJd <jMd!|j:jNfd"}jMd#|jQd$|jSfd%}jUd&|jQd'|jVt1j2|_,t[j\||j_P|j|j`jd(sjcd)dfd*}jed+|S),Nrr>r?stransaction requires locking)rjournalsabandoned transaction founds(run 'hg recover' to clean up transactionrrz/cannot open a transaction with a dirty dirstates%.40f#%fsTXN:s pretxnopenT)r9txnnametxnidcyrDr)xs rQrwz-localrepository.transaction.. sdrUrshook-track-tagsstripc}|Jtj|j|}|jj }tj|j||}tj |j|||}|rCd|j d<|jddd5}tj||dddyy#1swYyxYw)N1s tag_movedschanges/tags.changeswT) atomictemp) rK fnoderevsrrheadrevsdifftagshookargsr7 writediff) tr2rM oldfnodesnewheads newfnodeschanges changesfileoldheadsreporefs rQ tracktagsz.localrepository.transaction..tracktags sy'''#--dggtXF >>224#--dggtXF "**477D)YO15CLL./$"$ ))+w? s 0CCc |}|Jd}|jj|}|r^|jj|d}|jdd}|jddrd}nd}t j ||||t j|jd rtjd jD]p\}\}} jj} | jtj||| |j dd d it!j"| rt j|jd r|j%j&} jdD]\} \}} | D]} jj} t)| j+| }| jt-j||| |j dd d it!j"| |j dd d it!j"jy)zwill run pre-closing hooksN)rssingle-head-per-branchrsaccount-closed-headsFspublic-changes-onlys immutablervpretxnclose-bookmarkrr9Tpretxnclose-phaserr)r)r)s pretxnclose)rrconfigsuboptionsr}r/enforcesingleheadrhashookrrrrrrrpreparehookargsr(rrErrrr&)rrM singleheadopt singlehead singleheadsub accountclosedrCrr!r"rrr+rrdescrrrs rQvalidatez-localrepository.transaction..validate s.$ cN9D# ##HM+++];J 8 8 8- H K - 1 1+U! !$$%;UC!-J!+J))#t]J||DGG%<=(.JJ|,224)$D*3;;++-DKK 9 9$S IJDII/"#,,T2 )||DGG%9:__&00(* 9(=$D*3#!{{//1"2773<0 F$:$:4c$JK! 0"&'006 $)> DII &* .6.@.@.M rUcz}|y|r|jjdy|jdyr)rrr)rsuccessrMrs rQ releasefnz.localrepository.transaction..releasefn" s;9D|   ##D)t4rUundocyrDrrrUrQrwz-localrepository.transaction..< sDrU) validatorrcheckambigfilesr origrepolens obsmarkersrrrstxnidstxnnameschangess flush-fncachecf|jfd}}|J|j|y)z@To be run if transaction is successful, will schedule a hook runc  }|Jtj|jdrtjdj }|D]p\}\}}j j}|jtj||||j d dditj|rtj|jdr|jj}tjdd}|D]\} \}}| D]} j j}t|j!| } |jt#j| |||j d dditj||j d dditj y) Ntxnclose-bookmarkrr9Ftxnclose-phaserrc|ddS)Nrr)rs rQrwzUlocalrepository.transaction..txnclosehook..hookfunc..l s QqT!WrU)r)r)r)stxnclose)rrrrrrrrrrrr(rrErrrr&)unused_successrM bmchangesrr!r"rrphasemvr+rrrrrs rQhookfunczClocalrepository.transaction..txnclosehook..hookfuncZ sy'''<<)=> &rzz,'?'E'E'G HI,5(jsC!{{//1 I$=$=dC$MN! 0"''006-6<<):;*44B$ 9-3DG-4(jsC#'C#%;;#3#3#5D#&rwws|#4D KK(>(>tS#(NO%DII 1&+#+"4"4T": $(-4 ',080B0B80LrUN)r _afterlock)rrrMrrrs @rQ txnclosehookz1localrepository.transaction..txnclosehookR s5 ||H! F9D# ## OOH %rUs txnclose-hooks -warm-cachec}|J|j ddditj|jy)z#To be run if transaction is abortedNr9F)stxnabort)rr(rr)rrMrs rQ txnaborthookz1localrepository.transaction..txnaborthook sF9D# ## DII #( ,4,>,>s||,L rUs txnabort-hooksrefresh-filecachestatssbranchsdefaultcXjD]}|j|ddy)NTr_)hardlinkr)all_file_names addbackup)rrdss rQbackup_dirstatez4localrepository.transaction..backup_dirstate s***,ALLTHLE -rUsdirstate-backup)3rrrorQrrr*nestr,rZr[rr_dirtyrandomtimerr:sha1digestr _writejournalr r~rvrwrrr4r1rra _journalfiles add_journalrlrrSr addfinalizer addpostclose_buildcacheupdateraddabort_refreshfilecachestatsrPr/registersummarycallback currentwlockr7 setbranch addvalidator)rLrreportridbaseharrpvfsmapshouldtracktagsrrvfs_idrerrrrrrrrs ` @@@@@rQr4zlocalrepository.transactiony sx 77  h 8DGG777% % 99  J '//01BC  ==  AA((+ + == v&--/ 0"  -tT G 4 BB++d#D# '',, /  8 ~~..0H @&> @ 5( $ $  II     JJ ! !(  !..0LFD NN64 (1%(Y >"$'E =! " 9#% < % H"& J"$** J ')9)9:- &^ '6 (?(?(CD  $l3 143N3NO R''b$7     *B88??9- Z. F OO. @ rUc:|jdf|jdffS)Nr journal.descr}rs rQrzlocalrepository._journalfiles s$ YY # XX '  rUcj|jDcgc]\}}|t|fc}}Scc}}wrD)rundoname)rLr7rs rQ undofileszlocalrepository.undofiles s2151C1C1EF1EvsAhqk"1EFFFs/cX|jjddt||fzy)Nrs%d %s )r7rrl)rLrs rQrzlocalrepository._writejournal s"  s4y$6G(GHrUc|j5|jjdr|jj t d|j }tj|j|d|jjt|j dddy|jjt d dddy#1swYyxYw)Nrs%rolling back interrupted transaction )rTs%no interrupted transaction available F) rr,rZrstatusrr~r4rollbackr rar)rLrs rQrecoverzlocalrepository.recover s YY[yy +q!JKL$$IIGGLL$0 ![ QHIJ[[sBC!3%C!!C*cDdx}} |j}|j}|jjdr|j ||t ||S|j jtd t ||y#t ||wxYw)Nrs"no rollback information available r) wlockrr,rZ _rollbackreleaserr r)rLdryrunforcer rs rQrzlocalrepository.rollback s !JJLE99;Dyy(~~fe4 D%  QEFG D% GD% sA B$BBcNj}jj} jj dj }t |d|dd}}}t|dk\r|d}|dz |r|jrtd||fz} ntd|fz} tfd|D} |s9d d k7r.|d k(r)tjtdtd|j| |ryjj } d} | st"} t%j&j(| d|j*t,| j/jj/| rKj0j2j4t7fdjj8Dscjj;5jj=j>jjAdddtCdjD cgc]} | jEc} }t|dkDr|jtd|zn|jtd|ztFjHjKjMy#t$rtd } d}d } YLwxYw#1swYxYwcc} w)Ns undo.descrrrfrs8repository tip rolled back to revision %d (undo %s: %s) s4repository tip rolled back to revision %d (undo %s) c3JK|]}|jkDywrD)r)ripoldtiprLs rQrjz,localrepository._rollback.. s!EWT!W[[]V3Ws #s!rolling back unknown transaction Trrcommits;rollback of last commit while not checked out may lose datasuse -f to forcerrr)rskip_journal_patternc3.K|] }|ywrDr)rir'has_nodes rQrjz,localrepository._rollback.. s>,=qx{,=ss3working directory now based on revisions %d and %d s+working directory now based on revision %d )'rrrr7rTrdrrlverboserrnrrr$r destroyingr~RE_SKIP_DIRSTATE_ROLLBACKr4rr,r rarrrr,all_plchanging_parentsr~rBclearrr mergestatemodr clean destroyed)rLr#r$rrroldlenrdetailr parentgonerr*r'r,r(s` @@rQr!zlocalrepository._rollback s WW--'') 88==.99;D&)$q'lDGT6TV4yA~aaZF"**(T6*+ LTN#EWEEJ dtF|3 8I++%)*   #  ##<  II   GG(!5      " ~~++44H>DMM,=,=>>]]33D9MM,,T[[9MM''):d4j.@.@.BC.BQUUW.BCDG7|a 1  EFP  $ $ * *4 0  9:CDJ P:9Ds%BK7>AL L"7LLLc<tj|fd}|S)zcalled during transaction to build the callback updating cache Lives on the repository to help extension who might want to augment this logic. For this purpose, the created transaction is passed to the method. c>}|J|j|yrD) updatecaches)rrMrs rQupdaterz3localrepository._buildcacheupdater..updaterB s$9D# ##   b !rUru)rLnewtransactionr=rs @rQrz"localrepository._buildcacheupdater8 s++d# " rUc2||jjddk(ry|j}|rTd}|jj |dt j }|dk(rt j}t j }n|t j}t j|vr||jdt|krt|jjd|jd j|jd j|jj!|t j"|vr|j$j'| t j(|vr|j*j'| |j,j/D]P}|j0s|j2s|j5|j7}|?|j'| Rt j8|vrB|j;}|j$D]} |j=| |j?t j@|vr(|d jCD]} | jEt jF|vr9tIjJ|j||j$jMt jN|vr|jQt jR|vr|jd jQt jT|vrTtVjXj[D]2} |j| } | jj?| 4yy) awarm appropriate caches If this function is called after a transaction closed. The transaction will be available in the 'tr' argument. This can be used to selectively update caches relevant to the changes in that transaction. If 'full' is set, make sure all caches the function knows about have up-to-date data. Even the ones usually loaded more lazily. The `full` argument can take a special "post-clone" value. In this case the cache warming is made after a clone and of the slower cache might be skipped, namely the `.fnodetags` one. This argument is 5.8 specific as we plan for a cleaner way to deal with this for 5.9. Nssourcerza`full` argument for `repo.updatecaches` is deprecated (use `caches=repository.CACHE_ALL` instead)s5.9s post-clonersupdating the branch cache rr)r4r).rr}rEr deprecwarnr9 CACHES_ALLCACHES_POST_CLONECACHES_DEFAULTCACHE_BRANCHMAP_SERVEDrrlrrrrL write_delayedCACHE_CHANGELOG_CACHEr update_cachesCACHE_MANIFESTLOG_CACHErr1walk is_revlogis_manifestlogget_revlog_instance get_revlogCACHE_REV_BRANCHr` branchinforCACHE_FULL_MANIFESTrmanifestCACHE_FILE_NODE_TAGSrKrr+CACHE_TAGS_DEFAULTr3CACHE_TAGS_SERVEDCACHE_BRANCHMAP_ALLr* filtertablekeys) rLrfullcachesrOrentrymanifestrevlogrbcrrfiltrs rQr<zlocalrepository.updatecachesI s >bkkooi8HD   >  GG  sF +**F}$#55**F ^..F  , , 6zRZZ7#d)C <= i(224 ./99;""006  + +v 5 NN ( (R ( 8  - - 7    * *r * :*++!&!:!:4!@!K!K!M!-"00R0@+  & && 0%%'C^^q!$ IIK  ) )V 3Dz))+ ,  * *f 4   dggtT^^-@-@-B C  ( (F 2 IIK  ' '6 1 MM) $ ) ) +  ) )V 3 !,,113==.""$**844 4rUcdt|vr |jd=|jj|j |j jy)NrD)rrFrLr3invalidatevolatilesetsrXrs rQinvalidatecachesz localrepository.invalidatecaches sJ 4: % l+   " ##% ""((*rUc|jjtj||j yrD)rSr3r$clearobscachesrrs rQr_z&localrepository.invalidatevolatilesets s. ##%% ..0rUc|j}d|jvr&|jjrJ|jd=yy)aInvalidates the dirstate, causing the next call to dirstate to check if it was modified since the last time it was read, rereading it if it has. This is different to dirstate.invalidate() that it doesn't always rereads the dirstate. Use dirstate.invalidate() if you want to explicitly read the dirstate again (i.e. restoring it to a previous known good state).rN)rErFris_changing_anyr!s rQinvalidatedirstatez"localrepository.invalidatedirstate s@   &}}44 44 j) 'rUc|j}t|jjD]J}|dk(r'|j r|j j r/|r |j|= t||L|j|j s|jjyy#t$rYwxYw)a9Invalidates both store and non-store parts other than dirstate If a transaction is running, invalidation of store is omitted, because discarding in-memory changes might cause inconsistency (e.g. incomplete fncache causes unintentional failure, but redundant one doesn't). rN) rElistrrWr*r_delayedr AttributeErrorr`r1)rLrrErHs rQrzlocalrepository.invalidate s__& doo**,-A\!++-NN++ OOA&  A&." &&( JJ ' ' ) )"  s3 B== C C cD|j|jy)zyFully invalidates both store and non-store parts, causing the subsequent operation to reread any outside changes.N)rrers rQ invalidateallzlocalrepository.invalidateall s  !rUc|jjD]>\}}tj|}|dk(s||jvr/|j @y)z>Reload stats of cached files so that they are flagged as validrN)rrr(rrFr)rLrrHces rQr z&localrepository._refreshfilecachestats sK__**,EAr"AJ!4=="8 JJL -rUc  d}d}|r8|jjdd}|jjdd}|jjdd} tj|j||||||||  } | S)Nruistimeouts timeout.warnssignal-safe-lock)r acquirefnr signalsafe)rrrlockmodtrylock) rLr7locknamewaitrrprtimeout warntimeoutrqrVs rQ_lockzlocalrepository._lock s gg''z:G''++E?CKWW''/BC OO GG    ! rUc|j|jfD]9}|xr|}|s|js|jj |y|dy)zadd a callback to be run when the repository is fully unlocked The callback will be executed when the outermost lock is released (with wlock being higher level than 'lock').TN)rRrQheld postreleaser~)rLrrwrVs rQrzlocalrepository._afterlock sM NNDMM2C AQVV $$X. 3 TNrUc |j|j}||j|S|j|jd|d|j t d|jz}tj||_|S)a]Lock the repository store (.hg/store) and return a weak reference to the lock. Use this before modifying the store (e.g. committing or stripping). If you are opening a transaction, get a lock as well.) If both 'lock' and 'wlock' must be acquired, ensure you always acquires 'wlock' first to avoid a dead-lock hazard.Nslocks repository %s)r7rtrurrpr) rorQrrxr,rrrrvrw)rLrurVs rQrzlocalrepository.lock s}   dmm , = FFHH JJ oo#$t}}4   A rUc "jrjnd}||jr|j|S|rnjj ddsjj ddr6j j jjdfd}jjd||jtdjz}tj|_|S) a8Lock the non-store parts of the repository (everything under .hg except .hg/store) and return a weak reference to the lock. Use this before modifying files in .hg. If both 'lock' and 'wlock' must be acquired, ensure you always acquires 'wlock' first to avoid a dead-lock hazard.Nrr>r?s"wlock" acquired after "lock"cjjr8d}jj|jj nNjj rd}jj|jj dj}d|jvr|jd=yy)Ns1wlock release in the middle of a changing parentssdirty dirstate on wlock releaser) rrdrrmrrrrErF)rrOrLs rQunlockz%localrepository.wlock..unlockH s}},,J!!#& ((*==''>IJG[[]MM++A.9W T]]0B&A01299??1%)9)9!)<DA%==+!&Q"> ?@dmm+A234#-rUc |i}d}|stj}|s||_j5j 5d} t | j dkD} |s0| r.|jstjtdj||} |r%| jj| jtjj | | ||\} } }|sj#| || |t%j&| ||||}t(j*j-}t/j0||j3rYj j5dds=j j7d |j9 ddddddy| r.|j;rtjtd |r||| |_||j<k7}j?|j<}| rtAjB}tE| D]}}| jG|}j jtd |tjH|z|jK|j<||}||d |f||<tjL|jNj \}}tQ||jRk7xr tQ|xsd c jUddjWd5jY|dt[j\||g|j_|j9dddddddddfd}jc|S#1swY4xYw#|rNj jatd|zj jatd|zxYw#1swYxYw#1swYxYw)zAdd a new revision to current repository. Revision information is gathered from the working directory, match can be used to filter the committed files. If editor is supplied, it is called to get a commit message. Nc6tjd||fz)Ns%s: %s)r InputError)rrs rQrz$localrepository.commit..fail s""93x#78 8rUrsBcannot partially commit a merge (do not specify files or patterns))rr5)r$rosallowemptycommits(nothing to commit, clearing merge state s&cannot commit merge with missing filesscommitting subrepository %s rrUs precommitT)r9parent1parent2r)s!note: commit message saved in %s s6note: use 'hg commit --logfile %s --edit' to reuse it czjjrjdtyy)Nr))rrr)rhasnoderr)rhookp1hookp2r3rLs rQ commithookz*localrepository.commit..commithook s:~~%%c* CHff+rU)2rrbadr rrlrrr$rrrextendr5r2 precommitrrrworkingcommitctxr4r rTr!checkunresolvedisemptyrrresetr_textsavecommitmessager/ getuipathfnrr subrelpathr writestaterrrBrr4 commitctxrr markcommittedrr)rLtextr3daterr$editorextrarrmergersubs commitsubsnewstatecctxmseditedmsg_pathuipathfnrrsrrrrrrr3s` @@@rQrzlocalrepository.commit s" =E 9OO%EEIZZ\499;:D '!+EU5<<>kk>[[uE[:F&&LL *5)>)>vuE* &D*h ((ufdC++fdD$D))..t4B  % %b )||~dgg&8&8*' JK Q'\\Tkk!$M"NOO#D$5 TZZ'F --djj9H"..t4 +A((1+CGGNN:;";#9#9##>?@DJJd;B#+A;q>2"6HQK,&&tX6]]**,FB WrT[['8'DSW'KNFF   ff%%i0..t4C$$TB8S9&&s+HHJ 1S'\z   # ;10 GGMM?@8KGGMM8# #w';\\s]Q E2Q>QE,Q<&O."A O"/O.7Q"O+ 'O..AQQQ QQc4tj||||S)N)rorigctx)rr)rLrrrs rQrzlocalrepository.commitctx scHHrUcTdt|vr|jjyy)aInform the repository that nodes are about to be destroyed. Intended for use by strip and rollback, so there's a common place for anything that has to be done before destroying history. This is mostly useful for saving state that is in memory and waiting to be flushed when the current lock is released. Because a call to destroyed is imminent, the repo will be invalidated causing those changes to stay in memory (waiting for the next unlock), or vanish completely. rN)rrrrs rQr.zlocalrepository.destroying s' DJ &    " " $ 'rUc|jj||jj|j|j y)zInform the repository that nodes have been destroyed. Intended for use by strip and rollback, so there's a common place for anything that has to be done after destroying history. N)r filterunknownrr<rrs rQr6zlocalrepository.destroyed% sD &&t,    rUc4||j||||||S)z3a convenience method that calls node1.status(node2))r)rLnode1node2rignoredr5unknown listsubreposs rQrzlocalrepository.statusE s(E{!! 5'5'<  rUc:|jj|y)aAdd a callback to run within the wlock, at the point at which status fixups happen. On status completion, callback(wctx, status) will be called with the wlock held, unless the dirstate has changed from underneath or the wlock couldn't be grabbed. Callbacks should not capture and use a cached copy of the dirstate -- it might change in the meanwhile. Instead, they should access the dirstate via wctx.repo().dirstate. This list is emptied out after each status run -- extensions should make sure it adds to this list each time dirstate.status is called. Extensions should also make sure they don't call this for statuses that don't involve the dirstate. N)rUr~)rLpss rQaddpostdsstatuszlocalrepository.addpostdsstatusT s( !!"%rUc|jS)zAUsed by workingctx to get the list of post-dirstate-status hooks.rUrs rQ postdsstatuszlocalrepository.postdsstatusj s!!!rUc"|jdd=y)z7Used by workingctx to clear post-dirstate-status hooks.Nrrs rQclearpostdsstatusz!localrepository.clearpostdsstatusn s   q !rUc|D|j}t|j}|Dcgc]}|j|c}S|jj |}t ||jj dScc}w)NT)rreverse)rreversedrrrrr)rLstartrrrrs rQrzlocalrepository.headsr so =B .H,45HSBGGCLH5 5$$U+e!3!3TBB 6sBcH||dj}|j}|j|sgStt |j ||}|=t |jj|g|d}|Dcgc] }||vs| }}|Scc}w)aVreturn a (possibly filtered) list of heads for the given branch Heads are returned in topological order, from newest to oldest. If branch is None, use the dirstate branch. If start is not None, return only heads reachable from start. If closed is True, return heads that are marked as closed as well. N)closedr) rgrrlrgr branchheadsrSr nodesbetween)rLrgrrrFbheadsfbheadshs rQrzlocalrepository.branchheads| s >$Z&&(F>>#!!&)Ihx33F63JKL  $..55ugvFqIJG!'8A1.runhook s& II#  rU)s prepushkey)r*rrr(rrr HookAbortr write_errrrsrr'pushr) rLrrr!r"rrr5rr3s ````` @rQr'zlocalrepository.pushkey s' ((*BH~ ,))(3H$-H[ !!HUO!HUO!HUO DII <4 <8 <  2i5EEFll4Cc:     '  GG  a 67#= >xx!!!I,"9:  sA,C E A$EE c|jdd||jjd|ztj||}|jd|||S)Ns prelistkeysT)r9rslisting keys for "%s" slistkeys)rrY)rrrr'rg)rLrrYs rQrzlocalrepository.listkeys sQ . B  09<=dI. +6 B rUcd||tj|tj|tj|fzS)z+used to test argument passing over the wirerrrs rQrzlocalrepository.debugwireargs rrUc|jdd} |j||j|j|jt |j dzdS#|jwxYw)Nslast-message.txtswbr)r7rrrrrlr)rLrfps rQrz!localrepository.savecommitmessage sa XX)5 1  HHTN HHJ{{2773tyy>A#5#7899 HHJs A))A;ctj|jvry|jj t j |yrD)r9rryrrbr(r)rLcategorys rQregister_wanted_sidedataz(localrepository.register_wanted_sidedata s6  , ,DMM A  !!("2"28"<=rUc|tjvr#td}tj||zt j |}||jj|gv}|r%|s#td}tj||z|r%|s#td}tj||z|jj|i|||f|j||<y)Nsunexpected revlog kind '%s'.s<cannot register a sidedata computer twice for category '%s'.sKcannot replace a sidedata computer that isn't registered for category '%s'.) r ALL_KINDSrrrr(rr]r}rX) rLkindrrWcomputerrreplaceralready_registereds rQregister_sidedata_computerz*localrepository.register_sidedata_computer s {,, ,34C((t4 4##H-%)A)A)E)EdB)OO gOC((x8 8 -&C((x8 8   ++D"548(E3J  &x0rUrDr)FN)Fr=)FF)NFN)T)rUNNNFNN)rNNFFFFr<)rVrWrXrYrVARCHIVED_PHASE_REQUIREMENTBOOKMARKS_IN_STORE_REQUIREMENTrrrr rrrINTERNAL_PHASE_REQUIREMENTrrWrrrrrrrrrrpbytesrYr7r`rDrIpropertyr~rrrrrrrrErrrrrrmrrrrrrrrrrrr#FILENAMErr4rrrrrrrrrrr__bool__r"r%r+rSr5rrrrDr3rBrTr@r[r]rr`rdrfrrmrrrtrwrr|r~rrrrrrrrrrrrrr*r4rrrrrr!rr<r`r_rerrkr rxrrr ror rrrrr.r6rrrrrrrFrCrrr'rrrrrrrUrQrrs  2266//--00//--++0022++33,,,,**--**00))00)N2<]5 ]5  ]5 zz ]5]5**]5::]5~1f,  ) KK   $L  5$ (  2'  2'h &&  /0<1< 11  DD *@ ##$ %  ##$M%M  ##$M%M!&-  <;;00M,^H# $..  U2$U$=,"! F 5( ;+( $$ >  5 I D 8u88%81  E &&,,HUO,u,(4 ++++)DeDD   2D5DD%D zx  GII$ !TTl"W5W5r+1 **B"< ..`105,  CCJII%%"B  &,""C* &  B :>>CKrUrrr6ctjj|\}}|jdsJtjj ||j dddS)Nrrr)osrerrrgr)rr\rs rQrrsLr"JD$ ??: && & 77<<dll:wB CCrUcddlm}tj||rt |fd}|}|j ||}|S)Nrro createoptsc tS)N)rx)r)rx localpathrsrQ repo_makerzinstance..repo_maker$s"2y'BBrU)rrpr= urllocalpathcreaterepositorymay_auto_upgrade) rrecreaterxrrprrMrs ` ` @rQinstancersK$$T*I Y:>C |jtj,|jtj.|j ddr|jtj0|j3dd}|dk(r|jtj,|j3dd}|dk(r>|j5tj |jtj6|j ddr|jtj8|j ddr|jtj:|j=dr|jtj>|j=dr|jd|j ddr|jtj@|j dd r|jtjB|j dd!r|jtjDd"|vrtG|d"jH}tjD|vr|}nDtG} |D]+} | tjJvr| |vr| j| -|| z}||z}|j=d#r |jtjLn|jtjN|j dd$rd|jQdd%} td&} td'} | d(k7r|jS| | z| |S|jtjT|S))zDetermine the set of requirements for a new local repository. Extensions can wrap this function to specify custom requirements for new repositories. r sFbackend key not present in createopts; was defaultcreateopts() called?rsCunable to determine repository requirements for storage backend: %srsusestores usefncaches dotencodesrevlog-compressionsIcompression engines %s defined by format.revlog-compression not available, c3&K|] }d|z yw)s"%s"Nr)rirs rQrjz&newreporequirements..s:k1kss;run "hg debuginstall" to list available compression enginesrrrsrevlog-compression-zstdszlibrrsuse-dirstate-v2s"exp-use-copies-side-data-changesetrrsexp-use-changelog-v2s*enable-unstable-format-and-corrupt-my-datarsuse-internal-phasesexp-archived-phase narrowfilesrsbookmarks-in-storesuse-persistent-nodemapuse-share-safe sharedreposharedrelativesuse-dirstate-tracked-hints!use-dirstate-tracked-hint.versions)ignoring unknown tracked key version: %d s<see `hg help config.format.use-dirstate-tracked-hint-versionr)+rrr$rrVrrrbrrr configlistr6rrrrgr/ gdinitconfigrrr rrrrrrrrr}rrrrrSr+rrWrrr r)rrr+r compenginer changelogv2revlogv2source_requirementsto_dropreqversionrrss rQrrUs#$$ /  *,kk ' $  %  $889L }}Y ,::; ==M 2   _@@ A}}Y 5  !F!FG-- +@AK! )) )%%j1F!f&9&9&; " kk ; jj:k::  ; '  W34 w .;<BAAB ==$4 5   _EE F }}Y 23@@A }}Y EF@@A>>? }}_o6AAB))I'>?KCC@@Ayy+6H@@_AAB==> }}Y 56CCD }}Y 56CCD~~n%;;<~~f  }}Y 56GGH }}Y 9:<<= }}Y 12>>? "!*]";"H"HI  0 08K K/LeG#/BBB-- C $ G #L / /L >>+ ,   _HH I   _?? @ }}Y <=,,y*NO=> K  a< GGC'MG -    _EE F rUct}tj|vrtj|vr9|j t d|j tjtj|vstj|vrtjt dtj|vrM|jddrt d}|j ||j tj|S)zChecks compatibility of repository requirements enabled and disabled. Returns a set of requirements which needs to be dropped because dependend requirements are not enabled. Also warns users about itsvignoring enabled 'format.bookmarks-in-store' config beacuse it is incompatible with disabled 'format.usestore' config s\cannot create shared repository as source was created with 'format.usestore' config disabledrrsrignoring enabled 'format.use-share-safe' config because it is incompatible with disabled 'format.usestore' config ) rSrVrrr rrbrrWrr$rr)rr+droppedrs rQcheckrequirementscompatr&s eG(( <  9 9\ I GG4  KKFF G  . ., >::lJ++?   0 0L @||I'89!  KK== > NrUchhd}|jDcic] \}}||vs ||c}}Scc}}w)a%Filters a dict of repo creation options against options that are known. Receives a dict of repo creation options and returns a dict of those options that we don't know how to handle. This function is called as part of repository creation. If the returned dict contains any items, repository creation will not be allowed, as it means there was a request to create a repository with options not recognized by loaded code. Extensions can wrap this function to filter out creation options they know how to handle. >shallowfilestorerr rr shareditemsr)r)rrrrHrIs rQfilterknowncreateoptsr*s< E(--/ B/TQ1E>AqD/ BB Bs ..cp||d}tj|i}nt||}t||}t |t stjd|rDtj tddjt|ztdt||}|t||z}tj|d d }tj|jd }|jr!tjtd |zd |vr`|d j }|j#dr@ t$j&j)||j*}t-j.|}|js|j9|j;d d |vr|j=d|j=dt>j@|v} | r'd |vr#|j=d|jCddtEjF|\} } tEjH|| | r@d |vr  +2*E /LAA jj$>G JJw||F+ ,E ||~ooa ?@4GHH " .99 >>+ , WW__ZD !]]:6  >>  MMTM"J& H KK 11\AI]*4 H    00>OE8 %' M3::ejj2Fh1 " M:.~~n%F:n#=>?%G Iv&&eZ( kk78#003 s?K..L5=3L00L5cf|jGdd}tj|d|y)z9Poison a repository instance so it can no longer be used.ceZdZdZdZy),poisonrepository..poisonedrepositorycb|dk(rtj||Stjd)Nrs/repo instances should not be used after unshare)r__getattribute__rr)rLitems rQr;z=poisonrepository..poisonedrepository.__getattribute__s2w..tT::((B rUcyrDrrs rQrz2poisonrepository..poisonedrepository.closes rUN)rVrWrXr;rrrUrQpoisonedrepositoryr9s   rUr>rPN)rrr)rMr>s rQpoisonrepositoryr?s, JJL   t[*<=rUrD)NN)rrrrerrrv concurrentrtypingri18nrrrrr r r r(r r rrrrrrrrrrrrrrrrrrrrrrr r4r!r"r#r$r%r&r'r)r*r+rVr,r-r.r/r0r1rr2r3rKr4r5r6r7rYr8 interfacesr9 interfaceutilutilsr:r;r<r= revlogutilsr>rr?rr@r^r"urlerrrcompiler/rSra filecacherBr]rmrrrrr propertycacherrrrrunionrA implementeripeercommandexecutorr ipeercommandsrripeerlegacycommandsr?rr`rfrrrrrrrrrrr#ilocalrepositoryfilestorager%r1r7ilocalrepositorymainrrrrboolr r rrr&r*rr?rrUrQrTs ,,,,,,,,,,,,\  //  &BJJ2u IW&&I$ #N #     Z  z $.$* (d00(2D..2+    34 5 :::;**<*Z:334U* U*5U*t:99:PiP;PNE2 /{e{F '+ - ZZ- ::-  # -`K60 > 4 .$NiX :AAB E EC E:AAB   C  !"$$&67++-DE :::;~#K~#K<~#KBHDD5D u  %D ,Rj(VC6{'u{'|>rU