*8VddlZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZmZmZdd lmZmZmZmZmZm Z mZmZmZdd l m!Z!ejDd Z#d Z$d Z%dZ&e e#de&Z'dZ(dZ)dZ*e*\Z+Z,dZ-dZ.dZ/e e#ddxse/Z0dZ1dZ2dZ3dZ4dZ5de5dzzdz Z6dZ7dZ8dZ9e e#d e9Z9d!Z:d"Z;gd#Zd&Z?ejd'ZAd(ZBd)ZCe jd*+Gd,d-ZEe jd*d./Gd0d1ZFe jd*d./Gd2d3eFZGe jd*d./Gd4d5eFZHd6ZId7ZJd8ZKGd9d:ZLGd;dZNGd?d@ejZPGdAdBeLZQy)CN) GeneratorList)_)getattr)attr)hex) INDEX_HEADERKIND_CHANGELOG KIND_FILELOGKIND_MANIFESTLOG) changelogerrorfilelogmanifestpolicypycompatrevlogutilvfs)hashutilparsersi@Bc|y|jr||jS|jr*|j|jj dSt j d|z)zparses a fncache entry and returns whether the entry is tracking a path matched by matcher or not. If matcher is None, returns TrueT/scannot process entry %r) is_filelog target_idis_manifestlogvisitdirrstriprProgrammingError)entrymatchers 3usr/lib/python3.12/site-packages/mercurial/store.py_match_tracked_entryr$,sd  u''    6 6t <==  !;e!C DDcf|jddjddjddS)aM >>> _encodedir(b'data/foo.i') 'data/foo.i' >>> _encodedir(b'data/foo.i/bla.i') 'data/foo.i.hg/bla.i' >>> _encodedir(b'data/foo.i.hg/bla.i') 'data/foo.i.hg.hg/bla.i' >>> _encodedir(b'data/foo.i\ndata/foo.i/bla.i\ndata/foo.i.hg/bla.i\n') 'data/foo.i\ndata/foo.i.hg/bla.i\ndata/foo.i.hg.hg/bla.i\n' .hg/.hg.hg/.i/.i.hg/.d/.d.hg/replacepaths r# _encodedirr1=s/ Wj)  #  #r% encodedircrd|vr|S|jddjddjddS)z >>> decodedir(b'data/foo.i') 'data/foo.i' >>> decodedir(b'data/foo.i.hg/bla.i') 'data/foo.i/bla.i' >>> decodedir(b'data/foo.i.hg.hg/bla.i') 'data/foo.i.hg/bla.i' r'r,r+r*r)r(r-r/s r# decodedirr4Rs<d  Y' F # W %r%c#KdDcgc] }t|}}tdD]}|tddD]}||D]}|ycc}ww)zcharacters that are problematic for filesystems * ascii escapes (0..31) * ascii hi (126..255) * windows specials these characters will be escaped by encodefunctions z\:*?"<>| ~N)ordrange)x winreserveds r# _reservedr=ds\$00>> enc, dec = _buildencodefun() >>> enc(b'nothing/special.txt') 'nothing/special.txt' >>> dec(b'nothing/special.txt') 'nothing/special.txt' >>> enc(b'HELLO') '_h_e_l_l_o' >>> dec(b'_h_e_l_l_o') 'HELLO' >>> enc(b'hello:world?') 'hello~3aworld~3f' >>> dec(b'hello~3aworld~3f') 'hello:world?' >>> enc(b'the\x07quick\xADshot') 'the~07quick~adshot' >>> dec(b'the~07quick~adshot') 'the\x07quick\xadshot' _AZr~%02xc3Kd}|t|kr;tddD]} ||||z||z }nt|t|kr:yy#t$rY;wxYww)Nrr)lenr:KeyError)sildmaps r#decodez_buildencodefun..decodest #a&j1a[qQU|,,FA !#a&j  s- AAAA AAAAc djtt|Dcgc] }|||dzc}Scc}w)Nr%r)joinr:rFrHccmaps r#z!_buildencodefun..s7#((c!f F 1D1q1u. FGFs<cDdjt|SNr%)rNlist)rHrLs r#rRz!_buildencodefun..s#((4q ?+r%) rbytechrrUmapr:r9r=loweritems) exchrasciistrcapitalsr;kvrQrLrKs @@@r#_buildencodefunr`vs0 A   DCeCj)*HE#d)SY]34H" #(QAqD( #D [ 1 T!W  Q DGMMO+T!W ! D 1Q  H+ / $s" C0c*tt|S)z~ >>> encodefilename(b'foo.i/bar.d/bla.hg/hi:world?/HELLO') 'foo.i.hg/bar.d.hg/bla.hg.hg/hi~3aworld~3f/_h_e_l_l_o' ) _encodefnamer2rHs r#encodefilenamerds  ! %%r%c*tt|S)z~ >>> decodefilename(b'foo.i.hg/bar.d.hg/bla.hg.hg/hi~3aworld~3f/_h_e_l_l_o') 'foo.i/bar.d/bla.hg/hi:world?/HELLO' )r4 _decodefnamercs r#decodefilenamergs \!_ %%r%cLtj}tdDcic]}||||c}tD]}d|z||<tt dt ddzD]!}||j ||<#fd}|Scc}w)z >>> f = _buildlowerencodefun() >>> f(b'nothing/special.txt') 'nothing/special.txt' >>> f(b'HELLO') 'hello' >>> f(b'hello:world?') 'hello~3aworld~3f' >>> f(b'the\x07quick\xADshot') 'the~07quick~adshot' r@rCrArBrcxdjtj|Dcgc]}| c}Scc}wrT)rNr iterbytestrrOs r# lowerencodez)_buildlowerencodefun..lowerencodes5xx(*>*>q*AB*AQa*ABCCBs 7)rrVr:r=r9rX)r[r;rkrQs @r#_buildlowerencodefunrls   D&+Cj 1jDGT!W j 1D [ 1 T!W  3t9c$i!m ,Q T!W -D  2sB!rk)sauxsconsprnsnul)scomslptct|D]\}}|s |r$|ddvrdt|ddz|ddz}|||<nu|jd}|dk(r t|}|dk(r |ddtvs |d k(r?|dd d kr7|dd d k\r/|ddt vr$dt|d dz}|dd |z|ddz}|||<|ddvs|dddt|ddzz||<|S) a Encodes filenames containing names reserved by Windows or which end in period or space. Does not touch other single reserved characters c. Specifically, c in '\:*?"<>|' or ord(c) <= 31 are *not* encoded here. Additionally encodes space or period at the beginning, if dotencode is True. Parameter path is assumed to be all lowercase. A segment only needs encoding if a reserved name appears as a basename (e.g. "aux", "aux.foo"). A directory or file named "foo.aux" doesn't need encoding. >>> s = b'.foo/aux.txt/txt.aux/con/prn/nul/foo.' >>> _auxencode(s.split(b'/'), True) ['~2efoo', 'au~78.txt', 'txt.aux', 'co~6e', 'pr~6e', 'nu~6c', 'foo~2e'] >>> s = b'.com1com2/lpt9.lpt4.lpt1/conprn/com0/lpt0/foo.' >>> _auxencode(s.split(b'/'), False) ['.com1com2', 'lp~749.lpt4.lpt1', 'conprn', 'com0', 'lpt0', 'foo~2e'] >>> _auxencode([b'foo. '], True) ['foo.~20'] >>> _auxencode([b' .foo'], True) ['~20.foo'] r. rCrN.rE91) enumerater9findrF_winres3_winres4)r0 dotencoderInrJecs r# _auxencoder|s,$1  13q1v;&12.ADGt ABwFQ1Ra5H,QaFdNaFdNbqEX%AaF +aFRK!AB%'Q R5E>fx#af+55DG- . Kr%xrEc|ttj|j}t |ddj d}t ||}|d}tjj|\}}g}d} |ddD]Z} | dt} | ddvr| dddz} | dk(r t| } n| dzt| z} | tkDrn|j| | } \dj|} t| dkDr| dz } d| z|z|z}tt|z }|dkDr|d|}d| z|z|z|z}|S) Nrrprrnr?rsdh/)r rsha1digestrksplitr|osr0splitext _dirprefixlenrF_maxshortdirslenappendrN_maxstorepathlen)r0ryrlepartsbasename_rootextsdirssdirslenpdtdirsres spaceleftfillers r# _hashencodersY t$++- .F T!"X  $ $T *B r9 %ERyH!!(+JE3 EH 3BZ n}  R5E>#2 A q=AA1 s1v%A## Q 99U D 4y1}   4-& 3 &C 3s8+I1}*9%tmf$v-3 Jr%ct|}t|jd}djt ||}t |t kDr t||}|S)aeencodes path with a length limit Encodes all paths that begin with 'data/', according to the following. Default encoding (reversible): Encodes all uppercase letters 'X' as '_x'. All reserved or illegal characters are encoded as '~xx', where xx is the two digit hex code of the character (see encodefilename). Relevant path components consisting of Windows reserved filenames are masked by encoding the third character ('aux' -> 'au~78', see _auxencode). Hashed encoding (not reversible): If the default-encoded path is longer than _maxstorepathlen, a non-reversible hybrid hashing of the path is done instead. This encoding uses up to _dirprefixlen characters of all directory levels of the lowerencoded path, but not more levels than can fit into _maxshortdirslen. Then follows the filler followed by the sha digest of the full path. The filler is the beginning of the basename of the lowerencoded path (the basename is everything after the last path separator). The filler is as long as possible, filling in characters from the basename until the encoded path has _maxstorepathlen characters (or all chars of the basename have been taken). The extension (e.g. '.i' or '.d') is preserved. The string 'data/' at the beginning is replaced with 'dh/', if the hashed encoding was used. r)r2rbrrNr|rFrr)r0ryefrs r# _hybridencoder8sU> T?D d  ! !$ 'B ))Jr9- .C 3x""$ * Jr%ct|}t|tkDr t|dSt |j d}dj t|d}t|tkDr t|dS|S)NTr)r2rFrrrbrrNr|)r0derrs r# _pathencoder_sn 4B 4y##2t$$ b    %B ))Jr4( )C 3x""2t$$ Jr% pathencodect|dSNF)rfs r#_plainhybridencoderms E ""r%c |jj}dtjzd|zk(rd}|S#t$rd}Y|SwxYw)Ni)statst_moderumaskOSError)rmodes r# _calcmoderqsVxxz!! TZZK UT\ 2D K  Ks6: A A ) bookmarks narrowspecdatameta 00manifest.d 00manifest.i 00changelog.d 00changelog.i phaserootsobsstorerequires).i.idx.d.dat.n.nd.sda)rrrr)rrs.*undo\.[^/]+\.(nd?|i)$cX|tjk7ry|jtryy)NFT)rS_IFREGendswithREVLOG_FILES_EXT)rkindsts r# is_revlogrs$ t||zz"# r%c0|jtryyNTF)rrrs r#is_revlog_filerszz"# r%T)slotsceZdZdZej Zej dZej dZdZ dZ y) StoreFileza file matching a store entryNdefaultFc2|j_|&d}||jz}tj| |j |jj |_|jS|jS#t $rd|_Y|jSwxYw)Ns1calling vfs-less file_size without prior call: %sr) _file_sizeunencoded_pathrr rst_sizeFileNotFoundError)selfrmsgs r# file_sizezStoreFile.file_sizes ?? "{Jt***,,S11 $"%((4+>+>"?"G"Gt% $"# $s*A88BBc~jdfd}|}t|j|fS)zvreturn data "stream" information for this file (unencoded_file_path, content_iterator, content_size) Nc3Kjj}t|d5}ddkr|jnt j |Ed{dddy7 #1swYyxYww)Nrblimit)rNropenreadr filechunkiter) actual_pathfpcopiesrsizers r# get_streamz(StoreFile.get_stream..get_streamss $*=*=!>?Kk4(B 5=''$-'#11"DAAA )( B )(s.+B8A6&A4'A6+ B4A66A?;B)rnextr)rrrrrHrs``` @r#rzStoreFile.get_streams< ~~d# B L Q##Q--r%) __name__ __module__ __qualname____doc__ribrr is_volatilerrr%r#rrs<'TWWYN&J$''%(K .r%rF)rinitc4eZdZdZdeefdZ ddZy)BaseStoreEntryzaAn entry in the store This is returned by `store.walk` and represent some data in the store.returnctN)NotImplementedErrorrs r#fileszBaseStoreEntry.filess!!r%Ncp|J|jDcgc]}|j||c}Scc}w)ureturn a list of data stream associated to files for this entry return [(unencoded_file_path, content_iterator, content_size), …] )rr)rreporr max_changesetpreserve_file_countrs r# get_streamszBaseStoreEntry.get_streamss737::<@11r%c(|jtk(Sr)r r rs r#rzRevlogStoreEntry.is_manifestlog9s#333r%c(|jtk(Sr)r r rs r#rzRevlogStoreEntry.is_filelog=s<//r%c |jdzS)z&unencoded path of the main revlog filer)r rs r#main_file_pathzRevlogStoreEntry.main_file_pathAs  5((r%rc6|jg|_t|jtD]]}|j|z}|j|}|j t }t|||}|jj|_|jS)N)key) rsortedr _ext_keyr rREVLOG_FILES_VOLATILE_EXTrr)rrr0rvolatilers r#rzRevlogStoreEntry.filesEs ;; DKdmm:((3. MM#. <<(ABdIx8 ""1%;{{r%c|:|8td|jjDsd|jvrt||||||S|s|j Dcgc]/}|j jds|j||1}}|j|j}|j |} |j| |Si} |j D] }|jd| |j <"|j Dcgc]/}|j jds|j||1}}|jdz} d || jtj } t"j$j'| r4| | fd} | }t)|d|j+| |fn|j|j}|j |d} | D]S\}}| j-|d k7st/d }|| j-|d |fz}t1j2||j| j5 |j }t7|t7|k(sJ|||j|j8f|Scc}wcc}w#j5wwxYw) Nc3>K|]}|jdyw)rNr).0r^s r# z/RevlogStoreEntry.get_streams..asE0D11::g&0Dsr)rrrrr)rrrc3K} |jdddkr|jntj|Ed{|j y7#|j wxYww)Nrrr)seekrrrclose)r index_filers r#rz0RevlogStoreEntry.get_streams..get_streamse#B# " 5="$''$-/'+'9'9"D'III J s/A<AA'A%A'A<%A''A99A<T) force_inliners(expected %d bytes but %d provided for %s)anyr keysrrrrrrget_revlog_instance get_revlogextendrr rr r revlogmodris_inline_indexrrgetrrAbortr"rFr)rrrrrrrstreamrl rl_stream name_to_size index_pathheaderrrHnamerrr#rrs @@r#rzRevlogStoreEntry.get_streamsUs L$E 0B0B0DEE %7&+$7 ' %%A''00@ S&)%  ))$/::L)) * ZZ\ !##,,U3 LLf %!  &&.  " #ZJ__\%6%67F//7#J/ #LQ!  z1d34--d3>>@NN=tNL %.MD!T#''a0D8 KL|//a8$DD#kk#.. &/  i(%  " 6{c%j(      NN +  (  E T%  "&s (4K (4K%0C K*;A K**K?c4|jrtj|jS|jr8|j}t j |j|j|Stj|j|jS)zrObtain a revlog instance from this store entry An instance of the appropriate class is returned. )tree) rrsvfsrrrmanifestrevlog nodeconstantsr)rrmandirs r#r'z$RevlogStoreEntry.get_revlog_instancess   &&tyy1 1  ^^F**""DIIF ??499dnn= =r%r)rrrrrrrr rr r rrpropertyrrrrrrrrr'rrs@r#rrs%I$''$'K%I4774(Ltwwt$H TWWT "F 224400)tI$ ! Zx >r%rctjt}|D]\}}t|\}}||||<t |j S)zgroup files per revlog prefix The returns a two level nested dict. The top level key is the revlog prefix without extension, the second level is all the file "suffix" that were seen for this revlog and arbitrary file data as value. ) collections defaultdictdict_split_revlog_extrrY) files_datarevlogsuvaluer4rs r#_gather_revlogrEsQ%%d+G5%a( c" c '--/ ""r%cl|jtrd}nd}|j|}|d|||dfS)z8split the revlog file prefix from the variable extension-roN)rREVLOG_FILES_LONG_EXTrfind)filenamecharidxs r#r@r@s@./ .. C DS>8CD> ))r%c|jdrd|fS|jdrd|fS|jdrd|fS|jdrd|fSd |fS) zJa key to order revlog suffix important to issue .i after other entry.rrr rr2(r)rs r#rrse  ||E3x f Cy e Cy e CyCyr%ceZdZdZdZdZddZddZdZ dde e ddffd Z dde e ddffd Z dde e ddffd Z d Zd ZdZdZdZy) basicstorez&base class for local repository storesc||}|j|_t||_|j|_||_t j |t|_|j|_ yr) baser0r createmoderawvfsvfsmod filtervfsr2ropenerrr0vfstypers r#rzbasicstore.__init__sRdmHH #C. ##C3hh r%c8|jdzt|zSNr)r0r2rrs r#rNzbasicstore.joinsyy4)A,..r%Nc6|j}|r|d|zz }t|jdz}g}|jj|r|g}|jj}|r|j } || dD]\} } } | dz| z} t | | | r?tj| |d}|jt|| jf[| tjk(so|sr|j| |r|j|S)z%yields (revlog_type, unencoded, size)rrT)rN)r0rFrWisdirreaddirpoprrpconvertrr4rrS_IFDIRsort)rrelpathrecurse undecodabler0striplenrJvisitrbrrrrrrzs r#_walkzbasicstore._walksyy  D7N "Dtyy>A%  ;;  T "FEkk))GIIK#*14#8KAtRTAB D"- MM"XY-8)A, !;<-' R( $9 r%cFtj|j||S)N) trypendingconcurrencychecker)rr)rrnros r#rzbasicstore.changelogs""" HH!1  r%ctj|j|j}tj|j|||Sr)rr8r9r manifestlog)rrstorenarrowmatch rootstores r#rqzbasicstore.manifestlogs:++D,>,>I ##DHHdI?OPPr%rc# Kdtdfdtdfg}|D]s\}}}|j|d|}t|D]K\}} |j ddd} |rd|vr| j ddd} | dz } t ||| | Muy w) a4Like walk, but excluding the changelog and root manifest. When [undecodable] is None, revlogs names that can't be decoded cause an exception. When it is provided, it should be a list and the filenames that can't be decoded are added to it instead. This is very rarely needed.rFrTrirrrr r rrN)r r rlrErrsplitr) rr"rirbase_dirrl_typestrip_filenamerrrrevlog_target_ids r# data_entrieszbasicstore.data_entriesslE * & - 26 -Hg~JJx;JGE#1%#8#)<<a#8#; !dfn'7'>'>tQ'G'J$$,$& & '.#  $926sB Bc#K|r*|jjdrtdd|r*|jjdrtddt|j dd}t j t}t j t}|D]e\}}|jdrt|\}} |||| <.|jdrt|\}} |||| <Vt|d| g|tf|tfg} t|d ksJt|d ksJ| D]7\} } t| jD]\} }t| | d| 9yw) NrT)rrrr%Fs 00changelogs 00manifest)rrrrrv)rexistsrreversedrlr=r>r? startswithr@r r rFrrYr)rphase obsolescencer changelogs manifestlogsrCrHr4rtop_rldatar rrs r# top_entrieszbasicstore.top_entries6s TXX__]3"(   DHHOOK8"&   C/0 ,,T2 "..t4 DAq||N+-a0 c() 4 %m,-a0 c*+ T"3'& %+ ,  ( < A%%%:!###!' D+#)$**,#7& & +!# $8"(sE=E?c#xK|j|D]}||j||D]}|yw)zreturn files related to data storage (ie: revlogs) yields instance from BaseStoreEntry subclasses if a matcher is passed, storage files of only those tracked paths are passed with matches the matcher )rrN)r|r)rr"rrr;s r#walkzbasicstore.walkhsB""7+AG,!!L!IAGJs8:ctSr_datars r#copylistzbasicstore.copylistxs r%cyrrrtrs r#writezbasicstore.write{ r%cyrrrs r#invalidatecacheszbasicstore.invalidatecaches~rr%cyrrrfns r# markremovedzbasicstore.markremovedrr%cdjd|f}|jj|dzry|jds|dz}|jj|S)!Checks if the store contains pathrrrT)rNrr~rrr0s r# __contains__zbasicstore.__contains__sSyy'4) 88??4%< (}}T"$;Dxxt$$r%rNN)FF)NFF)rrrrrrNrlrrqrrr|rrrrrrrrr%r#rSrSs0/. Q )- >4- .8).0 >4- .0f7< >4- .     %r%rScReZdZdZdfd Z d deeddfffd ZdZdZ xZ S) encodedstorec||dz}|j|_t||_|j|_||_t j |t|_|j|_ y)N/store) rUr0rrVrWrXrYrdrrZr[s r#rzencodedstore.__init__sXdY&'HH #C. ##C8hh r%Nct |||}g}|D]$\}} t|}|j||f&|S#t$r9|#t d|z} t j | |j|YjwxYw)Nsundecodable revlog name %s)rrlrgrGrr StorageErrorr) rrgrhrioldnewf1rDf2rrs r#rlzencodedstore._walksgmGW-IB #B' JJE{ #  &9:R?C,,S11&&r*  s ??BBrc#fKtt| |}|D]}t||s|yw)Nru)rrr|r$)rr"rientriesr!rs r#r|zencodedstore.data_entriess= d8#9 E#E73 s&11c8|jdzt|zSr^)r0rdr_s r#rNzencodedstore.joinsyy4."333r%cDddgtDcgc]}d|z c}zScc}w)Nrrstore/rr_s r#rzencodedstore.copylists)-.1OA)a-1OOO1Os rr) rrrrrlrrr|rNrrrs@r#rrs6")- >4- .4Pr%rcLeZdZdZd dZd dZdZdZdZdZ d Z d Z d Z y) fncachecj||_t|_d|_d|_t|_yr)rset_ignoresr_dirtyaddls)rrs r#rzfncache.__init__s)   U r%Nc@|j|j|yy)zread the fncache file if not already read. If the file on disk is corrupted, raise. If warn is provided, warn and keep going instead.N)r_load)rwarns r# ensureloadedzfncache.ensureloadeds <<  JJt  r%c d|_ |jdd}t|_d}t t j|jtdD]Y}||z } |jd}|jjt|d|dzj||dzd}[|r9td }|r ||dzn t!j"|td  |j%|||j'y#t$rt|_YywxYw#t$rYwxYw) z&fill the entries from the fncache fileFfncacherb)rNr% rs$fncache does not ends with a newlines3use 'hg debugrebuildfncache' to rebuild the fncache)hint)rrIOErrorrriter functoolspartialrfncache_chunksizerindexupdater4 splitlines ValueErrorrrr- _checkentriesr")rrrchunkrPrrs r#rz fncache._loads6  *51B u i''1BCSIA QJE LL' ##IeGa!en$=$H$H$JKa!eg J ;D?cd|jvrj|jdt|D]J\}}|jdrt d|dzz}|r ||dz7t j |yy)z-make sure there is no empty string in entriesr%rrs!invalid entry in fncache, line %drN)rr!rurrrr-)rrrrzliners r#rzfncache._checkentriessl $,,  GGAJ$R=4{{5)>?1q5IAQY#kk!n, ) r%c|jr|jJ|j|jz|_t|_|j d|j ddd}|jr6|j tdj|jdz|jd|_|jr|j d|j ddd}|jr6|j tdj|jdz|jd|_t|_yy)NrswbT)r atomictemprFsab) rrrr addbackuprrr2rNr")rrrs r#rz fncache.writes ;;<<+ ++<<$**4DLDJ LL $*5TBB||5::dll#;e#CDE HHJDK :: LL $*5TBBzz5::djj#9E#ABC HHJDLDJ r%c:|jj|yr)raddrs r# addignorezfncache.addignores "r%c||jvry|j|j||jvr|jj |yyr)rrrrrrs r#rz fncache.addsE    <<  JJL T\\ ! JJNN2  "r%c|j|j||jvr|jj|y |jj|d|_y#t $rYywxYwNT)rrrremoverrGrs r#rzfncache.remove sf <<  JJL   JJ  b !   LL   #DK   s"A++ A76A7ct||jvry|j|j||jvSr)rrrrs r#rzfncache.__contains__,s3   <<  JJLT\\!!r%c~|j|jt|j|jzSr)rrrrrs r#__iter__zfncache.__iter__3s- <<  JJLDLL4::-..r%r) rrrrrrrrrrrrrrr%r#rrs5$L -* "/r%rc&eZdZdZddZdZdZy) _fncachevfsc`tjj||||_||_yr)rXproxyvfsrrencode)rrfncrs r#rz_fncachevfs.__init__:s$  s+  r%c|j|}|dvr|jds|jdrt|r|jjduxr|j j |}|r+d|vr'|j j|jsd}|s|jj||j ||g|i|S)N)rrdata/meta/sr+F) rrrrrrr~rrr)rr0rargskwencodednotloads r#__call__z_fncachevfs.__call__?s++d#  %*dooh.Gt$ll**d2Otxxw7OG5D=w1G1O1O    &txx3333r%c|r*|jj|j|S|jj|Sr)rrNrrs r#rNz_fncachevfs.joinRs4 88==T!23 388==& &r%c|jds|jdr|jj|yy)z1generic hook point to lets fncache steer its stewrrN)rrrrs r# register_filez_fncachevfs.register_fileXs1 ??8 $(A LL  T ")Br%N)r)rrrrrrNrrr%r#rr9s 4&' #r%rc^eZdZdZdZdZ d deeddffdZdZ dZ d Z d Z d Z d Zy) fncachestorecJ|rt}nt}||_||dz}|j|_|jdz|_t ||_|j|_||_t|}||_ t||||_ |j|_ y)Nrr) rrrrUr0pathseprrVrWrrrrZ)rr0r\ryrrrs r#rzfncachestore.__init___s  F'F dY&'HH yy4' #C. cl sC0hh r%c>|j|j|zSr)rrr_s r#rNzfncachestore.joinps||dkk!n,,r%cL|jj|jSr)rWrrrs r#getsizezfncachestore.getsizess{{%---r%Nrc#Kd|jD}t|}|D]\}}|jdrt}|j ddd}nL|jdr4t }|j ddd} | j ddddz}nJ|t||||} t| |s| yw)Nc3<K|]}t|s|dfywr)r)rrs r#rz,fncachestore.data_entries..|sFLqN14E!TLs rrrrrrv) rrErr rr rwrr$) rr"rir by_revlogrrryr{tmpr!s r#r|zfncachestore.data_entriesvs GDLLF"5) (OFG  *&#)<<a#8#; ""8,*ll4+A.#&::dA#6q#9D#@ %f$u$"#* E $E73 ' )s B;C>Cc@d}ddg|Dcgc]}d|z c}zScc}w)N) rrrrsdhrrrrrrrrrrrr)rrrs r#rzfncachestore.copylists2 -.1KA)a-1KKK1Ks c:|jj|yr)rrrs r#rzfncachestore.writes 2r%cXd|j_t|j_yr)rrrrrs r#rzfncachestore.invalidatecachess#  U r%c:|jj|yr)rrrs r#rzfncachestore.markremoveds Br%ch|j|} |j|y#t$rYywxYwr)rrr)rrrs r#_existszfncachestore._existss5 [[^  LL    s % 11c djd|f}|dz}||jvr|j|ry|jds|dz }|jD]'}|j |s|j|s'yy)rrrrTF)rNrrrr)rr0rZs r#rzfncachestore.__contains__swyy'4) 5L  a}}T" DLDA||D!dll1or%r)rrrrrNrrrr|rrrrrrrr%r#rr^sN"-.)- >4- .:L$#  r%r)Rr=rrrertypingrri18nrrr thirdpartyrnoder revlogutils.constantsr r r r rrrrrrr*rrrXutilsr importmodrrr$r1r2r4r=r`rbrfrdrgrlrkrwrxr|rrrrrrrrrrrHrcompileEXCLUDEDrrrHrrrrrEr@rrSrrrrrrr%r#rsT "    &  9 % E"$ G[* 5 $$7t-. l&&2g}d3M7K7M  , -`  )*Q.@$Ng|[9 #  , 2::1 2 d%.%.%.PdAA A0d~ Ddc>~c> c>L #*"c%c%L(P:(PV{/{/|"#&//"#Jf:fr%