a &0É_‹`ã@sddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z ddlmZmZmZm Z mZdd„ZGd d „d eƒZGd d „d eƒZeZGd d„deƒZGdd„deeƒZeZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZdS)é)Úabsolute_importNé)Ú_)ÚdelattrÚgetattrÚsetattr)ÚencodingÚerrorÚpathutilÚpycompatÚutilcs0‡‡fdd„}|ƒs,t t ˆ¡ˆ¡|ƒdS)z Avoid file stat ambiguity forcibly This function causes copying ``path`` file, if it is owned by another (see issue5418 and issue5584 for detail). cs$tj ˆ¡}| ˆ¡ p"| ˆˆ¡S©N)r ÚfilestatÚfrompathZisambigZ avoidambig)Znewstat©ÚoldstatÚpath©ú//usr/lib/python3/dist-packages/mercurial/vfs.pyÚ checkandavoid&s z"_avoidambig..checkandavoidN)r ÚrenameÚ mktempcopy)rrrrrrÚ _avoidambigsrc@sÆeZdZdZdd„Zdfdd„Zdd„Zd d „Zd d „Zdgd d„Z e j dd„ƒZ dd„Z dhdd„Zdidd„Zdjdd„Zdd„Zdd„Zdd „Zd!d"„Zdkd$d%„Zd&d'„Zdld(d)„Zdmd*d+„Zdnd,d-„Zdod.d/„Zd0d1„Zd2d3„Zdpd4d5„Zdqd6d7„Zdrd8d9„Zdsd;d<„Z dtd=d>„Z!d?d@„Z"dudAdB„Z#dvdEdF„Z$dwdGdH„Z%dIdJ„Z&dxdKdL„Z'dMdN„Z(dydOdP„Z)dzdQdR„Z*d{dSdT„Z+dUdV„Z,d|dWdX„Z-d}dYdZ„Z.d~d[d\„Z/dd]d^„Z0d€d_d`„Z1ddadb„Z2e3j4d‚ddde„ƒZ5d#S)ƒÚ abstractvfsz+Abstract base class; cannot be instantiatedcOstdtt|ƒƒƒ‚dS)z7Prevent instantiation; don't call this from subclasses.úattempted instantiating N©ÚNotImplementedErrorÚstrÚtype)ÚselfÚargsÚkwargsrrrÚ__init__5szabstractvfs.__init__órbcKst‚dSr ©r)rrÚmoder!rrrÚ__call__9szabstractvfs.__call__cCst‚dSr r$©rrr%rrrÚ _auditpath<szabstractvfs._auditpathcGst‚dSr r$©rrZinsidefrrrÚjoin?szabstractvfs.joinc CsDz | |¡WSty>}z|jtjkr*‚WYd}~n d}~00dS)z3gracefully return an empty string for missing filesNó)ÚreadÚIOErrorÚerrnoÚENOENT)rrÚinstrrrÚtryreadBs   zabstractvfs.tryreadc CsHz|j||dWStyB}z|jtjkr.‚WYd}~n d}~00gS)z2gracefully return an empty array for missing files©r%N)Ú readlinesr-r.r/)rrr%r0rrrÚ tryreadlinesKs  zabstractvfs.tryreadlinescCs|jS)zéOpen ``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&©rrrrÚopenTszabstractvfs.opencCs6||dƒ}| ¡WdƒS1s(0YdS)Nr#)r,)rrÚfprrrr,^s zabstractvfs.readcCs8|||d}| ¡WdƒS1s*0YdS)Nr2)r3)rrr%r7rrrr3bszabstractvfs.readlinesFcKsD||dfd|i|¤Ž}| |¡WdƒS1s60YdS)NówbÚbackgroundclose©Úwrite)rrÚdatar9r!r7rrrr;fszabstractvfs.writer8cCs<||||d}| |¡WdƒS1s.0YdS)N)r%Ú notindexed)Ú writelines)rrr<r%r=r7rrrr>jszabstractvfs.writelinescCs8||dƒ}| |¡WdƒS1s*0YdS)Nsabr:)rrr<r7rrrÚappendns zabstractvfs.appendcCs tj |¡S)z‚return base element of a path (as os.path.basename would do) This exists to allow handling of strange encoding if needed.)ÚosrÚbasename©rrrrrrArszabstractvfs.basenamecCst | |¡|¡Sr )r@Úchmodr*r'rrrrCxszabstractvfs.chmodcCs tj |¡S)z„return dirname element of a path (as os.path.dirname would do) This exists to allow handling of strange encoding if needed.)r@rÚdirnamerBrrrrD{szabstractvfs.dirnameNcCstj | |¡¡Sr )r@rÚexistsr*rBrrrrEszabstractvfs.existscCs t |¡Sr )r Úfstat)rr7rrrrF„szabstractvfs.fstatcCstj | |¡¡Sr )r@rÚisdirr*rBrrrrG‡szabstractvfs.isdircCstj | |¡¡Sr )r@rÚisfiler*rBrrrrHŠszabstractvfs.isfilecCstj | |¡¡Sr )r@rÚislinkr*rBrrrrIszabstractvfs.islinkcCs>z| |¡}Wnty"YdS0|j}t |¡p|tj ||¡fS||fSdS)N)ÚsuffixÚprefixÚdir)r Úmkstempr*r rTr@r)rr]r^r_ÚfdÚnameZdnameÚfnamerrrr`½s ÿ zabstractvfs.mkstempcCst | |¡||¡Sr )r rVr*)rrrMÚskiprrrÚreaddirÇszabstractvfs.readdircCst | |¡¡Sr )r Úreadlockr*rBrrrrfÊszabstractvfs.readlockcCs`| |d¡| |¡}| |¡}|o.tj |¡}|rT|jrTt ||¡}t||ƒ|St ||¡S)a¼Rename 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)r(r*r rrrMrr)rÚsrcÚdstÚ checkambigZsrcpathZdstpathrZretrrrrÍs      zabstractvfs.renamecCst | |¡¡Sr )r Úreadlinkr*rBrrrrkãszabstractvfs.readlinkcCst | |¡¡S)z@Remove a leaf directory and all empty intermediate ones )r Ú removedirsr*rBrrrrlæszabstractvfs.removedirscCst | |¡¡S)zRemove an empty directory.)r@Úrmdirr*rBrrrrmëszabstractvfs.rmdircCs(|rdd„}nd}tj| |¡||dS)zqRemove a directory tree recursively If ``forcibly``, this tries to remove READ-ONLY files, too. cSsP|tjur ‚t |¡}|jtj@dkr(‚t |t |j¡tjB¡t |¡dS)Nr)r@ÚremoverMrLÚS_IWRITErCÚS_IMODE)ZfunctionrÚexcinfoÚsrrrÚonerrorös  z#abstractvfs.rmtree..onerrorN)Ú ignore_errorsrs)ÚshutilÚrmtreer*)rrrtZforciblyrsrrrrvïs   ÿzabstractvfs.rmtreecCst | |¡||¡Sr )r Úsetflagsr*)rrÚlÚxrrrrwszabstractvfs.setflagscCst | |¡¡Sr )r@rMr*rBrrrrM szabstractvfs.statcCst | |¡¡Sr )r Úunlinkr*rBrrrrz szabstractvfs.unlinkcCst | |¡¡dS)z7Attempt to remove a file, ignoring missing file errors.N)r Ú tryunlinkr*rBrrrr{szabstractvfs.tryunlinkcCstj| |¡||dS)N)Ú ignoremissingrm)r Ú unlinkpathr*)rrr|rmrrrr}s ÿzabstractvfs.unlinkpathcCst | |¡|¡Sr )r@Úutimer*)rrÚtrrrr~szabstractvfs.utimeccsXtj | d¡¡}tt |¡ƒ}tj| |¡|dD]\}}}||d…||fVq4dS)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)rs)r@rÚnormpathr*Úlenr Z normasprefixÚwalk)rrrsÚrootZ prefixlenÚdirpathÚdirsÚfilesrrrr‚s zabstractvfs.walkéÿÿÿÿc cstt ¡tjƒsdVdSt|d|ƒ}t|ddƒr@t tdƒ¡‚t||d0}z||_ |VWd|_ nd|_ 0Wdƒn1s‚0YdS)zþAllow 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. NÚvfsÚ_backgroundfileclosers-can only have 1 active background file closer)Ú expectedcount) Ú isinstanceÚ threadingÚ currentThreadÚ _MainThreadrr ÚAbortrÚbackgroundfilecloserr‰)rÚuirŠrˆZbfcrrrÚbackgroundclosing+s( þ  ÿÿÿÿzabstractvfs.backgroundclosing)r#)r#)r#)F)r8F)N)N)N)N)N)N)N)N)NT)NN)N)r+r\N)NNN)F)N)N)NFF)N)N)N)NFT)NN)NN)r‡)6Ú__name__Ú __module__Ú __qualname__Ú__doc__r"r&r(r*r1r4r Ú propertycacher6r,r3r;r>r?rArCrDrErFrGrHrIrQrSrTrUrJrVrWrXrYr[r`rerfrrkrlrmrvrwrMrzr{r}r~r‚Ú contextlibÚcontextmanagerr’rrrrr2sb                            rc@s`eZdZdZddd„Zejdd„ƒZejdd „ƒZd d „Z d d „Z ddd„Z dd„Z dd„Z dS)rˆakOperate 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. TFcCsd|rt |¡}|rtj |¡}||_||_|rBtj|j|d|_ n ddd„|_ d|_ d|_ i|_ dS)N)ÚcachedcSsdS©NTr)rr%rrrÚjr+zvfs.__init__..)N) r Ú expandpathr@rÚrealpathÚbaseÚ_auditr Z pathauditorÚauditÚ createmodeÚ _trustnlinkÚoptions)rrŸr¡Z cacheauditedrržrrrr"Ys   z vfs.__init__cCs t |j¡Sr )r Z checklinkrŸr5rrrÚ _cansymlinkoszvfs._cansymlinkcCs t |j¡Sr )r Z checkexecrŸr5rrrÚ_chmodssz vfs._chmodcCs*|jdus|jsdSt ||jd@¡dS)Ni¶)r¢r¦r@rC)rrbrrrÚ _fixfilemodewszvfs._fixfilemodecCs`|jr\tj |¡r.| |j¡r.tj ||j¡}t |¡}|rNt   d||f¡‚|j ||ddS)Ns%s: %rr2) r r@rÚisabsÚ startswithrŸÚrelpathr Zcheckosfilenamer rr¡)rrr%Úrrrrr(|s zvfs._auditpathórc  Cs|r| ||¡| |¡} d|vr*|d7}d} |dvrxt | ¡\} } | rx|rx|rdt | |j|¡tj| ||j|dSz\d|vr’t | ¡d} n@t | ¡&t  | ¡} | dkr´d} Wd ƒn1sÈ0YWnRt t fy&} z4| j t j krø‚d} |rt | |j|¡WYd } ~ n d } ~ 00| dkrx|jd urT| dkpPt | ¡|_| dksf|jsxt t | ¡| ¡t | |¡}| dkr˜| | ¡|rÂ|dvrºt td ƒ|¡‚t|ƒ}|rütt ¡tjƒrü|jsðt td ƒ¡‚t||jƒ}|S) a«Open ``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). óbr‡©r¬r#)rjrgrréNs>implementation error: mode %s is not valid for checkambig=TruesSbackgroundclose can only be used when a backgroundclosing context manager is active)r(r*r rTrXr¢ZatomictempfilerzZ posixfileZnlinksrKr-r.r/r£Z checknlinkrrr§r rrÚcheckambigatclosingr‹rŒrrŽr‰Údelayclosedfile)rrr%Z atomictempr=r9rjZ auditpathZmakeparentdirsÚfZnlinkrDrAÚer7rrrr&…s~)    ÿ   & &      ÿüÿþÿÿÿþz vfs.__call__c Cs¤| |¡| |¡}t |¡t tj |¡|j¡|j r”zt  ||¡Wq t y}z.t |j t dƒ|t |j¡f|ƒ‚WYd}~q d}~00n | ||¡dS)Nscould not symlink to %r: %s)r¡r*r r{rXr@rrDr¢r¥ÚsymlinkrKr.rrZ strtolocalÚstrerrorr;)rrhriZlinknameÚerrrrrr´ûs    ÿüz vfs.symlinkcGs&|rtjj|j|g|¢RŽS|jSdSr )r@rr*rŸr)rrrr*szvfs.joinN)TFFF)r¬FFFFTT)r“r”r•r–r"r r—r¥r¦r§r(r&r´r*rrrrrˆNs, ú    ÷ vrˆc@s6eZdZdd„Zdd„Zedd„ƒZejdd„ƒZdS) ÚproxyvfscCs ||_dSr )rˆ©rrˆrrrr"szproxyvfs.__init__cCs|j ||¡Sr )rˆr(r'rrrr(szproxyvfs._auditpathcCs|jjSr ©rˆr¤r5rrrr¤ szproxyvfs.optionscCs ||j_dSr r¹)rÚvaluerrrr¤$sN)r“r”r•r"r(Úpropertyr¤Úsetterrrrrr·s  r·c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú filtervfsz4Wrapper vfs for filtering filenames with a function.cCst ||¡||_dSr )r·r"Ú_filter)rrˆÚfilterrrrr",s zfiltervfs.__init__cOs|j| |¡g|¢Ri|¤ŽSr )rˆr¾)rrr r!rrrr&0szfiltervfs.__call__cGs6|r&|j | |jj|g|¢RŽ¡¡S|j |¡SdSr )rˆr*r¾rSr)rrrr*3s"zfiltervfs.joinN©r“r”r•r–r"r&r*rrrrr½)sr½c@s*eZdZdZdd„Zd dd„Zdd„Zd S) Ú readonlyvfsz#Wrapper vfs preventing any writing.cCst ||¡dSr )r·r"r¸rrrr"@szreadonlyvfs.__init__r¬cOs0|dvrt tdƒ¡‚|j||g|¢Ri|¤ŽS)Nr®sthis vfs is read only)r rrrˆ)rrr%r Úkwrrrr&Cszreadonlyvfs.__call__cGs|jj|g|¢RŽSr )rˆr*r)rrrr*Hszreadonlyvfs.joinN)r¬rÀrrrrrÁ=s rÁc@sHeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dS)Ú closewrapbasezaBase class of wrapper, which hooks closing Do not instantiate outside of the vfs layer. cCst |d|¡dS)NÚ_origfh)ÚobjectÚ __setattr__©rÚfhrrrr"Rszclosewrapbase.__init__cCs t|j|ƒSr )rrÄ©rÚattrrrrÚ __getattr__Uszclosewrapbase.__getattr__cCst|j||ƒSr )rrÄ)rrÊrºrrrrÆXszclosewrapbase.__setattr__cCs t|j|ƒSr )rrÄrÉrrrÚ __delattr__[szclosewrapbase.__delattr__cCs|j ¡|Sr )rÄÚ __enter__r5rrrrÍ^s zclosewrapbase.__enter__cCstdtt|ƒƒƒ‚dS©Nrr©rÚexc_typeÚ exc_valueÚexc_tbrrrÚ__exit__bszclosewrapbase.__exit__cCstdtt|ƒƒƒ‚dSrÎrr5rrrÚcloseeszclosewrapbase.closeN) r“r”r•r–r"rËrÆrÌrÍrÓrÔrrrrrÃLsrÃcs0eZdZdZ‡fdd„Zdd„Zdd„Z‡ZS)r±zfProxy for a file object whose close is delayed. Do not instantiate outside of the vfs layer. cs"tt|ƒ |¡t |d|¡dS)NÚ_closer)Úsuperr±r"rÅrÆ)rrÈZcloser©Ú __class__rrr"oszdelayclosedfile.__init__cCs|j |j¡dSr ©rÕrÔrÄrÏrrrrÓsszdelayclosedfile.__exit__cCs|j |j¡dSr rÙr5rrrrÔvszdelayclosedfile.close)r“r”r•r–r"rÓrÔÚ __classcell__rrr×rr±is r±c@s:eZdZdZddd„Zdd„Zdd„Zd d „Zd d „Zd S)rzCCoordinates background closing of file handles on multiple threads.r‡c CsÆd|_d|_g|_d|_tj}| dd|¡}|s4dS| dd¡}|dkrT||krTdS| dd¡}| dd¡}| d|¡tj j |d |_ d |_t |ƒD](}t j|jd d } |j | ¡|  ¡q˜dS) NFsworkersbackgroundclosesbackgroundcloseminfilecountrsbackgroundclosemaxqueuesbackgroundclosethreadcounts0starting %d threads for background file closing )ÚmaxsizeTZbackgroundcloser)Útargetrb)Ú_runningÚ_enteredÚ_threadsÚ_threadexceptionr Z iswindowsZ configboolZ configintÚdebugÚqueueZQueueÚ_queueÚrangerŒZThreadÚ_workerr?Ústart) rr‘rŠZdefaultenabledZenabledZ minfilecountZmaxqueueZ threadcountÚirrrrr"}s,   ÿ  zbackgroundfilecloser.__init__cCs d|_|Sr›)rÞr5rrrrÍ£szbackgroundfilecloser.__enter__cCsd|_|jD] }| ¡q dS)NF)rÝrßr*)rrÐrÑrÒrrrrrÓ§s zbackgroundfilecloser.__exit__c CstzL|jjddd}z | ¡Wn*tyH}z||_WYd}~n d}~00Wqtjjyl|jshYqpYq0qdS)zMain routine for worker thread.Tgš™™™™™¹?©ÚblockZtimeoutN) rãÚgetrÔÚ Exceptionràr râZEmptyrÝ©rrÈr³rrrrå¯s  zbackgroundfilecloser._workercCsR|jst tdƒ¡‚|jr*|j}d|_|‚|js<| ¡dS|jj|ddddS)zSchedule a file for closing.s1can only call close() when context manager activeNTrè) rÞr rrràrÝrÔrãZputrìrrrrÔ¿sÿzbackgroundfilecloser.closeN)r‡) r“r”r•r–r"rÍrÓrårÔrrrrrzs  &rcs8eZdZdZ‡fdd„Zdd„Zdd„Zdd „Z‡ZS) r°a"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. cs,tt|ƒ |¡t |dtj |j¡¡dS)NÚ_oldstat) rÖr°r"rÅrÆr rrrbrÇr×rrr"ászcheckambigatclosing.__init__cCs|j}|jrt|jj|ƒdSr )rírMrrÄrb)rrrrrÚ _checkambigåszcheckambigatclosing._checkambigcCs|j |||¡| ¡dSr )rÄrÓrîrÏrrrrÓêszcheckambigatclosing.__exit__cCs|j ¡| ¡dSr )rÄrÔrîr5rrrrÔîs zcheckambigatclosing.close) r“r”r•r–r"rîrÓrÔrÚrrr×rr°Ös  r°) Z __future__rr˜r.r@rurMrŒZi18nrr rrrÚrr r r rrÅrrˆZopenerr·r½Z filteropenerrÁrÃr±rr°rrrrÚs0   I\