pߡfJddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZmZmZm Z mZdefdZGd d ZGd d eZeZGd deZGddeeZeZGddeZGddZGddeZGddZGddeZy)N)Optional)_)delattrgetattrsetattr)encodingerrorpathutilpycompatutilpathcfd}|s1tjtj|yy)zAvoid file stat ambiguity forcibly This function causes copying ``path`` file, if it is owned by another (see issue5418 and issue5584 for detail). ctjj}|j xs|j SN)r filestatfrompathisambig avoidambig)newstatoldstatrs 1usr/lib/python3.12/site-packages/mercurial/vfs.py checkandavoidz"_avoidambig..checkandavoid(s;--((.??7++Pw/A/A$/PPN)r rename mktempcopy)rrrs`` r _avoidambigr!s3Q ? DOOD)40 rc eZdZdZdZdZdAdedefdZdedefdZde eded efd Z ded efd Z dAdedefd Z e jd Zded efdZdAdedefdZ dBdeded efdZ dCdededed dfdZdeded efdZded efdZdeded dfdZded efdZdDde ed efdZdZdDde ed efdZdDde ed efdZdDde ed efdZdDde ed efdZded efdZ ded efd Z!defd!Z"dDde ed efd"Z#dDde efd#Z$dDde efd$Z%dEde efd%Z& dFde ede efd&Z'defd'Z(dDde efd(Z) dGd)ed*ed+e efd,Z*dHde efd-Z+ded efd.Z,dBd/ed0efd1Z-ded efd2Z.dDde efd3Z/dDde efd4Z0 dIde efd5Z1ded6ed7efd8Z2dDde efd9Z3dDde efd:Z4dDde efd;Z5 dJde efd<Z6dFde efd=Z7dFde efd>Z8e9jtdKd?Z;d@Z>$T>2 2     s  ""c|jS)zOpen ``path`` file, which is relative to vfs root. Newly created directories are marked as "not to be indexed by the content indexing service", if ``notindexed`` is specified for "write" mode access. )r.r's ropenzabstractvfs.open]s}}rc`||d5}|jcdddS#1swYyxYw)Nrb)r9)r'rfps rr9zabstractvfs.readgs# $ "779  s$-cb|||5}|jcdddS#1swYyxYw)Nr>)r?)r'rr+rFs rr?zabstractvfs.readlinesks# $T "b<<># " "s%.datac h||dfd|i|5}|j|cdddS#1swYyxYw)Nwbbackgroundclosewrite)r'rrHrKr)rFs rrMzabstractvfs.writeos2$ I I& IR88D>J I Is(1Ncf||||5}|j|cdddS#1swYyxYw)N)r+ notindexed) writelines)r'rrHr+rOrFs rrPzabstractvfs.writelinesus*$Tj 9R==&: 9 9s'0cb||d5}|j|cdddS#1swYyxYw)NsabrL)r'rrHrFs rappendzabstractvfs.append{s% $ "88D>  s%.c@tjj|S)zreturn base element of a path (as os.path.basename would do) This exists to allow handling of strange encoding if needed.)osrbasenamer;s rrUzabstractvfs.basenamesww%%rcLtj|j||Sr)rTchmodr7r1s rrWzabstractvfs.chmodsxx $..rc@tjj|S)zreturn dirname element of a path (as os.path.dirname would do) This exists to allow handling of strange encoding if needed.)rTrdirnamer;s rrYzabstractvfs.dirnameswwt$$rc^tjj|j|Sr)rTrexistsr7r;s rr[zabstractvfs.existsww~~diio..rc,tj|Sr)r fstat)r'rFs rr^zabstractvfs.fstatszz"~rc^tjj|j|Sr)rTrisdirr7r;s rr`zabstractvfs.isdirsww}}TYYt_--rc^tjj|j|Sr)rTrisfiler7r;s rrbzabstractvfs.isfiler\rc^tjj|j|Sr)rTrislinkr7r;s rrdzabstractvfs.islinkr\rc |j|}|j}tj|xstj |S#t$rYywxYw)zhreturn whether path is a regular file or a symlink Unlike isfile, this doesn't follow symlinks.F)lstatOSErrorst_modestatS_ISREGS_ISLNK)r'rstr+s r isfileorlinkzabstractvfs.isfileorlinksQ D!Bzz||D!7T\\$%77  sA AApathscd}t|D]B\}}tjj|s|j |j sA|}D|dk7r||d}|Dcgc]}|s| }}|j j |Scc}wNr) enumeraterTrisabs startswith_dir_sepr7)r'rnroot_idxidxps r_joinzabstractvfs._joins&FCww}}Q1<< #>' q=()$E!'EqQE'}}!!%(((s !B )B c |j|S)zjoin various elements of a path together (as os.path.join would do) The vfs base is not injected so that path stay relative. This exists to allow handling of strange encoding if needed.)rx)r'rns rreljoinzabstractvfs.reljoins tzz5!!rc@tjj|S)zsplit top-most element of a path (as os.path.split would do) This exists to allow handling of strange encoding if needed.)rTrsplitr;s rr|zabstractvfs.splitsww}}T""rc^tjj|j|Sr)rTrlexistsr7r;s rr~zabstractvfs.lexistsswwtyy//rcJtj|j|Sr)rTrfr7r;s rrfzabstractvfs.lstatxx $((rcJtj|j|Sr)rTlistdirr7r;s rrzabstractvfs.listdirszz$))D/**rcLtj|j||Sr)r makedirr7)r'rrOs rrzabstractvfs.makedirs||DIIdOZ88rcLtj|j||Sr)r makedirsr7r1s rrzabstractvfs.makedirss}}TYYt_d33rcLtj||j|Sr)r makelockr7)r'infors rrzabstractvfs.makelocks}}T499T?33rcJtj|j|Sr)rTmkdirr7r;s rrzabstractvfs.mkdirrrsuffixprefixdirctj|||j|\}}tj|\}}|r"|t j j||fS||fS)N)rrr)r mkstempr7r r|rTr)r'rrrfdnamednamefnames rrzabstractvfs.mkstempsb ##&diin Dzz$' u rww||C// /u9 rcNtj|j|||Sr)r rr7)r'rriskips rreaddirzabstractvfs.readdirs||DIIdOT488rcJtj|j|Sr)r readlockr7r;s rrzabstractvfs.readlock}}TYYt_--rsrcdstc@|j|d|j|}|j|}|xrtjj |}|r0|j r$tj ||}t|||Stj ||S)aRename from src to dst checkambig argument is used with util.filestat, and is useful only if destination file is guarded by any lock (e.g. repo.lock or repo.wlock). To avoid file stat ambiguity forcibly, checkambig=True involves copying ``src`` file, if it is owned by another. Therefore, use checkambig=True only in limited cases (see also issue5418 and issue5584 for detail). w)r2r7r rrrirr)r'rr checkambigsrcpathdstpathrrets rrzabstractvfs.renames~ T"))C.))C.@!7!7!@ w||++gw/C  )J{{7G,,rcJtj|j|Sr)r readlinkr7r;s rrzabstractvfs.readlinkrrcJtj|j|S)z7Remove a leaf directory and all empty intermediate ones)r removedirsr7r;s rrzabstractvfs.removedirsstyy//rcJtj|j|S)zRemove an empty directory.)rTrmdirr7r;s rrzabstractvfs.rmdirsxx $((rc`|rd}nd}tj|j|||S)zqRemove a directory tree recursively If ``forcibly``, this tries to remove READ-ONLY files, too. cH|tjurtj|}|jtjzdk7rtj |tj |jtjztj|yrp)rTremoverirhS_IWRITErWS_IMODE)functionrexcinfoss ronerrorz#abstractvfs.rmtree..onerrorse299,GGDMII -!3t||AII6FG $rN) ignore_errorsr)shutilrmtreer7)r'rrforciblyrs rrzabstractvfs.rmtree s3  G}} IIdO='  rlxcNtj|j|||Sr)r setflagsr7)r'rrrs rrzabstractvfs.setflags%s}}TYYt_a33rcJtj|j|Sr)rTrir7r;s rrizabstractvfs.stat(swwtyy''rcJtj|j|Sr)r unlinkr7r;s rrzabstractvfs.unlink+s{{499T?++rcLtj|j|y)z7Attempt to remove a file, ignoring missing file errors.N)r tryunlinkr7r;s rrzabstractvfs.tryunlink.s tyy'rcPtj|j|||S)N) ignoremissingr)r unlinkpathr7)r'rrrs rrzabstractvfs.unlinkpath2s$ IIdO=  rcLtj|j||Sr)rTutimer7)r'rts rrzabstractvfs.utime9sxx $++rc#Ktjj|jd}t t j |}tj|j||D]\}}}||d||fyw)a/Yield (dirpath, dirs, files) tuple for each directories under path ``dirpath`` is relative one from the root of this vfs. This uses ``os.sep`` as path separator, even you specify POSIX style ``path``. "The root of this vfs" is represented as empty ``dirpath``. N)r)rTrnormpathr7lenr normasprefixwalk)r'rrroot prefixlendirpathdirsfiless rrzabstractvfs.walk<stww $0--d34 $&GGDIIdOW$M GT59:&e4 4%NsBB c#bKttjtjsdyt |d|}t |ddrt j tdt||5} ||_ |d|_ dddy#d|_ wxYw#1swYyxYww)zAllow files to be closed asynchronously. When this context manager is active, ``backgroundclose`` can be passed to ``__call__``/``open`` to result in the file possibly being closed asynchronously, on a background thread. Nvfs_backgroundfileclosers-can only have 1 active background file closer) expectedcount) isinstance threadingcurrent_thread _MainThreadrr Abortrbackgroundfilecloserr)r'uirrbfcs rbackgroundclosingzabstractvfs.backgroundclosingLs  $ $ &  ! !   dE4( 3/ 6++BC ""M Bc ) )C B)C Bs6A7B/9B#; BB# B/ B  B##B,(B/cy)z1generic hook point to lets fncache steer its stewNr;s r register_filezabstractvfs.register_filensrrE)F)rJFrNT)NN)rstmpN)NNN)NFF)NFT)=__name__ __module__ __qualname____doc__rtr*bytesr.r2rr7r<r@r propertycacherCr9r?intrMrPrRrUrWrYboolr[r^r`rbrdrmrxrzr|r~rfrrrrrrrrrrrrrrrirrrrr contextlibcontextmanagerrrrrrrr4s5HP "U"%""u"E""%"E"e"Eee 5"e"5" 9>""!&" "IN''!&'.3' ' "5""#"&U&u& /%/s/t/%E%e% /8E?/d/.(5/.T./8E?/d//8E?/d/ 8% 8D 8)E)e)"e""#%# 0HUO0t0)(5/)+HUO+9HUO9CG4UO42:3-4 454)(5/) #   e_ 9HUO9.U.u.-%-e-,.U.u.0x0)(5/) KP UO 24U4t44(%(,8E?,(huo( HL UO ,(5/,5%5 B@rrceZdZdZ ddefdZejdefdZ ejdZ dZ dd Z dd e edefd Z dd ed efd ZdededdfdZd e ededefdZy)rakOperate files relative to a base directory This class is used to hide the details of COW semantics and remote file access from higher level code. 'cacheaudited' should be enabled only if (a) vfs object is short-lived, or (b) the base directory is managed by hg and considered sort-of append-only. See pathutil.pathauditor() for details. basec|rtj|}|rtjj |}||_||_|r'tj|j ||_ n dd|_ d|_ d|_ i|_ y)N)cachedcyrr)rr+s rzvfs.__init__..srr) r expandpathrTrrealpathr_auditr pathauditoraudit createmode _trustnlinkoptions)r'rr cacheauditedrrs rr*z vfs.__init__}sr ??4(D 77##D)D  !--dii MDJ5DJ rr4c@tj|jSr)r checklinkrrBs r _cansymlinkzvfs._cansymlink~~dii((rc@tj|jSr)r checkexecrrBs r_chmodz vfs._chmodrrc||j |jsytj||jdzy)Ni)rrrTrW)r'rs r _fixfilemodezvfs._fixfilemodes, ?? "$++  t./rNcn|jrtjj|rE|j |j r*tjj ||j }tj|}|rtjd||fz|j||yy)Ns%s: %rr>) rrTrrrrsrrelpathr checkosfilenamer rr)r'rr+rs rr2zvfs._auditpaths ;;ww}}T"ttyy'AwwtTYY7$$T*Akk)q$i"788 JJt$J ' rrc< tjtj|D]@}||vr||}n0tjj |j ||}|||<|r@y |j|S#ttjf$rYywxYw)a8return True if the path is a regular file or a symlink and the directories along the path are "normal", that is not symlinks or nested hg repositories. Ignores the `_audit` setting, and checks the directories regardless. `dircache` is used to cache the directory checks. F) r finddirs_rev_norootr localpathr_checkfs_existsrrgr rrm)r'dircacherrress risfileorlink_checkdirzvfs.isfileorlink_checkdirs "66t~~d7KLX%"6*C"..>> 64C(+HV$ M  &&%  sA'A?*A?,A??BBr+c |r|j|||j|} d|vr|dz }d} |dvr&tj| \} } | r |rF|r!tj| |j |tj | ||j |S d|vrtj| d} n:tj| 5tj| } | dkrd} d d d | dkDrg|j!| dkDxstj| |_ | dkDs |js)tjtj| | tj| |} | dk(r|j| |r0|dvr!t!j"t%d |zt'| } |rlt)t+j,t*j.r@|j0st!j"t%d t3| |j0} | S#1swYDxYw#t$r)d} |r!tj| |j |YxwxYw) aOpen ``path`` file, which is relative to vfs root. By default, parent directories are created as needed. Newly created directories are marked as "not to be indexed by the content indexing service", if ``notindexed`` is specified for "write" mode access. Set ``makeparentdirs=False`` to not create directories implicitly. If ``backgroundclose`` is passed, the file may be closed asynchronously. It can only be used if the ``self.backgroundclosing()`` context manager is active. This should only be specified if the following criteria hold: 1. There is a potential for writing thousands of files. Unless you are writing thousands of files, the performance benefits of asynchronously closing files is not realized. 2. Files are opened exactly once for the ``backgroundclosing`` active duration and are therefore free of race conditions between closing a file on a background thread and reopening it. (If the file were opened multiple times, there could be unflushed data because the original file handle hasn't been flushed/closed yet.) ``checkambig`` argument is passed to atomictempfile (valid only for writing), and is useful only if target file is guarded by any lock (e.g. repo.lock or repo.wlock). To avoid file stat ambiguity forcibly, checkambig=True involves copying ``path`` file opened in "append" mode (e.g. for truncation), if it is owned by another. Therefore, use combination of append mode and checkambig=True only in limited cases (see also issue5418 and issue5584 for detail). brrrE)rrrrNs>implementation error: mode %s is not valid for checkambig=TruesSbackgroundclose can only be used when a backgroundclosing context manager is active)r2r7r r|rratomictempfiler posixfilenlinksr:r checknlinkrrrr rrcheckambigatclosingrrrrrdelayclosedfile)r'rr+ atomictemprOrKr auditpathmakeparentdirsfnlinkrYrUrFs rr.z vfs.__call__s5R  OOD$ ' IIdO t  DLD } $ $ 1 GX% gt K..4ZLt| A !"^^A.$(KKNE$qy()/19''/+019+J8J(qy(8(8 DOOA$6: ^^At $ A:   a }$kk6 %R(B z  $ $ &  ! ! ..kkG!**B  _/.)LE% gt KLs*1H7 H*(H7*H4/H77.I)(I)rrc |j||j|}tj|tjt j j||j|jr t j||y|j#||y#t$rG}t|jtd|tj|j fz|d}~wwxYw)Nscould not symlink to %r: %s)rr7r rrrTrrYrrsymlinkrgerrnorr strtolocalstrerrorrM)r'rrlinknameerrs rr!z vfs.symlink6s 399S> x  bggooh/A     3) JJsC  II45H// =>?  sB,, C<5AC77C<r3cz|r.|j|g}|j||j|S|jSr)rextendrx)r'rr3partss rr7zvfs.joinJs: YY%E LL !4::u% %99 r)TFFF)r4Nr)rEFFFFTT)rrrrrr*r rrrrrr2rrr.r!r7rrrrrrs , )T)) ))0 (15'&uo' '8rrrh!5!u!!(%Eerrc^eZdZddZedZdZedZejdZy)proxyvfsc||_yr)rr'rs rr*zproxyvfs.__init__Ws rc.|jjSr)rrrBs rrzproxyvfs.createmodeZsxx"""rc:|jj||Sr)rr2r1s rr2zproxyvfs._auditpath^sxx""4..rc.|jjSrrrrBs rrzproxyvfs.optionsasxxrc&||j_yrr1)r'values rrzproxyvfs.optionses rNrr) rrrr*propertyrr2rsetterrrrr+r+VsL##/   ^^!!rr+c>eZdZdZd dZdefdZdeededefdZy) filtervfsz4Wrapper vfs for filtering filenames with a function.c>tj||||_yr)r+r*_filter)r'rfilters rr*zfiltervfs.__init__ms$$ rrcL|j|j|g|i|Sr)rr:)r'rr(r)s rr.zfiltervfs.__call__qs&txx T*dhh.>.>t.Ng.N!OP P88==& &rNr4 rrrrr*rr.rr7rrrr8r8js4>=U='%'E'e'rr8cDeZdZdZd dZd dedefdZdeededefdZy ) readonlyvfsz#Wrapper vfs preventing any writing.c0tj||yr)r+r*r-s rr*zreadonlyvfs.__init__s$$rrr+ct|dvrtjtd|j||g|i|S)Nrsthis vfs is read only)r rrr)r'rr+r(kws rr.zreadonlyvfs.__call__s< } $++a 89: :txxd0T0R00rr3r4c<|jj|g|Sr)rr7r6s rr7zreadonlyvfs.joinstxx}}T,G,,rNr4rr>rrrr@r@~s;-%1U1%1 -%-E-e-rr@c:eZdZdZdZdZdZdZdZdZ dZ y ) closewrapbasezaBase class of wrapper, which hooks closing Do not instantiate outside of the vfs layer. c2tj|d|y)N_origfh)object __setattr__)r'fhs rr*zclosewrapbase.__init__s4B/rc.t|j|Sr)rrHr'attrs r __getattr__zclosewrapbase.__getattr__t||T**rc0t|j||Sr)rrH)r'rNr3s rrJzclosewrapbase.__setattr__st||T511rc.t|j|Sr)rrHrMs r __delattr__zclosewrapbase.__delattr__rPrc:|jj|Sr)rH __enter__rBs rrUzclosewrapbase.__enter__s   rcBtdtt|zNr"r#r'exc_type exc_valueexc_tbs r__exit__zclosewrapbase.__exit__!">'' }}% s1A2 A AAA  A)A=<A=c|jstjtd|jr|j}d|_||j s|j y|jj|ddy)zSchedule a file for closing.s1can only call close() when context manager activeNTr) rrr rrrtrqr_r{putrs rr_zbackgroundfilecloser.closesq}}++FG   %%A$(D !G}} HHJ  $5rNr) rrrrr*rUr\r~r_rrrrrsM$L 6rrc4eZdZdZfdZdZdZdZxZS)ra"Proxy for a file object, to avoid ambiguity of file stat See also util.filestat for detail about "ambiguity of file stat". This proxy is useful only if the target file is guarded by any lock (e.g. repo.lock or repo.wlock) Do not instantiate outside of the vfs layer. ctt| |tj |dt j j|jy)N_oldstat) rcrr*rIrJr rrr)r'rKres rr*zcheckambigatclosing.__init__"s8 !41"54T]]-C-CBGG-LMrcv|j}|jr!t|jj|yyr)rrirrHr)r'rs r _checkambigzcheckambigatclosing._checkambig&s+-- <<  ))7 3 rc^|jj||||jyr)rHr\rrXs rr\zcheckambigatclosing.__exit__+s$ h 6: rcX|jj|jyr)rHr_rrBs rr_zcheckambigatclosing.close/s  r) rrrrr*rr\r_rjrks@rrrsN4 rr)rrTrrirtypingri18nrr rrrr r r r rrrropenerr+r8 filteropenerr@rFrrrrrrrs  e&{@{@| ^+^B !{!('+'"  -( -PP:)m)"Y6Y6x-r