6h <%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r J r J r J r JrJrJrJrJrJrJrJrJr SSKJr SSKJrJrJrJrJr \R>(aSSKJ r! \"SS S 9r"\"S S S 9r#\ \$/\\%4r&S"S jr'"SS\RP5r)"SS\)5r*\*r+S\,S'"SS\)\RP5r-"SS\-\)5r.\.r/S\,S'"SS\-5r0"SS \RP5r1"SS\15r2"SS 5r3"S S!\15r4g)#) annotationsN)AnyBinaryIOCallableDictIterableIteratorListMutableMappingOptionalSetTupleTypeTypeVarUnion)_)encodingerrorpathutilpycompatutil)ui_Tbackgroundfilecloserbackgroundfilecloser)bound_Tclosewrapbase closewrapbasec^^UU4SjnU"5(d3[R"[R"T5T5 U"5 gg)zAvoid file stat ambiguity forcibly This function causes copying ``path`` file, if it is owned by another (see issue5418 and issue5584 for detail). c>[RRT5nURT5(+=(d UR TT5$N)rfilestatfrompathisambig avoidambig)newstatoldstatpaths //usr/lib/python3/dist-packages/mercurial/vfs.py checkandavoid"_avoidambig..checkandavoid?s;--((.??7++Pw/A/A$/PPN)rrename mktempcopy)r(r'r*s`` r) _avoidambigr/8s5Q ?? DOOD)40 r,c\rSrSr%SrSrS\S'SrS\S'S \S '\RS>S?S jj5r \RS@S j5r \RSAS j5r SBSjr S>SCSjjr\R S5rSBSjrS>SCSjjrSDSESjjrSFSGSjjrSHSjrSBSjrSISjrSBSjrSJSKSjjrSLSjrSJSKSjjrSJSKSjjrSJSKSjjrSJSKSjjrSMS jr SMS!jr!SNS"jr"SJSKS#jjr#SJSOS$jjr$SJSKS%jjr%SJSPS&jjr&SQSRS'jjr'SSSTS(jjr(SUS)jr)SJSRS*jjr*SVSWS+jjr+SXSYS,jjr,SBS-jr-SDSZS.jjr.SBS/jr/SJSRS0jjr0SJSRS1jjr1S[S\S2jjr2S]S3jr3SJSOS4jjr4SJSRS5jjr5SJSKS6jjr6S^S_S7jjr7SSS`S8jjr8SSSaS9jjr9\:RvSbScS:jj5rS=r?g)f abstractvfsKz+Abstract base class; cannot be instantiated/bytes_dir_sepTint createmodebool_chmodc gr!)selfr(modekwargss r)__call__abstractvfs.__call__` r,cgr!r;r<r(r=s r) _auditpathabstractvfs._auditpathdrAr,cgr!r;r<r(insidefs r)joinabstractvfs.joinhrAr,cFURU5$![a gf=f)z3gracefully return an empty string for missing filesr,)readFileNotFoundErrorr<r(s r)tryreadabstractvfs.tryreadls* 99T? "    s   cDURXS9$![a /$f=f)z2gracefully return an empty array for missing filesr=) readlinesrMrCs r) tryreadlinesabstractvfs.tryreadlinests/ >>$>2 2     s  cUR$)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 r)openabstractvfs.open|s}}r,cjU"US5nUR5sSSS5 $!,(df  g=f)Nrb)rL)r<r(fps r)rLabstractvfs.reads# $ "779  s$ 2cdU"XS9nUR5sSSS5 $!,(df  g=f)NrR)rS)r<r(r=r\s r)rSabstractvfs.readliness! $ "b<<># " "s! /c rU"US4SU0UD6nURU5sSSS5 $!,(df  g=f)Nwbbackgroundclosewrite)r<r(datarbr>r\s r)rdabstractvfs.writes2$ I I& IR88D>J I Is( 6chU"XUS9nURU5sSSS5 $!,(df  g=f)N)r= notindexed) writelines)r<r(rer=rhr\s r)riabstractvfs.writeliness($j 9R==&: 9 9s# 1clU"US5nURU5sSSS5 $!,(df  g=f)Nsabrc)r<r(rer\s r)appendabstractvfs.appends% $ "88D>  s% 3c@[RRU5$)zzreturn base element of a path (as os.path.basename would do) This exists to allow handling of strange encoding if needed.)osr(basenamerNs r)rpabstractvfs.basenamesww%%r,cN[R"URU5U5$r!)rochmodrIrCs r)rsabstractvfs.chmodsxx $..r,c@[RRU5$)z|return dirname element of a path (as os.path.dirname would do) This exists to allow handling of strange encoding if needed.)ror(dirnamerNs r)rvabstractvfs.dirnameswwt$$r,Nc^[RRURU55$r!)ror(existsrIrNs r)ryabstractvfs.existsww~~diio..r,c.[R"U5$r!)rfstat)r<r\s r)r}abstractvfs.fstatszz"~r,c^[RRURU55$r!)ror(isdirrIrNs r)rabstractvfs.isdirsww}}TYYt_--r,c^[RRURU55$r!)ror(isfilerIrNs r)rabstractvfs.isfiler{r,c^[RRURU55$r!)ror(islinkrIrNs r)rabstractvfs.islinkr{r,cURU5nURn[R"U5=(d [R "U5$![a gf=f)z`return whether path is a regular file or a symlink Unlike isfile, this doesn't follow symlinks.F)lstatOSErrorst_modestatS_ISREGS_ISLNK)r<r(str=s r) isfileorlinkabstractvfs.isfileorlinksQ D!Bzz||D!7T\\$%77  sA AAcFSn[U5HMup4[RRU5(d"UR UR 5(dMKUnMO US:waXSnUVs/sH oD(dM UPM nnUR R U5$s snfNr) enumerateror(isabs startswithr5rI)r<pathsroot_idxidxps r)_joinabstractvfs._joins&FCww}}Q1<< #>#>' q=)$E!'EqQE'}}!!%(((s - B;Bc UR"U6$)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.)r)r<rs r)reljoinabstractvfs.reljoins zz5!!r,c@[RRU5$)zzsplit top-most element of a path (as os.path.split would do) This exists to allow handling of strange encoding if needed.)ror(splitrNs r)rabstractvfs.splitsww}}T""r,c^[RRURU55$r!)ror(lexistsrIrNs r)rabstractvfs.lexistsswwtyy//r,cL[R"URU55$r!)rorrIrNs r)rabstractvfs.lstatxx $((r,cl[R"URU55nUSL=(a US:g$)areturn True if it is safe to read a file content as mmap This focus on the file system aspect of such safety, the application logic around that file is not taken into account, so caller need to make sure the file won't be truncated in a way that will create SIGBUS on access. The initial motivation for this logic is that if mmap is used on NFS and somebody deletes the mapped file (e.g. by renaming on top of it), then you get SIGBUS, which can be pretty disruptive: we get core dump reports, and the process terminates without writing to the blackbox. Instead, in this situation we prefer to read the file normally. The risk of ESTALE in the middle of the read remains, but it's smaller because we read sooner and the error should be reported just as any other error. Note that python standard library does not offer the necessary function to detect the file stem bits. So this detection rely on compiled bits and is not available in pure python. Nsnfs)r getfstyperI)r<r(fstypes r) is_mmap_safeabstractvfs.is_mmap_safes/4 $0T!6f&66r,cL[R"URU55$r!)rolistdirrIrNs r)rabstractvfs.listdirszz$))D/**r,cN[R"URU5U5$r!)rmakedirrI)r<r(rhs r)rabstractvfs.makedirs||DIIdOZ88r,cN[R"URU5U5$r!)rmakedirsrIrCs r)rabstractvfs.makedirs s}}TYYt_d33r,cL[R"XRU55$r!)rmakelockrI)r<infor(s r)rabstractvfs.makelocks}}T99T?33r,cL[R"URU55$r!)romkdirrIrNs r)rabstractvfs.mkdirrr,c[R"XURU5S9upE[R"U5upgU(a!U[ R RX754$XG4$)N)suffixprefixdir)rmkstemprIrrror()r<rrrfdnamednamefnames r)rabstractvfs.mkstempsX ##diin zz$'  rww||C// /9 r,cN[R"URU5X#5$r!)rrrI)r<r(rskips r)readdirabstractvfs.readdir+s||DIIdOT88r,cL[R"URU55$r!)rreadlockrIrNs r)rabstractvfs.readlock0}}TYYt_--r,c2URUS5 URU5nURU5nU(a[RR U5OSn[R "XE5 U(aUR (a [XV5 ggg)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). wN)rDrIrr"r#r-rr/)r<srcdst checkambigsrcpathdstpathr's r)r-abstractvfs.rename3sh T"))C.))C.5?$--((1T G% w||  )$7r,cL[R"URU55$r!)rreadlinkrIrNs r)rabstractvfs.readlinkIrr,cL[R"URU55$)z7Remove a leaf directory and all empty intermediate ones)r removedirsrIrNs r)rabstractvfs.removedirsLstyy//r,cL[R"URU55$)zRemove an empty directory.)rormdirrIrNs r)rabstractvfs.rmdirPsxx $((r,cU(aSSjnOSn[R"URU5X$S9$![a' [R"URU5X$S9s$f=f)zaRemove a directory tree recursively If ``forcibly``, this tries to remove READ-ONLY files, too. cTU[RLae[R"U5nUR[R-S:wae[R "U[R "UR5[R-5 [R"U5 gr)roremoverrS_IWRITErsS_IMODE)functionr(excinfoss r)onexc!abstractvfs.rmtree..onexc`sg 299,GGDMII -!3t||AII6FG $r,cgr!r;)argss r)rrpsr,) ignore_errorsr)ronerror)rrr(strr Exception)shutilrmtreerI TypeError)r<r(rforciblyrs r)rabstractvfs.rmtreeTsc    == $}  == $}  s#6.A'&A'cN[R"URU5X#5$r!)rsetflagsrI)r<r(lxs r)rabstractvfs.setflags~s}}TYYt_a33r,cL[R"URU55$r!)rorrIrNs r)rabstractvfs.statswwtyy''r,cL[R"URU55$r!)runlinkrIrNs r)rabstractvfs.unlinks{{499T?++r,cL[R"URU55$)z7Attempt to remove a file, ignoring missing file errors.)r tryunlinkrIrNs r)rabstractvfs.tryunlinks~~diio..r,cJ[R"URU5X#S9$)N) ignoremissingr)r unlinkpathrI)r<r(rrs r)rabstractvfs.unlinkpaths"  IIdO=  r,cN[R"URU5U5$r!)routimerI)r<r(ts r)rabstractvfs.utimesxx $++r,c## [RRURS55n[ [ R "U55n[R"URU5US9HupVnXTSXg4v M g7f)aYield (dirpath, dirs, files) tuple for each directory 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)ror(normpathrIlenr normasprefixwalk)r<r(rroot prefixlendirpathdirsfiless r)rabstractvfs.walksmww $0--d34 $&GGDIIdOW$M G5:&4 4%NsBBc#n# [R"5[R"5LaSv g[USU5n[USS5(a[R "[ S55e[XS9nUUlUv SUlSSS5 g!SUlf=f!,(df  g=f7f)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) threadingcurrent_thread main_threadgetattrrAbortrrr)r<rrrbfcs r)backgroundclosingabstractvfs.backgroundclosings  # # %Y-B-B-D D  dE4( 3/ 6 6++BC "" Bc ) )C B)C Bs6A8B5:B$< BB$ B5 B!!B$$ B2.B5cg)z1generic hook point to lets fncache steer its stewNr;rNs r) register_fileabstractvfs.register_filesr,cJURU5nURUS5 URU5 [R"U5upEXB;a2[R "X@R S5 URU5 SnUR bUR S-nX64$)atmake sure we are ready to write a file from a stream clone The "known_directories" variable is here to avoid trying to create the same directories over and over during a stream clone. It will be updated by this function. return (path, mode):: is the real file system path content should be written to, is the file mode that need to be set if any. raTN)rIrDr#rrrr7add)r<r(known_directories real_pathrvrpr=s r)prepare_streamed_file!abstractvfs.prepare_streamed_filesIIdO   5) 4  JJy1  + MM'??D 9  ! !' * ?? &??U*Dr,r;r[r(r4r=r4returnrr(r4r=r4r.Noner(Optional[bytes]rHr4r.r4)r(r4r.r4)r(r4r=r4r. List[bytes])F)r(r4rer4rbr8r.r6)raF) r(r4rezIterable[bytes]r=r4rhr8r.r0)r(r4rer4r.r6)r(r4r=r6r.r0r!)r(r2r.r8)r\rr.os.stat_result)rr4r.r4)r(r4r.zTuple[bytes, bytes])r(r2r.r4)r(r2r.r3NT)r(r2r.r0)NN)r(r2r= Optional[int]r.r0)rr4r(r4r.r0)r,stmpN)rr4rr4rr2r.zTuple[int, bytes])NNN)r(r2r.r)rr4rr4rr8r.r0)NFF)r(r2rr8rr8r.r0)r(r4rr8rr8r.r0)NFT)r(r2rr8rr8r.r0)r(r2r zOptional[Tuple[int, int]]r.r0)r(r2rzOptional[_OnErrorFn]r.z0Iterator[Tuple[bytes, List[bytes], List[bytes]]])ruimod.uirr6r.z(Iterator[Optional[backgroundfilecloser]])r(r4r.r0)r(r4r(z Set[bytes]r.zTuple[bytes, Optional[int]])@__name__ __module__ __qualname____firstlineno____doc__r5__annotations__rust_compatibleabcabstractmethodr?rDrIrOrTr propertycacherXrLrSrdrirlrprsrvryr}rrrrrrrrrrrrrrrrrrr-rrrrrrrrrrr contextlibcontextmanagerr r#r*__static_attributes__r;r,r)r1r1Ks5HeOO L          " AF""!&"9=" " ''' '  '  '"& /% /.// 8)"# 0)7:+9CG4#42?4 4 4) #      ,=A9#9 9 .*,.0) !%# ((( (  (T4(,/ !%#        LP,#,/H, , MQ5#55I5 95$13+. 1@@.8 $r,r1cT\rSrSr%SrS\S'S\S'S\S'S \S 'S \S 'S \S'SSSjjr\RSSj5r \RSSj5r SSjr SSjr SSjr S S!SjjrS"SjrS#SjrSrg)$riaSOperate 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. zDUnion[pathutil.pathauditor, Callable[[bytes, Optional[bytes]], Any]]auditr4baser6r7Dict[bytes, Any]optionsr8_auditzOptional[bool] _trustnlinkc8U(a[R"U5nU(a[RR U5nXlX lU(a%[R"UR US9Ul O SSjUl SUl SUl 0Ul g)N)cachedcgr5r;)r(r=s r)vfs.__init__..sr,r!) r expandpathror(realpathrIrLr pathauditorrHr7rMrK)r<rIrH cacheauditedrSrTs r)__init__ vfs.__init__sn ??4(D 77##D)D  !--dii MDJ5DJ r,cB[R"UR5$r!)r checklinkrIrWs r) _cansymlinkvfs._cansymlink~~dii((r,cB[R"UR5$r!)r checkexecrIrWs r)r9 vfs._chmodr]r,cURbUR(dg[R"XRS-5 g)Nr&)r7r9rors)r<rs r) _fixfilemodevfs._fixfilemodes* ?? "$++  ./r,cUR(a[RRU5(aIUR UR 5(a)[RR XR 5n[R"U5nU(a[R"SX14-5eURXS9 gg)Ns%s: %rrR) rLror(rrrIrelpathrcheckosfilenamerrrH)r<r(r=rs r)rDvfs._auditpath!s ;;ww}}T""ttyy'A'AwwtYY7$$T*Akk)qi"788 JJtJ ' r,cJ[R"[R"U55HDnX1;aXnO.[RR UR X25nXAU'U(aMD g URU5$![[R4a gf=f)areturn 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) rfinddirs_rev_norootr localpathrU_checkfs_existsrIrrrr)r<dircacher(rress r)isfileorlink_checkdirvfs.isfileorlink_checkdir*s "66t~~d7KL%"*C"..>> 6C(+V$s M  &&%  sA*B0B2BB"!B"c fU(aURX5 URU5n SU;aUS- nSn US;GaH[R"U 5upU (Ga(U(aHU(a![R"XR U5 [R "XUR US9$SU;a[R"U 5 Sn O=[R"U 5 [R"U 5n U S:aSn S S S 5 U S:avURc'U S:=(d [R"U 5Ul U S:dUR(d+[R"[R"U 5U 5 [R"XU S 9nU S:XaURU 5 U(a3US;a"[ R""[%S 5U-5e['U5nU(aq[(R*"5[(R,"5LaFUR.(d[ R""[%S 55e[1UUR.5nU$!,(df  GNk=f![a. Sn U(a![R"XR U5 GNf=f) 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). br8rr[)rrrrN) bufferings>implementation error: mode %s is not valid for checkambig=TruesSbackgroundclose can only be used when a backgroundclosing context manager is active)rDrIrrrr7atomictempfiler posixfilenlinksrMrM checknlinkr-r.rbrrrcheckambigatclosingrrrrdelayclosedfile)r<r(r= atomictemprhrbr auditpathmakeparentdirsrvfnlinkrvrpr\s r)r? vfs.__call__Es+T  OOD ' IIdO t  DLD } $ $ 1 G% g K..ZLt| A !"^^A.$(KKNE$qy()/19''/+019+J8J(qy(8(8 DOOA$6: ^^Ay 9 A:   a }$kk6 %R(B ((*i.C.C.EE..kkG!**B  _/.)LE% g KLs6.I8 I8#I&I8& I50I85I884J0/J0c URU5 URU5n[R"U5 [R"[ R RU5UR5 UR(a[ R"X5 gUR#X!5 g![aHn[UR[S5U[R"UR 54-U5eSnAff=f)Nscould not symlink to %r: %s)rHrIrrrror(rvr7r[symlinkrerrnorr strtolocalstrerrorrd)r<rrlinknameerrs r)r vfs.symlinks 399S> x  bggooh/A     3) JJs  II45H// =>?  s B22 Dr?rWrrCr[r9rbrDror?rrIrFr;r,r)rrso PO K  L "        , )) ))0 ('-''  '<  % #sss s  s  sssss sj!(r,rz Type[vfs]openerc\rSrSrS Sjr\S Sj5rS Sjr\S Sj5r\RSSj5r\S5r Sr g )proxyvfsicXlgr!rr<rs r)rWproxyvfs.__init__sr,c.URR$r!)rr7rWs r)r7proxyvfs.createmodesxx"""r,c8URRX5$r!)rrDrCs r)rDproxyvfs._auditpathsxx""4..r,c.URR$r!rrKrWs r)rKproxyvfs.optionssxxr,c$XRlgr!r)r<values r)rKrs  r,c.URR$r!)rrHrWs r)rHproxyvfs.auditsxx~~r,rNrrr.r0)r.r6r/)r.rJ)rrJr.r0) r:r;r<r=rWpropertyr7rDrKsetterrHrFr;r,r)rrs`##/   ^^!!r,rc6\rSrSrSrSSjrS SjrS SjrSrg) filtervfsiz4Wrapper vfs for filtering filenames with a function.c:[RX5 X lgr!)rrW_filter)r<rfilters r)rWfiltervfs.__init__s$$ r,cLUR"URU5/UQ70UD6$r!)rr)r<r(rr>s r)r?filtervfs.__call__s$xx T*.>t.Ng.N!OP P88==& &r,)rN)rrrzCallable[[bytes], bytes]r.r0)r(r4r.rr1 r:r;r<r=r>rWr?rIrFr;r,r)rrs> ='r,rzType[filtervfs] filteropenerc:\rSrSrSrSSjrS S SjjrS SjrSrg) readonlyvfsiz#Wrapper vfs preventing any writing.c.[RX5 gr!)rrWrs r)rWreadonlyvfs.__init__ s$$r,cxUS;a[R"[S55eUR"X/UQ70UD6$)Nrssthis vfs is read only)rrrr)r<r(r=rkws r)r?readonlyvfs.__call__s8 } $++a 89: :xx0T0R00r,c<URR"U/UQ76$r!)rrIrGs r)rIreadonlyvfs.joinsxx}}T,G,,r,r;Nrr,r-r1rr;r,r)rrs-%1 -r,rc\rSrSrSrS SjrS SjrSSjrSSjrSSjr \ RS Sj5r \ RS S j5r S rg )rizVBase class of wrapper, which hooks closing Do not instantiate outside the vfs layer. c2[RUSU5 g)N_origfh)object __setattr__)r<fhs r)rWclosewrapbase.__init__s4B/r,c.[URU5$r!)rrr<attrs r) __getattr__closewrapbase.__getattr__ t||T**r,c.[URX5$r!)setattrr)r<rrs r)rclosewrapbase.__setattr__#st||T11r,c.[URU5$r!)delattrrrs r) __delattr__closewrapbase.__delattr__&rr,c:URR5 U$r!)r __enter__rWs r)rclosewrapbase.__enter__)s   r,cgr!r;r<exc_type exc_valueexc_tbs r)__exit__closewrapbase.__exit__-rAr,cgr!r;rWs r)closeclosewrapbase.close1rAr,r;Nr.r0)rrr.r)rrrrr.r0)rrr.r0)r<rr.r)r:r;r<r=r>rWrrrrrArBrrrFr;r,r)rrsT 0+2+      r,cD^\rSrSrSrSU4SjjrSSjrSSjrSrU=r $)r|i6z[Proxy for a file object whose close is delayed. Do not instantiate outside the vfs layer. cR>[TU]U5 [RUSU5 g)N_closer)superrWrr)r<rcloser __class__s r)rWdelayclosedfile.__init__<s" 4F3r,cNURRUR5 gr!rrrrs r)rdelayclosedfile.__exit__@ 4<<(r,cNURRUR5 gr!rrWs r)rdelayclosedfile.closeCrr,r;r) r:r;r<r=r>rWrrrF __classcell__rs@r)r|r|6s 4)))r,r|cN\rSrSrSrS S SjjrS SjrS SjrS SjrS Sjr Sr g )riGzCCoordinates background closing of file handles on multiple threads.cHSUlSUl/UlSUl[R nUR SSU5nU(dgURSS5nUS:aX%:agURSS5nURSS5nURSU-5 [RRUS 9Ul S Ul[U5HMn[R"URS S 9n URR!U 5 U R#5 MO g) NFsworkersbackgroundclosesbackgroundcloseminfilecountrsbackgroundclosemaxqueuesbackgroundclosethreadcounts0starting %d threads for background file closing )maxsizeTbackgroundcloser)targetr)_running_entered_threads_threadexceptionr iswindows configbool configintdebugqueueQueue_queuerangerThread_workerrlstart) r<rrdefaultenabledenabled minfilecountmaxqueue threadcountir s r)rWbackgroundfilecloser.__init__Js   $"++-- +=~N  ||I/MN  1 != << +EFll9.KL   @; N nn**8*<  {#A   ;MNA MM  # GGI$r,cSUlU$r5)rrWs r)rbackgroundfilecloser.__enter__ps  r,cXSUlURHnUR5 M g)NF)rrrI)r<rrrr s r)rbackgroundfilecloser.__exit__ts" A FFHr,cURRSSS9nUR5 M.![anX lSnANSnAff=f![ R Ra UR(dgNRf=f)zMain routine for worker thread.Tg?blocktimeoutN) rgetrrrrrEmptyrr<res r)rbackgroundfilecloser._worker|sw [[__4_?.HHJ !.,-)).>>'' }}% s1A 0 A AA A  A /BBc*UR(d[R"[S55eUR(aURnSUlUeUR (dUR 5 gURRUSSS9 g)zSchedule a file for closing.s1can only call close() when context manager activeNTr ) rrrrrrrrputrs r)rbackgroundfilecloser.closesq}}++FG   %%A$(D !G}} HHJ  $5r,)rrrrrNr7)rr9rr6r.r0)r<rr.rr) r:r;r<r=r>rWrrrrrFr;r,r)rrGsM$L 6r,cN^\rSrSrSrSU4SjjrSSjrSSjrSSjrSr U=r $) r{ia 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 the vfs layer. c>[TU]U5 [RUS[R R UR55 g)N_oldstat)rrWrrrr"r#r)r<rrs r)rWcheckambigatclosing.__init__s5 4T]]-C-CBGG-LMr,cURnUR(a![URRU5 ggr!)rrr/rr)r<r's r) _checkambigcheckambigatclosing._checkambigs+-- <<  ))7 3 r,c\URRXU5 UR5 gr!)rrrrs r)rcheckambigatclosing.__exit__s" h6: r,cXURR5 UR5 gr!)rrrrWs r)rcheckambigatclosing.closes  r,r;r) r:r;r<r=r>rWrrrrFrrs@r)r{r{s"N4 r,r{)r(r4r'z util.filestatr.r0)5 __future__rrArDrorrrtypingrrrrrr r r r r rrrri18nrrrrrr TYPE_CHECKINGruimodrrrr _OnErrorFnr/ABCr1rrr?rrrrrr|rr{r;r,r)r(s*#   " % (>/GO9+x'778J&^#''^B h+hV {CGG0'+'$!* o) -( -  CGG >)m)"Y6Y6x-r,