6h%SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJrJrJrJrJrJrJrJ r J!r! SSK"J#r# SSK$J%r% \RL(aSSK%r%SSK'J(r( SS K)J*r*J+r+J,r,J-r-J.r.J/r/J0r0 SS K1J2r3J4r5 SS K6J7r7J8r8J9r9J:r: \\\\\/(de\RL(a SS K;JqGNf=f)zMercurial utility functions and platform specific implementations. This contains helper routines that are independent of the SCM core and hide platform-specific details from the core. ) annotationsN) AnyBinaryIOCallableIterableIteratorListOptionalTupleTypeTypeVar)hex)attr)tracing)encodingerrori18npolicypycompattypelib urllibcompat)miscmodules) compressionhashutilprocutil stringutil)Self_Tcowcow)boundbase85z intmod.Base85osutil)windows)posix statfiles _Tfilestatfilestatc|[R(ag[R"U5 US-=[lqg)z%updates the umask. used by chg serverNi)r iswindowsosumaskplatform)vals 0/usr/lib/python3/dist-packages/mercurial/util.pysetumaskr1s)HHSM 5[(HNUc$SnUHnX-nM U$Nr) containerbitsbits r0bitsfromr9s D  Kr2sHGEMITWARNINGSdefault mercurialhgexthgext3rdignorez bad escapezinvalid escape sequencezthe imp module is deprecatedc[(aZUSU-- n[R"[R"U5[ US-5 [ RR5 gg)zpIssue an python native deprecation warning This is a noop outside of tests, use 'ui.deprecwarn' when possible. sF (compatibility will be dropped after Mercurial-%s, update your code.)rN) _dowarnwarningswarnrsysstrDeprecationWarningsysstderrflush)msgversion stacklevels r0nouideprecwarnrLsU w  #    hooc*,> QO r2)md5sha1sha512)rOrNrMcD\rSrSrSrS SjrSrSrSr\ S5r Sr g ) digesteriafhelper to compute digests. This helper can be used to compute one or more digests given their name. >>> d = digester([b'md5', b'sha1']) >>> d.update(b'foo') >>> [k for k in sorted(d)] ['md5', 'sha1'] >>> d[b'md5'] 'acbd18db4cc2f85cedef654fccc4a4d8' >>> d[b'sha1'] '0beec7b5ea3f0fdbc95d0dd47f3c5bc275da8a33' >>> digester.preferred([b'md5', b'sha1']) 'sha1' c0UlUHJnU[;a"[R"[ S5U-5e[U"5URU'ML U(aUR U5 ggNsunknown digest type: %s)_hashesDIGESTSrAbort_update)selfdigestssks r0__init__digester.__init__s] Akk!$>"?!"CDD%ajlDLLO KKN r2chURR5HnURU5 M gN)rTvaluesrX)rYdatahs r0rXdigester.updates$$$&A HHTN'r2cU[;a&[R"[S5[-5e[ UR UR55$rS)rUrrVrWr\rrTdigest)rYkeys r0 __getitem__digester.__getitem__#sA g ++a :;a?@ @4<<$++-..r2c,[UR5$r`)iterrTrYs r0__iter__digester.__iter__(sDLL!!r2c0[H nX;dM Us $ g)z@returns the strongest digest type in both supported and DIGESTS.N)DIGESTS_BY_STRENGTH) supportedr\s r0 preferreddigester.preferred+s%A~%r2)rTN)r2) __name__ __module__ __qualname____firstlineno____doc__r]rXrhrm staticmethodrr__static_attributes__r5r2r0rQrQs/ / "r2rQc.\rSrSrSrSrSSjrSrSrg) digestcheckeri5zfile handle wrapper that additionally checks content against a given size and digests. d = digestchecker(fh, size, {'md5': '...'}) When multiple digests are given, all of them are validated. cXlX lSUl[U5Ul[ URR 55Ulgr4)_fh_size_gotdict_digestsrQkeys _digester)rYfhsizerZs r0r]digestchecker.__init__>s7  W  !$--"4"4"67r2cURRU5nURRU5 U=R[ U5- slU$r`)r~readrrXrlen)rYlengthcontents r0rdigestchecker.readEs=((--' g& S\! r2ctURUR:wa8[R"[ S5URUR4-5eUR R 5HHupX RU:wdM[R"[ S5XURU4-5e g)Ns"size mismatch: expected %d, got %ds %s mismatch: expected %s, got %s)rrrrVrWritemsrrYr\vs r0validatedigestchecker.validateKs :: "++78::tyy)* MM'')DANN1%%kk9:T^^A./0*r2)rrr~rrN) rtrurvrwrxr]rrrzr5r2r0r|r|5s8 r2r|cUb [U5XU-nUR5$[U5USnUR5$r`) memoryview toreadonly) sliceableoffsetrviews r0bufferr^sJ  i(6/BD  i(1D  r2ic^\rSrSrSrU4SjrSr\S5r\S5r Sr Sr S r S r S rS r\4S jrSrU=r$)bufferedinputpipeiia3a manually buffered input pipe Python will not let us use buffered IO and lazy reading with 'polling' at the same time. We cannot probe the buffer state and select will not detect that data are ready to read if they are already buffered. This class let us work around that by implementing its own buffering (allowing efficient readline) while offering a way to know if the buffer is empty from the output (allowing collaboration of the buffer with polling). This class lives in the 'util' module because it makes use of the 'os' module from the python stdlib. cX>[U[5(a[n[TU]U5$r`) isinstancefileobjectproxyobservedbufferedinputpipesuper__new__)clsr __class__s r0rbufferedinputpipe.__new__xs& b/ * *+Cws##r2c:Xl/UlSUlSUlg)NFr)_input_buffer_eof_lenbuf)rYinputs r0r]bufferedinputpipe.__init__s    r2c,[UR5$)zTrue is any data is currently buffered This will be used externally a pre-step for polling IO. If there is already data then no polling should be set in place.)boolrrls r0 hasbufferbufferedinputpipe.hasbuffers DLL!!r2c.URR$r`)rclosedrls r0rbufferedinputpipe.closeds{{!!!r2c6URR5$r`)rfilenorls r0rbufferedinputpipe.filenos{{!!##r2c6URR5$r`)rcloserls r0rbufferedinputpipe.closes{{  ""r2cUR(dCURU:a3UR5 UR(dURU:aM3URU5$r`)rr _fillbuffer _frombufferrYrs r0rbufferedinputpipe.readsE994<<$#6    994<<$#6%%r2cUR(d/URS:XaUR[U[55 UR [ URU55$r4)rrrmax _chunksizerminrs r0unbufferedread bufferedinputpipe.unbufferedreadsEyyT\\Q.   Sz2 3DLL$ 788r2c[UR5S:a>SRUR5/Ul[URS5UlSnUR(aURSR S5nUR (d^US:aXUR 5 UR(aURSR S5nUR (dUS:aMXUS-nUS:a URnO@[UR5S:a'X@R[URS5- - nURU5$)Nrr2rr )rrjoinrfindrrr)rYargskwargslfirs r0readlinebufferedinputpipe.readlines  t|| q  HHT\\23DLt||A/DL <<,,r"''.C99#'    ||ll2&++E299#'Qw 7<T$r`r5fpsr0mmapread..srr2cH[R"X[RS9$)N)access)r ACCESS_READ)fdrs r0rrs2D[R"XT[RS9nT(aT(a[RU5 U$)N)flagsprot)r PROT_READr$r)rrm bg_populater pre_populates r0_mmapmmapread.._mmaps1 "%dnnEA //2Hr2)returnz mmap.mmap) getattrrr+r MAP_PRIVATErr$ ValueErrorr,fstatst_size)rrrrrrrs` ` @@r0mmapreadrs qy  Xz * ,BM  f&@A  WT>15 5E   R  88B<  1 $ s B.CCc4\rSrSr%S\S'SSjrS SjrSrg) uncacheable_cachestati Optional[os.stat_result]statcSUlgr`rrls r0r]uncacheable_cachestat.__init__s  r2cgNFr5rls r0 cacheableuncacheable_cachestat.cacheablesr2rNrNonerr)rtrurvrw__annotations__r]rrzr5r2r0rr s ""r2rc\rSrSrSrSrSrSrSr\r Sr Sr S r S r S rS rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!g) rizA proxy around file objects that tells a watcher when events occur. This type is intended to only be used for testing purposes. Think hard before using it in important code. _orig _observerc`[RUSU5 [RUSU5 gNr r object __setattr__)rYrobservers r0r]fileobjectproxy.__init__!s&4"-4h7r2c~1SknX;a[RX5$[[RUS5U5$)N>rseektellrrHread1writedetachrisattyreadallreadablereadintorseekabletruncatewritabler  readlines writelinesr r__getattribute__r)rYnameourss r0r# fileobjectproxy.__getattribute__%s< @ <**46 6v..tW=tDDr2c@[[RUS55$Nr rrr#rls r0 __nonzero__fileobjectproxy.__nonzero__KF++D':;;r2cB[[RUS5U5$r(delattrrr#rYr$s r0 __delattr__fileobjectproxy.__delattr__Pv..tW=tDDr2cB[[RUS5X5$r(setattrrr#rYr$values r0rfileobjectproxy.__setattr__Sv..tW=tKKr2cJ[RUS5R5$r()rr#rmrls r0rmfileobjectproxy.__iter__Vs&&tW5>>@@r2c[RUS5n[XA5"U0UD6n[RUS5n[XaS5nU(a U"U/UQ70UD6 U$r r"rYr$rrorigresrfns r0 _observedcallfileobjectproxy._observedcallYb&&tW5d!4262**4= XT * s $T $V $ r2cB[RUS5"S/UQ70UD6$)NrBrrr#rYrrs r0rfileobjectproxy.closeg/&&t_=   $  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.filenol/&&t_=   %  r2cB[RUS5"S/UQ70UD6$)NrBrHrFrGs r0rHfileobjectproxy.flushqrIr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.isattyvrLr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.readable{/&&t_=   !'  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.readlinerSr2cB[RUS5"S/UQ70UD6$)NrBr rFrGs r0r fileobjectproxy.readlines/&&t_=   "(  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.seek/&&t_=   #  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.seekablerSr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.tellr[r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.truncaterSr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.writablerSr2cB[RUS5"S/UQ70UD6$)NrBr!rFrGs r0r!fileobjectproxy.writelines/&&t_=   #)  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.readr[r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.readall/&&t_=   &  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.readintorSr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.writerIr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.detachrLr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rfileobjectproxy.read1rIr2r5N)"rtrurvrwrx __slots__r]r#r*__bool__r1rrmrBrrrHrrrr rrrrrr!rrrrrrrzr5r2r0rrs I 8$EL<HELA                    r2rcJ^\rSrSrSr\4U4SjjrU4SjrU4SjrSr U=r $)riaA variation of bufferedinputpipe that is aware of fileobjectproxy. ``bufferedinputpipe`` makes low-level calls to ``os.read()`` that bypass ``fileobjectproxy``. Because of this, we need to make ``bufferedinputpipe`` aware of these operations. This variation of ``bufferedinputpipe`` can notify observers about ``os.read()`` events. It also re-publishes other events, such as ``read()`` and ``readline()``. c>[TU]US9n[URRSS5nU(aU"X!5 U$)N)rosread)rrrrr rYrr@rArs r0r%observedbufferedinputpipe._fillbuffers<g!t!, T[[**Hd ; sM r2c>[TU]U5n[URRSS5nU(aU"X!5 U$)N bufferedread)rrrrr rys r0robservedbufferedinputpipe.reads8gl4  T[[**ND A sM r2c>[TU]"U0UD6n[URRSS5nU(aU"U5 U$)Nbufferedreadline)rrrrr )rYrrr@rArs r0r"observedbufferedinputpipe.readlines?g// T[[**,> E sG r2r5) rtrurvrwrxrrrrrzrrs@r0rrs!  *r2r> recvsendsendtosendallmakefilerecvfrom recv_into gettimeout setsockopt settimeout setblocking recvfrom_intoc\rSrSrSrSrSrSrSrSr Sr \ r S r S r S rS rS rSrSrSrSrSrSrSrSrSrg) socketproxyizA proxy around a socket that tells a watcher when events occur. This is like ``fileobjectproxy`` except for sockets. This type is intended to only be used for testing purposes. Think hard before using it in important code. r c`[RUSU5 [RUSU5 gr r)rYsockrs r0r]socketproxy.__init__s&4$/4h7r2cU[;a[RX5$[[RUS5U5$r()PROXIED_SOCKET_METHODSrr#rr0s r0r#socketproxy.__getattribute__s6 ) )**46 6v..tW=tDDr2cB[[RUS5U5$r(r.r0s r0r1socketproxy.__delattr__r3r2cB[[RUS5X5$r(r5r7s r0rsocketproxy.__setattr__r:r2c@[[RUS55$r(r)rls r0r*socketproxy.__nonzero__r,r2c[RUS5n[XA5"U0UD6n[RUS5n[XaS5nU(a U"U/UQ70UD6 U$r r"r>s r0rBsocketproxy._observedcall$rDr2c [RUS5"S/UQ70UD6n[RUS5n[URUURUR UR URURS9$)NrBrr readswriteslogdata logdataapis) rr#makeloggingfileobjectrr$rrrr)rYrrr@rs r0rsocketproxy.makefile2s~%%dO<   !'  **4=$ KK  MM..??$$ ,,  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.recvDr[r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.recvfromIrSr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.recvfrom_intoNs/&&t_=  " &,  r2cB[RUS5"S/UQ70UD6$)NrB recv_inforFrGs r0rsocketproxy.recv_intoSrXr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.sendXr[r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.sendall]rkr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.sendtobrLr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.setblockinggs/&&t_=    $*  r2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.settimeoutlrfr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.gettimeoutqrfr2cB[RUS5"S/UQ70UD6$)NrBrrFrGs r0rsocketproxy.setsockoptvrfr2r5N)rtrurvrwrxrtr]r#r1rr*rurBrrrrrrrrrrrrrzr5r2r0rrsrI 8E EL<H  $           r2rc \rSrSrSrSrSrg)baseproxyobserveri|c4XlX lX0lX@lgr`)rr$rr)rYrr$rrs r0r]baseproxyobserver.__init__}s  &r2c6UR(dGUR(a5URRS5 URR 5 gSU;aUR(a3URRS[ R "U5-5 O>URRSUR[ R "U54-5 URR 5 gUR(aURRS5 URS5nUHAnURRSUR[ R "U54-5 MC URR 5 g)Nrs: %s s %s> %s s: T) rrrrrHr escapestrr$ splitlines)rYrblineslines r0 _writedatabaseproxyobserver._writedatas|| e$     i**>*>t*DDE #tyy*2F2Ft2L&MM GGMMO     GGMM& !%D GGMM499j.B.B4.H"II   r2)rrrr$N)rtrurvrwr]rrzr5r2r0rr|s ' r2rcd^\rSrSrSrS U4SjjrS SjrS SjrSrSr Sr S r S r S r U=r$)fileobjectobserverizLogs file object activity.c>>[TU]XXV5 X0lX@lgr`)rr]rr)rYrr$rrrrrs r0r]fileobjectobserver.__init__s 78  r2cUR(dgUcSnUS:XaUS:XagUR(a4URRSURU[ U54-5 UR U5 g)Nr2rs%s> read(%d) -> %drrrrr$rrrYr@rs r0rfileobjectobserver.readsbzz  ;C 2:#*     GGMM/499dCH2MM N r2cUR(dgUR(a3URRSUR[ U54-5 UR U5 g)Ns%s> readline() -> %dr)rYr@limits r0rfileobjectobserver.readlinesDzz     GGMM1TYYC4II J r2c2UR(dgUR(a4URRSUR[ U5U4-5 UbUSUOSn[ U[5(aUR5nURU5 g)Ns%s> readinto(%d) -> %rrr2) rrrrr$rrrtobytesr)rYr@destrbs r0rfileobjectobserver.readintosuzz     GGMM)TYYD 3,GG "otAc{3 dJ ' '<<>D r2cUR(dgUcU(a [U5nUR(a4URR SUR [U5U4-5 UR U5 g)Ns%s> write(%d) -> %r)rrrrrr$r)rYr@rbs r0rfileobjectobserver.writesX{{  ;4d)C    GGMM0DIIs4y#3NN O r2c|UR(dgURRSURU4-5 g)Ns%s> flush() -> %r )rrrr$rYr@s r0rHfileobjectobserver.flushs+{{   , 3/??@r2cUR(dgUR(a4URRSURU[ U54-5 UR U5 g)Ns%s> bufferedread(%d) -> %drrs r0r|fileobjectobserver.bufferedreadsJzz     GGMM-D#c(0KK  r2cUR(dgUR(a3URRSUR[ U54-5 UR U5 g)Ns%s> bufferedreadline() -> %drrs r0r#fileobjectobserver.bufferedreadlinesHzz     GGMM/499c#h2GG  r2)rrTTFTr)rtrurvrwrxr]rrrrrHr|rrzrrs@r0rrs;$MQ&$ A   r2rFc 4[UUUUUUS9n[X5$)z.Turn a file object into a logging file object.r)rr)loghrr$rrrrrs r0rrs- "   H 2 ((r2c^\rSrSrSrSU4SjjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr S rS rSrSrSrU=r$)socketobserverizLogs socket activity.cJ>[TU]XXg5 X0lX@lXPlgr`)rr]rrstates) rYrr$rrrrrrs r0r]socketobserver.__init__s# 78   r2c|UR(dgURRSURX#4-5 g)Ns%s> makefile(%r, %r) rrrr$)rYr@modebufsizes r0rsocketobserver.makefile's+{{   /499d2LLMr2c UR(dgUR(a4URRSURX#[ U54-5 UR U5 g)Ns%s> recv(%d, %d) -> %drrYr@rrs r0rsocketobserver.recv-sJzz     GGMM)TYYSX,NN  r2c UR(dgUR(a7URRSURX#[ US54-5 UR US5 g)Ns%s> recvfrom(%d, %d) -> %drrrs r0rsocketobserver.recvfrom7sUzz     GGMM-99d3s1v;78  Ar2cUR(dgUR(a.URRSURX4US4-5 UR USUS5 g)Ns%s> recvfrom_into(%d, %d) -> %drrrrrr$rrYr@rrrs r0rsocketobserver.recvfrom_intoCsWzz     GGMM299d3q623  AA(r2cUR(dgUR(a+URRSURX4U4-5 UR USU5 g)Ns%s> recv_into(%d, %d) -> %drrrs r0rsocketobserver.recv_intoOsLzz     GGMM.$))T#1NN  Ac #r2c UR(dgURRSUR[ U5U[ U54-5 UR U5 g)Ns%s> send(%d, %d) -> %d)rrrr$rrrYr@rbrs r0rsocketobserver.sendZsG{{   %CIuc#h(O O  r2cUR(dgUR(a4URRSUR[ U5U4-5 UR U5 g)Ns%s> sendall(%d, %d)rrrrr$rrrs r0rsocketobserver.sendallcsJ{{     GGMM&$))SY)FF  r2cUR(dgU(aUnOSnUR(a5URRSUR[ U5XTU4-5 UR U5 g)Nrs%s> sendto(%d, %d, %r) -> %dr)rYr@rbflagsoraddressaddressrs r0rsocketobserver.sendtoos\{{  "EE    GGMM/99c$i=>  r2c|UR(dgURRSURU4-5 g)Ns%s> setblocking(%r) r)rYr@flags r0rsocketobserver.setblockings+{{   .$))T1BBCr2c|UR(dgURRSURU4-5 g)Ns%s> settimeout(%r) r)rYr@r8s r0rsocketobserver.settimeouts+{{   -E0BBCr2c|UR(dgURRSURU4-5 g)Ns%s> gettimeout() -> %f rrs r0rsocketobserver.gettimeouts+{{   1TYY4DDEr2c~UR(dgURRSURX#XA4-5 g)Ns!%s> setsockopt(%r, %r, %r) -> %r r)rYr@leveloptnamer8s r0rsocketobserver.setsockopts2{{   1yy%%5 6 r2)rrrTTTFTNNr)rrr`)rtrurvrwrxr]rrrrrrrrrrrrrzrrs@r0rrsa  N    ) $ "D D F   r2rc 6[UUUUUUUS9n[X5$)z$Turn a socket into a logging socket.)rrrrr)rr) rrr$rrrrrrs r0makeloggingsocketrs0  H r $$r2cdSSKJn URR5$![a gf=f)z(Return version information if available.r __version__sunknown)r;rrJencode ImportErrorrs r0rJrJs3!""))++ s " //c|U(d [5n[R"SU5nU(dSUpCO;URS5(aUR 5up4OURS5SpCUce/nUR S5HnUR [U55 M [U5S:a"UR S5 [U5S:aM"US:Xa USUS4$US:XaUSUSUS4$US :XaUSUSUSU4$[R"S U-5e![a  Mf=f) aParses a Mercurial version string into an N-tuple. The version string to be parsed is specified with the ``v`` argument. If it isn't defined, the current Mercurial version string will be parsed. ``n`` can be 2, 3, or 4. Here is how some version strings map to returned values: >>> v = b'3.6.1+190-df9b73d2d444' >>> versiontuple(v, 2) (3, 6) >>> versiontuple(v, 3) (3, 6, 1) >>> versiontuple(v, 4) (3, 6, 1, '190-df9b73d2d444') >>> versiontuple(b'3.6.1+190-df9b73d2d444+20151118') (3, 6, 1, '190-df9b73d2d444+20151118') >>> v = b'3.6' >>> versiontuple(v, 2) (3, 6) >>> versiontuple(v, 3) (3, 6, None) >>> versiontuple(v, 4) (3, 6, None, None) >>> v = b'3.9-rc' >>> versiontuple(v, 2) (3, 9) >>> versiontuple(v, 3) (3, 9, None) >>> versiontuple(v, 4) (3, 9, None, 'rc') >>> v = b'3.9-rc+2-02a8fea4289b' >>> versiontuple(v, 2) (3, 9) >>> versiontuple(v, 3) (3, 9, None) >>> versiontuple(v, 4) (3, 9, None, 'rc+2-02a8fea4289b') >>> versiontuple(b'4.6rc0') (4, 6, None, 'rc0') >>> versiontuple(b'4.6rc0+12-425d55e54f98') (4, 6, None, 'rc0+12-425d55e54f98') >>> versiontuple(b'.1.2.3') (None, None, None, '.1.2.3') >>> versiontuple(b'12.34..5') (12, 34, None, '..5') >>> versiontuple(b'1.2.3.4.5.6') (1, 2, 3, '.4.5.6') s(\d+(?:\.\d+){,2})[+-]?(.*)r2rN.rs invalid version part request: %d) rJremodmatchgroupgroupssplitrintrrrProgrammingError)rnrvpartsextravintsis r0 versiontupler's=n I 3Q7A Q   D    E \\$   LLQ  e*q. T e*q. Ava%(##Ava%(E!H--Ava%(E!He44  !Dq!H II   s D,, D;:D;c^^^TRRS:Xa /mUU4SjnU$0mTRRS:Xa UU4SjnU$UU4SjnU$)z"cache the result of function callsrcX>[T5S:XaTRT"55 TS$r4)rr)func listcachesr0fcachefunc..fs)9~"  (Q< r2rc0>UT;a T"U5TU'TU$r`r5)argcacher*s r0r,r-&s"%!#Yc : r2c*>UT;aT"U6TU'TU$r`r5)rr0r*s r0r,r--s"5 "Dkd ; r2)__code__ co_argcount)r*r,r0r+s` @@r0 cachefuncr4sW }}  A%   E }}  A%  H   Hr2c8\rSrSr%SrS\S'S SjrS SjrSrg) r!i5zVhelper class to make copy-on-write easier Call preparewrite before doing any writes. r _copiedcv[USS5(a&U=RS-slURU5$U$)z;call this before writes, return self or a copied new objectr6rr)rr6rrls r0 preparewritecow.preparewrite=s3 4A & & LLA L>>$' ' r2c0[USS5S-UlU$)zalways do a cheap copyr6rr)rr6rls r0copycow.copyEstY2Q6  r2)r6N)rYr rr rr) rtrurvrwrxrr8r;rzr5r2r0r!r!5s Lr2cZ^\rSrSrSrU4Sjr\R(aSrSr Sr U=r $)sortdictiKa7a simple sorted dictionary >>> d1 = sortdict([(b'a', 0), (b'b', 1)]) >>> d2 = d1.copy() >>> list(d2.items()) [('a', 0), ('b', 1)] >>> d2.update([(b'a', 2)]) >>> list(d2.keys()) # should still be in last-set order ['b', 'a'] >>> d1.insert(1, b'a.5', 0.5) >>> list(d1.items()) [('a', 0), ('a.5', 0.5), ('b', 1)] c2>X;aX [TU]X5 gr`)r __setitem__)rYrgr8rs r0rAsortdict.__setitem__Zs ;  C'r2c [U[5(aUR5nUH up4X@U'M UH nX#X'M gr`)rrr)rYsrcr,r\rs r0rXsortdict.updateas@#t$$iikQ$r2c[[UR555HunupVXA:XaX0U'XA:dMX X`U'M gr`) enumeratelistr)rYpositionrgr8r&r\rs r0insertsortdict.insertis?"4 #56IAv}!S }GQ 7r2r5) rtrurvrwrxrArispypyrXrJrzrrs@r0r?r?Ks% (  r2r?c\rSrSrSrSrg)cowdictiraTcopy-on-write dict Be sure to call d = d.preparewrite() before writing to d. >>> a = cowdict() >>> a is a.preparewrite() True >>> b = a.copy() >>> b is a True >>> c = b.copy() >>> c is a True >>> a = a.preparewrite() >>> b is a False >>> a is a.preparewrite() True >>> c = c.preparewrite() >>> b is c False >>> b is b.preparewrite() True r5Nrtrurvrwrxrzr5r2r0rNrNrsr2rNc\rSrSrSrSrg) cowsortdictizRcopy-on-write sortdict Be sure to call d = d.preparewrite() before writing to d. r5NrOr5r2r0rQrQsr2rQc|\rSrSrSr\R S Sj5r\R S Sj5rS Sjr S Sjr Sr g) transactionalizBBase class for making a transactional type into a context manager.cg)z$Successfully closes the transaction.Nr5rls r0rtransactional.closer2cg)z_Marks the end of the transaction. If the transaction has not been closed, it will be aborted. Nr5rls r0releasetransactional.releaserVr2cU$r`r5rls r0 __enter__transactional.__enter__ r2cvUcUR5 UR5 g!UR5 f=fr`)rrX)rYexc_typeexc_valexc_tbs r0__exit__transactional.__exit__s)  LLNDLLNs&8r5Nrr=) rtrurvrwrxabcabstractmethodrrXr[rbrzr5r2r0rSrSsAL33   r2rSc## U(dSv gSv UR5 UR5 g![Ra UR5 ef=f!UR5 f=f7f)zA context manager that closes the transaction on InterventionRequired If no transaction was provided, this simply runs the body and returns N)rrInterventionRequiredrX)trs r0acceptinterventionrisZ      % %    s% A46A4&AAA11A4c## Uv g7fr`r5) enter_results r0nullcontextmanagerrls sc(\rSrSrSrSrSrSrSrg) _lrucachenodeizA node in a doubly linked list. Holds a reference to nodes on either side as well as a key-value pair for the dictionary entry. )nextprevrgr8costcNXlXl[UlSUlSUlgr4)rorp_notsetrgr8rqrls r0r]_lrucachenode.__init__s!    r2c6[UlSUlSUlg)zMark the node as emptied.Nr)rsrgr8rqrls r0 markempty_lrucachenode.markemptys  r2)rqrgrorpr8N) rtrurvrwrxrtr]rvrzr5r2r0rnrns 9Ir2rnc\rSrSrSrSSjrSrSrSrSr SSjr S r S r \ 4S jrSS jr\ 4SjrSrSSjrSrSSjrSSjrSrSrg ) lrucachedictiaDict that caches most recent accesses and sets. The dict consists of an actual backing dict - indexed by original key - and a doubly linked circular list defining the order of entries in the cache. The head node is the newest entry in the cache. If the cache is full, we recycle head.prev and make it the new head. Cache accesses result in the node being moved to before the existing head and being marked as the new head node. Items in the cache can be inserted with an optional "cost" value. This is simply an integer that is specified by the caller. The cache can be queried for the total cost of all items presently in the cache. The cache can also define a maximum cost. If a cache insertion would cause the total cost of the cache to go beyond the maximum cost limit, nodes will be evicted to make room for the new code. This can be used to e.g. set a max memory limit and associate an estimated bytes size cost to each item in the cache. By default, no maximum cost is enforced. cd0Ul[5UlSUlXlSUlX lg)Nrr)_cachern_headrcapacity totalcostmaxcost)rYrrs r0r]lrucachedict.__init__s* "_    r2c,[UR5$r`)rr{rls r0__len__lrucachedict.__len__s4;;r2cXR;$r`)r{rYr\s r0 __contains__lrucachedict.__contains__sKKr2c## URn[[UR55HnURv UR nM g7fr`)r|rangerr{rgro)rYr"r&s r0rmlrucachedict.__iter__s8 JJs4;;'(A%%KA)sA AcZURUnURU5 UR$r`)r{ _movetoheadr8)rYr\nodes r0rhlrucachedict.__getitem__ s'{{1~ zzr2cURRU5nUbsU=RUR-slX$lX4lU=RU- slUR U5 UR (aUR5 gURUR:aUR5nOURRnUR[La6U=RUR-slURUR Xl X$lX4lU=RU- slX@RU'X@l UR (aUR5 gg)z8Insert a new item in the cache with optional cost value.N)r{getr~rqr8rr_enforcecostlimitrr} _addcapacityr|rprgrs)rYr\rrqrs r0rJlrucachedict.inserts {{q!   NNdii 'NJI NNd "N   T "||&&(  :: %$$&D::??D 887 " NNdii 'N DHH%   $ A <<  " " $ r2c&URX5 gr`)rJrs r0rAlrucachedict.__setitem__6s Ar2c&URU5 gr`)poprs r0 __delitem__lrucachedict.__delitem__9s   r2c0URRU5nURnU=R UR -slUR5 URU5 URUl U$![a U[LaeUs$f=fr`) r{rKeyErrorrsr8r~rqrvrror|)rYr\r:rr8s r0rlrucachedict.pop<s ;;??1%D   $))#  YY   '!N sA<<BBNcJURU5$![a Us$f=fr`)rhr)rYr\r:s r0rlrucachedict.getQs, ##A& & N s  ""crURUnUR$![a U[LaeUs$f=f)zGet the specified item without moving it to the head Unlike get(), this doesn't mutate the internal state. But be aware that it doesn't mean peek() is thread safe. )r{r8rrs)rYr\r:rs r0peeklrucachedict.peekWs=  ;;q>D::  '!N s 66cURnUR[LaPU=RUR-slUR 5 UR nUR[LaMPURR5 gr`) r|rgrsr~rqrvror{clear)rYr"s r0rlrucachedict.cleares[ JJee7" NNaff $N KKMAee7" r2cU=(d URnU=(d URn[XS9nURRnUR [ La=X@RLa/URnUR [ LaX@RLaM/[[UR55H>nURUR URURS9 URnM@ U$)aCreate a new cache as a copy of the current one. By default, the new cache has the same capacity as the existing one. But, the cache capacity can be changed as part of performing the copy. Items in the copy have an insertion/access order matching this instance. )r)rq) r}rryr|rprgrsrrr{rJr8rq)rYr}rresultr"r&s r0r;lrucachedict.copyns,t}})T\\h8 JJOOeew1JJ#6Aeew1JJ#6 s4;;'(A MM!%%qvvM 6A) r2czUR(dgURRnUR[La!URnUR[LaM!URUR p2URUR U=R UR-slUR5 X#4$)zeRemove the oldest item from the cache. Returns the (key, value) describing the removed cache entry. N) r{r|rprgrsr8r~rqrv)rYr"rgr8s r0 popoldestlrucachedict.popoldests {{  JJOOeewAeewUUAGGU KK  !&&  zr2c,URnURURlURURlURUlURRUlXRlXRlXlg)aMark a node as the newest, making it the new head. When a node is accessed, it becomes the freshest entry in the LRU list, which is denoted by self._head. Visually, let's make ``N`` the new head node (* denotes head): previous/oldest <-> head <-> next/next newest ----<->--- A* ---<->----- | | E <-> D <-> N <-> C <-> B To: ----<->--- N* ---<->----- | | E <-> D <-> C <-> B <-> A This requires the following moves: C.next = D (node.prev.next = node.next) D.prev = C (node.next.prev = node.prev) E.next = N (head.prev.next = node) N.prev = E (node.prev = head.prev) N.next = A (node.next = head) A.prev = N (head.prev = node) N)r|rorp)rYrheads r0rlrucachedict._movetoheads^:zz  II IINN    r2cURn[5nX!RlURUlXlX!lU=RS- slU$)zXAdd a node to the circular linked list. The new node is inserted before the head node. r)r|rnrpror)rYrrs r0rlrucachedict._addcapacitysD zz II    a  r2cF[U5S::dURUR::ag[URS-5nURR nUR [La!UR nUR [LaM![U5S:aURU:auURUR U=RUR-slUR5 UR n[U5S:aURU:aMsgggg)Nrg?) rr~rr r|rprgrsr{rqrv)rY targetcostr"s r0rlrucachedict._enforcecostlimits t9>T^^t||; ,- JJOOeewAeew$i!m ; AEE" NNaff $N KKMA $i!m ;m ;mr2)r{r|rr}rr~rr`r4)rrn)rrn)rtrurvrwrxr]rrrmrhrJrArrsrrrrr;rrrrrzr5r2r0ryrysh,   %%N%* & >0-^ r2ryc^^^0m[R"5mTRRS:Xa UUU4SjnU$UUU4SjnU$)z+cache most recent results of function callsrc>UT;a,[T5S:aTTR5 T"U5TU'OTRU5 TRU5 TU$Nrpopleftremover)r/r0r*orders r0r,lrucachefunc..f sS%u:?emmo.!#Yc  S! LL : r2c>UT;a)[T5S:aTTR5 T"U6TU'OTRU5 TRU5 TU$rr)rr0r*rs r0r,rsS5 u:?emmo."Dkd  T" LL ; r2) collectionsdequer2r3)r*r,r0rs` @@r0 lrucachefuncrs@ E    E }}  A% , H  Hr2c*\rSrSrSrSSjrSrSrg) propertycachei"c2XlURUlgr`)r*rtr$)rYr*s r0r]propertycache.__init__#s MM r2NcJURU5nURX5 U$r`)r* cachevalue)rYobjtypers r0__get__propertycache.__get__'s 3 $ r2c4X!RUR'gr`)__dict__r$)rYrr8s r0rpropertycache.cachevalue,s"' TYYr2)r*r$r`)rtrurvrwr]rrrzr5r2r0rr"s" (r2rcj[R"U5nXR;aURU gg)z2clear a cached property value, if one has been setN)rrDr)rprops r0clearcachedpropertyr1s+ ??4 D || LL r2c#"# Sn/nSnUHcnURU5 U[U5- nXQ:dM)X:aUS-nSU"U5-nXq:aUnX:aUnSRU5v Sn/nMe U(aSRU5v gg7f)znreturn no less than min bytes per chunk while data remains, doubling min after each chunk until it reaches maxcTU(dgSnU(aUS-nUS- nU(aMUS- $)Nrrr5)xr&s r0log2increasingchunks..log2<s4  !GA FAa1u r2rrr2N)rrr)sourcerrrrblenchunknmins r0increasingchunksr8s C D 5 E  ;yQhDJ:C9C((3- DC hhsm s /BABcgNTr5rAs r0alwaysrYs r2cgrr5rs r0neverr]s r2c2Uc [5$[U5$)adisable garbage collector Python's garbage collector triggers a GC each time a certain number of container objects (the number being defined by gc.get_threshold()) are allocated even when marked not to be tracked by the collector. Tracking has no effect on when GCs are triggered, only on what objects the GC looks into. As a workaround, disable GC while building complex (huge) containers. This garbage collector issue have been fixed in 2.7. But it still affect CPython's performance. ) _nogc_context_nogc_decorator)r*s r0nogcras |t$$r2c## [R"5n[R"5 Sv U(a[R"5 gg!U(a[R"5 ff=f7fr`)gc isenableddisableenable) gcenableds r0rrtsC IJJL  IIK 9 IIK s+A2AA2A//A2c^U4SjnU$)Nc^>[5 T"U0UD6sSSS5 $!,(df  g=fr`)r)rrr*s r0wrapper _nogc_decorator..wrappers _((__s ,r5r*rs` r0rrs) Nr2cU$r`r5rs r0rrsQr2c6U(d [U5$[RRU5(a[RR U5S[RR U5S:wa)[RR U[U55$SR [ U5U45n[U5URS5pCUR5 UR5 U(aOU(aHUSUS:Xa<UR5 UR5 U(aU(aUSUS:XaM<UR5 [RR S/[U5-U-5=(d S$)aAreturn the relative path from one place to another. root should use os.sep to separate directories n1 should use os.sep to separate directories n2 should use "/" to separate directories returns an os.sep-separated path. If n1 is a relative path, it's assumed it's relative to root. n2 should always be relative to root. r/r..r) localpathr,pathisabs splitdriverpconvert splitpathrreverserrossepr)rootn1n2abs r0pathtors } ww}}R 77  d #A &"''*<*.checksY (( ( 9'' q(9:;uD***  s  AA r5)r*r r s`` r0checksignaturer s Lr2> hfsjfsufsxfszfsNTFSapfsext2ext3ext4btrfstmpfsreiserfscU(a U(aeSn[RRU5(a0U(aU=(a [R U5n[ U5 U(aFU(a?[ [RRU55n U [;a UbU"5 SnU(a([X5 UbSn [R"U 5eg[RRU5(aG[R "[R""U5U5 UbSn [R"U 5eg[$R&"X5 U(a[$R("X5 O[$R*"X5 U(awUR,(af[R U5n U R/U5(a;UR,[,R0S-S-n [R2"XU 45 Ub%[5USS9nUR7U5 SSS5 gg![a Sn GNf=f![a3n U R[R:wa UbU"5 Sn A GNSn A ff=f!,(df  g=f![$R8a/n[R:"[<R>"U55eSnAff=f) aJcopy a file, preserving mode and optionally other stat info like atime/mtime checkambig argument is used with filestat, and is useful only if destination file is guarded by any lock (e.g. repo.lock or repo.wlock). copystat and checkambig should be exclusive. nb_bytes: if set only copy the first `nb_bytes` of the source file. NFz7the `nb_bytes` argument is incompatible with `hardlink`z"cannot use `nb_bytes` on a symlinkrzr+)r) r,rlexistsr)frompathunlink getfstypedirnameOSError_hardlinkfswhitelistoslinkrr!errnoEEXISTislinksymlinkreadlinkshutilcopyfilecopystatcopymoderisambigST_MTIMEutimeopenrErrorrVr forcebytestr)rDrhardlinkr, checkambignb_bytesno_hardlink_cbcheck_fs_hardlinkoldstatfstyperexcnewstatadvancedr,insts r0r+r+s/*Z( (G wwt  T(a#T(a [S5O [S5Tlgg)Nslinkingscopying)rWtopic)r4progresssr0settopiccopyfiles..settopics .6Qz]AjMHN r2NFr)r,risdirrst_devr!mkdirlistdirr copyfilesr$r"r%r&r*r; increment) rDdstr4rBnumrCr$kindsrcnamedstnamer"r;s `` r0rIrIs CJ ww}}S   ##rwwrwws/C'D'K'KK     !#,JDggll3-Gggll3-G#GhIKHa HC '6 S=+  ,-4477277??3/0778    &s  KK ! q     S= &99 ,$H C%%  &s% G'' H116H,,H1>auxconnulprncom1com2com3com4com5com6com7com8com9lpt1lpt2lpt3lpt4lpt5lpt6lpt7lpt8lpt9s:*?"<>|c\URS5(a [S5$SU;a [S5$URSS5RS5HnU(dM [ U5HTnU[ ;a[S5U-s s $[ U5S::dM0[S5[R"U5-s s $ URS 5S nU(a(UR5[;a[S5U-s $US S nUS ;dMUS;dM[S5U-s $ g )aCheck that the base-relative path is a valid filename on Windows. Returns None if the path is ok, or a UI string describing the problem. >>> checkwinfilename(b"just/a/normal/path") >>> checkwinfilename(b"foo/bar/con.xml") "filename contains 'con', which is reserved on Windows" >>> checkwinfilename(b"foo/con.xml/bar") "filename contains 'con', which is reserved on Windows" >>> checkwinfilename(b"foo/bar/xml.con") >>> checkwinfilename(b"foo/bar/AUX/bla.txt") "filename contains 'AUX', which is reserved on Windows" >>> checkwinfilename(b"foo/bar/bla:.txt") "filename contains ':', which is reserved on Windows" >>> checkwinfilename(b"foo/bar/b\07la.txt") "filename contains '\\x07', which is invalid on Windows" >>> checkwinfilename(b"foo/bar/bla ") "filename ends with ' ', which is not allowed on Windows" >>> checkwinfilename(b"../bar") >>> checkwinfilename(b"foo\\") "filename ends with '\\', which is invalid on Windows" >>> checkwinfilename(b"foo\\/bar") "directory name ends with '\\', which is invalid on Windows" \s3filename ends with '\', which is invalid on Windowss\/s9directory name ends with '\', which is invalid on Windowsrs4filename contains '%s', which is reserved on Windowss3filename contains '%s', which is invalid on WindowsrrrNs. rs8filename ends with '%s', which is not allowed on Windows) endswithrWreplacer_filenamebytestr_winreservedcharsordrrlower_winreservednames)rr"cbasets r0checkwinfilenamers_s-0 }}UHII ~NOO \\% & , ,T 2 !!$A%%& 1v|J((+,,%wwt}Q DJJL$55IJ  bcF :!5."  13r2 perf_counterc[R"X5$![a)nUR[R:XaeSnAOSnAf[ a Of=f[R [R-[R-[[SS5-n[R"X5n[R"X@5 [R"U5 g![R"U5 f=f)zCreate a lock file atomically if possible This may leave a stale lock file if symlink isn't supported and signal interrupt is enabled. NO_BINARYr) r,r(r"r%r&AttributeErrorO_CREATO_WRONLYO_EXCLrr1rr)infopathnamewhyrlds r0makelockrs  zz$))  99 $  %     JJ $ryy 072z13M ME  !B    s& AA AA4C!!C9c*[U5$![a9nUR[R[R4;aeSnAOSnAf[ a Of=f[ US5nUR5sSSS5 $!,(df  g=f)Nrb)r)r"r%EINVALENOSYSrw posixfiler)r|r}rs r0readlockrso !!  99U\\5<<8 8  9    8U #rwwy $ # #s& A/A  AA*B Bc[R"UR55$![a# [R"UR 5s$f=f)z1stat file object that may not have fileno method.)r,rrrwrr$rs r0rrs> xx $$  wwrww s#&*AAc`[R"U5n[RRU5up#UR 5nX4:XaUR 5nX4:Xag[RR X$5n[R"U5nXa:Xagg![a gf=f)z Return true if the given path is on a case-sensitive filesystem Requires a path (like /foo/.hg) ending with a foldable final directory component. TF)r,lstatrrupperrnrr")rs1drb2p2s2s r0fscasesensitivers $B 77== DA Bw WWY 7 a B XXb\ 8 sB B-,B-cU$r`r5rs r0rrsqr2cD[c[R5 [$)z0return True is re2 is available, False otherwise)_re2_re _checkre2r5r2r0has_re2rs |  Kr2c>\rSrSr\S5rSSjr\S5rSr g)ri c[bgSnSn[[R"X55q[R"5nSUl Uq g![a SqN.[ a^ [ R"U5n[ R"U5n[[R"X55q[ RqNf=f![a gf=f)Ns \[([^\[]+)\]s[ui]F) rrre2rrrrrD _re2_inputOptions log_errors _re2_optionsrw) check_pattern check_inputquiets r0r _re._checkre2 s   (   ) -=>D KKME$E  L D )%OOM:M"//+6K -=>D!J  )   s)A C CA$CC CCc[cUR5 [(aU[R[R-)-S:XaU[R-(aSU-nU[R-(aSU-n[ U5n[ b[R"U[ S9nU$[R"U5nU$[R"X5$![Ra N,f=f)zCompile a regular expression, using re2 if possible For best performance, use only re2-compatible regexp features. The only flags from the re module that are re2-compatible are IGNORECASE and MULTILINE.rs(?i)s(?m))options) rrr IGNORECASE MULTILINErrrcompiler)rYpatr input_regexcompileds r0r _re.compile s < NN  4Uu//%//ABBqHu'''mu&m (o +"{{; MH  #{{;7H}}S((99  s,C"4C""C98C9c[cUR5 [(a[R$[R$)zReturn the version of escape corresponding to self.compile. This is imperfect because whether re2 or re is used for a particular function depends on the flags, etc, but it's the best we can do. )rrrescaperrls r0r _re.escape7 s, < NN  4:: << r2r5Nr) rtrurvrwryrrrrrzr5r2r0rr s-:)0    r2rcSn[Rn[R(aU[R-nURSS5 [R "SX34-5n[ RRU5n/nURU5HupxU(aURU5 MU[;aU"U5[U'[Un U RU5n U (d"U"U5=[U'n U RU5n URU =(d U5 [ RRXW5nM SRU5$)a Get name in the case stored in the filesystem The name should be relative to root, and be normcase-ed for efficiency. Note that this function is unnecessary, and should not be called, for case-sensitive filesystems (simply because it's expensive). The root should be normcase-ed, too. cn[R"U5Vs0sHn[U5U_M sn$s snfr`)r,rHnormcase)dirr"s r0_makefspathcacheentry%fspath.._makefspathcacheentryW s*(* 381 Q888s2rgs\\s([^%s]+)|([%s]+)r2)rrosaltseprjrrr,rnormpathfindallr _fspathcacherr) r$rrsepspatternrrpartsepcontentsfounds r0fspathrL s9 >>Dh'''LL mm0D<?@G ''  4 C F__T*   MM#   l " 5c :L $ T",A+E EL LL&E emt$ggll3%#+& 88F r2c"Supn[R"S[RR U5-S[RR U5S9upA[R "U5 SUSS-n[X5 [U5n[U5S:UbUR 5 X4HnUb[R"U5 MM! $![a M1f=f![aM UbUR 5 X4H0nUb[R"U5 MM!![a M.f=f g f=f!UbUR 5 X4H0nUb[R"U5 MM!![a M.f=f f=f) z5check whether hardlink count reporting works properly)NNN.%s-s1~prefixsuffixrs%s2~NrF) rmkstempr,rbasenamer!rr$rnlinksrr")testfilef1f2rrr,s r0 checknlinkrx st "JBB!!RWW--h77)   r#2w rr]bzA~ > HHJA =IIaL!    > HHJA =IIaL!     > HHJA =IIaL!   slBC(7C C%$C%( D?2E D** D87D8>D??EFE:6F: F FF Fc[UR[R5=(d6 [R=(a UR[R55$)z)Check path ends with os.sep or os.altsep.)rrirrrrs r0 endswithsepr sD  hnn% -    - MM(++ , r2c@UR[R5$)zSplit path by os.sep. Note that this function does not use os.altsep because this is an alternative of simple "xxx.split(os.sep)". It is recommended to use os.path.normpath() before using this function if need.)rrrrs r0rr s ::hnn %%r2c[RRU5upE[R"SU-SUS9upg[R "U5 [ XX#5 U(aU$[US5n[US5n [U5Hn U RU 5 M UR 5 U R 5 U$![aCn U R[R:XaUsSn A $[U SS5(dX l eSn A ff=f! [R"U5 e![a ef=f=f)aCreate a temporary file with the same contents from name The permission bits are copied from the original file. If the temporary file is going to be truncated immediately, you can use emptyok=True as an optimization. Returns the name of the temporary file. r~rrNfilenameswb)r,rrrrrr-rr"r%ENOENTrr filechunkiterrr) r$emptyok createmodeenforcewritablerrArtempifpr>ofprs r0 mktempcopyr s GGMM$ EAw|DaHHBHHRL T5  D%(Ce$"3'E IIe (   K# zzU\\) 4T22 $     IIdO     sa* C6AD DD0D1D6DDDED10E1 D>;E=D>>Ec\rSrSrSrS Sjr\S Sj5r\SSj5r\ Rr SSjr SSjr SSjr SS jrS rg )r)i zhelp to exactly detect change of a file 'stat' attribute is result of 'os.stat()' if specified 'path' exists. Otherwise, it is None. This can avoid preparative 'exists()' examination on client side of this class. cXlgr`r)rYrs r0r]filestat.__init__ s r2cd[R"U5nU"U5$![a SnNf=fr`)r,rFileNotFoundError)rrrs r0rfilestat.frompath s6 774=D4y! D s  //cZ[R"UR55nU"U5$r`)r,rr)rrrs r0fromfpfilestat.fromfp s xx $4yr2cURRURR:H=(a} UR[RUR[R:H=(a; UR[RUR[R:H$![a Of=fURSL=(a URSL$![a gf=fr)rrST_CTIMEr/rwrYolds r0__eq__filestat.__eq__ s   !!SXX%5%55HIIdmm,0GGHIIdmm,0GG      99$9T)9 9  s$B0B33 C?C"C'' C43C4cUR[RUR[R:H$![a gf=f)agExamine whether new (= self) stat is ambiguous against old one "S[N]" below means stat of a file at N-th change: - S[n-1].ctime < S[n].ctime: can detect change of a file - S[n-1].ctime == S[n].ctime - S[n-1].ctime < S[n].mtime: means natural advancing (*1) - S[n-1].ctime == S[n].mtime: is ambiguous (*2) - S[n-1].ctime > S[n].mtime: never occurs naturally (don't care) - S[n-1].ctime > S[n].ctime: never occurs naturally (don't care) Case (*2) above means that a file was changed twice or more at same time in sec (= S[n-1].ctime), and comparison of timestamp is ambiguous. Base idea to avoid such ambiguity is "advance mtime 1 sec, if timestamp is ambiguous". But advancing mtime only in case (*2) doesn't work as expected, because naturally advanced S[n].mtime in case (*1) might be equal to manually advanced S[n-1 or earlier].mtime. Therefore, all "S[n-1].ctime == S[n].ctime" cases should be treated as ambiguous regardless of mtime, to avoid overlooking by confliction between such mtime. Advancing mtime "if isambig(oldstat)" ensures "S[n-1].mtime != S[n].mtime", even if size of a file isn't changed. F)rrrwrs r0r.filestat.isambig s>< 99T]]+sxx /FF F  s:= A  A cUR[RS-S-n[R"XU45 g![a gf=f)aChange file stat of specified path to avoid ambiguity 'old' should be previous filestat of 'path'. This skips avoiding ambiguity, if a process doesn't have appropriate privileges for 'path'. This returns False in this case. Otherwise, this returns True, as "ambiguity is avoided". rrFT)rr/r,r0PermissionError)rYrrr=s r0 avoidambigfilestat.avoidambig) sQHHT]]+a/:=  HHTh/ 0    s> A  A c X:X+$r`r5)rYothers r0__ne__filestat.__ne__= s   r2rN)rrrr)rType[_Tfilestat]rbytesrr()rrrrrr(r)rr(rr)rrrr(rr)rtrurvrwrxr] classmethodrrr__hash__rr.rrrzr5r2r0r)r) sTH"!F(!r2c@\rSrSrSrS SjrSrSrSrSr S r S r g) atomictempfileiA awritable file object that atomically updates a file All writes will go to a temporary copy of the original file. Call close() when you are done writing, and atomictempfile will rename the temporary copy to the original name, making the changes visible. If the object is destroyed without being closed, all your writes are discarded. checkambig argument of constructor is used with filestat, and is useful only if target file is guarded by any lock (e.g. repo.lock or repo.wlock). NcXl[USU;USU;S9Ul[URU5UlX@lURR UlURRUlURRUlURRUl URRUl URRUl g)Nw)rrr) _atomictempfile__namer _tempnamer_fp _checkambigrrr!rrr)rYr$rrr5s r0r]atomictempfile.__init__O s # T\!!T\  T^^T2%HHMM XX^^ ((--HHMM HHMM hhoo r2cDURR(GdURR5 [UR5nUR =(a [ RU5nU(aUR(a~[URU5 [ RU5nURU5(a<UR[RS-S-n[R"XU45 gg[URU5 gg)Nrr)rrrrrrr)rrrenamerr.r/r,r0)rYrr9r<r=s r0ratomictempfile.closec sxx HHNN  -H&&F8+<+ z*  D % % yyELL(   sE ( DDA D6 C C=C8.D7C88C==DDcp[US5nUR5sSSS5 $!,(df  g=f)Nrb)r1r)rrs r0readfiler& s# dD Rwwy   s' 5cr[US5nURU5 SSS5 g!,(df  g=f)Nwbr1rrtextrs r0 writefiler, % dD R    ( 6cr[US5nURU5 SSS5 g!,(df  g=f)Nabr)r*s r0 appendfiler1 r-r.c8\rSrSrSrSrSrS SjrS SjrSr g) chunkbufferi zkAllow arbitrary sized chunks of data to be efficiently read from an iterator over chunks of arbitrary size.ctSnU"U5Ul[R"5UlSUlSUlg)z?in_iter is the iterator that's iterating over the input chunks.c3# UHIn[U5S:a3SnU[U5:a US-nXUv UnU[U5:aMMCMEUv MK g7f)Nrr)chunksrposends r0splitbig&chunkbuffer.__init__..splitbig s\u:%CE *!Ek#n,!E **  K s AA ArN)rkrr_queue _chunkoffset_absolute_offset)rYin_iterr<s r0r]chunkbuffer.__init__ s5 W% !'')  !r2c## UR(axURR5nUR(aXRSnOUnU=R[ U5- slUv SUlUR(aMxUR H%nU=R[ U5- slUv M' g7fr4)r>rr?r@rrk)rYrrs r0rmchunkbuffer.__iter__ skkKK'')E  ++-.  ! !SV + !G !D kkkA  ! !SV + !Gs BC 6CcUR$)z&tell how much data we have read so far)r@rls r0rchunkbuffer.tell s$$$r2NcUc;SRUR5nU=R[U5- slU$Un/nURnUS:GaU(dDSnURH*nUR U5 U[U5-nUS::dM* O U(dOUSn[U5nUR n U S:Xa,X8:a'X8-nUR5 UR U5 MX- n X::a/X:-nUR5 UR XyS5 SUlO.UR XyX-5 U=R U- slX:-nUS:aGMSRU5nU=R[U5- slU$)zRead L bytes of data from the iterator of chunks of data. Returns less than L bytes if the iterator runs dry. If size parameter is omitted, read everythingNr2rr7)rrkr@rr>rr?r) rYlrleftrqueuetargetrchunklrchunkremainings r0rchunkbuffer.read sx 9#A  ! !SV + !H Qh!YYELL'c%j(F{ ' !HEZF&&F{t~  5!#_N%&  5>*$%! 5&-89!!T)!&[Qh^ HHSM Q'r2)r@r?r>rk)rr r`) rtrurvrwrxr]rmrrrzr5r2r0r3r3 s/"& %>r2r3ic## US:deUbUS:deUcUnO [X!5nU=(a URU5nU(dgU(aU[U5-nUv MN7f)aECreate a generator that produces the data in the file size (default 131072) bytes at a time, up to optional limit (default is to read all data). Chunks may be less than size bytes if the chunk is the last chunk in the file, or the file is a socket or some other type of file that sometimes reads less data than is requested.rN)rrr)r,rrnbytesr[s r0rrG sm 199 =EQJ& &  =F%F  %qvvf~   SVOE sA#A%c.\rSrSrSrSrSSjrSrSrg) cappedreaderi] aA file object proxy that allows reading up to N bytes. Given a source file object, instances of this type allow reading up to N bytes from that source file object. Attempts to read past the allowed limit are treated as EOF. It is assumed that I/O is not performed on the original file object in addition to I/O that is performed by this instance. If there is, state tracking will get out of sync and unexpected results will ensue. cXlX lg)z,Allow reading up to bytes from .Nr~_left)rYrrs r0r]cappedreader.__init__i s  r2c UR(dgUS:a URnURR[XR55nU=R[ U5-slURS:deU$)Nr2r)rUr~rrr)rYr"rbs r0rcappedreader.readn s^zz q5 Axx}}SJJ/0 c$i zzQ r2cnUR[U55nUcgX!S[U5&[U5$r4)rr)rYrr@s r0rcappedreader.readinto{ s2iiA ;!c#h3xr2rTNr) rtrurvrwrxr]rrrzr5r2r0rRrR] s  r2rRc^U4SjnU$)z@return a function that renders a readable count of some quantitycx>TH)upn[U5X!-:dMX0[U5- -s $ TSSU-$)Nrr)absfloat)count multiplierdivisorformat unittables r0gounitcountfn..go sI+4 'J5zW11w!788,5}Q%''r2r5)rcrds` r0 unitcountfnrf s( Ir2cX- S:a[R"[S55eUS:a[R"[S55eUS- U4$)aZCheck that linerange : makes sense and return a 0-based range. >>> processlinerange(10, 20) (9, 20) >>> processlinerange(2, 1) Traceback (most recent call last): ... ParseError: line range must be positive >>> processlinerange(0, 5) Traceback (most recent call last): ... ParseError: fromline must be strictly positive rsline range must be positivers"fromline must be strictly positive)r ParseErrorrW)fromlinetolines r0processlinerangerk sS1q!?@AA!|q!FGHH a< r2d@s%.0f GB s%.1f GBs%.2f GBr6s%.0f MBs%.1f MBs%.2f MBs%.0f KBs%.1f KBs%.2f KBs %.0f bytesc@\rSrSrSrS SjrS SjrS SjrS SjrSr g) transformingwriteri z3Writable file wrapper to transform data by functioncXlX lgr`)r_encode)rYrrs r0r]transformingwriter.__init__ s  r2c8URR5 gr`)rrrls r0rtransformingwriter.close  r2c8URR5 gr`)rrHrls r0rHtransformingwriter.flush rvr2cVURRURU55$r`)rrrr)rYrbs r0rtransformingwriter.write sxx~~dll4011r2)rrrN)rrrzCallable[[bytes], bytes]rrr)rbrrr ) rtrurvrwrxr]rrHrrzr5r2r0rprp s=2r2rps\r*\nc.[RSU5$)Nr_eolresubr[s r0tolfr s ::eQ r2c.[RSU5$)N r|rs r0tocrlfr s ::gq !!r2c"[U[5$r`)rprrs r0 _crlfwriterr s b& ))r2rc[er`NotImplementedErrorrs r0 tonativeeolr !!r2c[er`rrs r0 fromnativeeolr rr2c[er`rrs r0nativeeolwriterr rr2cU$r`r5rs r0iterfiler s Ir2c#R# UHnUR5ShvN M gN 7fr`)r)iteratorrs r0 iterlinesr s$##%%%%s '% 'cz[RR[RRU55$r`)r,r expanduser expandvarsrs r0 expandpathr s& 77  bgg006 77r2c^^T=(d SmSRTR55nU(a$USU-- n[U5S:aUSSnOUnUTU'[R"SX4-5nUR UU4SjU5$)aReturn the result of interpolating items in the mapping into string s. prefix is a single character string, or a two character string with a backslash as the first character if the prefix needs to be escaped in a regular expression. fn is an optional function that will be applied to the replacement text just before replacement. escape_prefix is an optional flag that allows using doubled prefix for its escaping. cU$r`r5rs r0rinterpolate.. s!r2|rNs%s(%s)c<>T"TUR5SS5$)Nr)r)rrAmappings r0rr s2gaggim45r2)rrrrrr~)rrr[rA escape_prefixpatterns prefix_charrs ` ` r0 interpolater s  Byy(HD6M! v;? *K K*  jF#556A 555q 99r2g@@s%.0f ss%.1f ss%.2f ss%.3f sgMbP?s%.1f mss%.2f mss%.3f msgư>s%.1f uss%.2f uss%.3f usg& .>s%.1f nss%.2f nss%.3f nsc\rSrSrSr\R "\R"S5S9r\R "SS9r \R "SS9r Sr \ R"\ 5rSrg ) timedcmstatsi) zFStats information produced by the timedcm context manager on entering.c[5$r`)timerr5r2r0rtimedcmstats./ sr2)r:rrcRUR(a[UR5$S$)Ns )elapsed timecountrls r0 __bytes__timedcmstats.__bytes__6 s*.,,y&HLHr2r5N)rtrurvrwrxribFactorystartrr rr strmethod__str__rzr5r2r0rr) sTP GGDLL9 :Egga G GGA EI  +Gr2rc'# [=RS- sl[[RS9n[R"U/UQ76 Uv SSS5 [ 5UR - Ul[=RS-slg!,(df  ND=f![ 5UR - Ul[=RS-slf=f7f)zA context manager that produces timing information for a given context. On entering a timedcmstats instance is produced. This context manager is reentrant. r)r N)timedcm_nestedrrlogrrr) whencefmt whenceargs timing_statss r0rr< s OOqOgoo6L [[ 0Z 0 1 %w););; 1 1 0 %w););; 1s41CB BB6C BB7CCc^U4SjnU$)zReport the execution time of a function call to stderr. During development, use as a decorator when you need to measure the cost of a function, e.g. as follows: @util.timed def foo(a, b, c): pass cH>[[R"TR55nT"U0UD6nSSS5 [R nUR SSWR-S-[R"TR5U4-5 W$!,(df  Ne=f)Ns %s%s: %s  r)rrbytestrrtrrGrr )rr time_statsrrGr*s r0rtimed..wrapper^ s X%%dmm4 54*6*F6 z'''!+  /   6 5s B B!r5rs` r0timedrS s  Nr2))mr6)kr)grm)skbr)smbr6)sgbrm)brc LUR5R5n[HAup#URU5(dM[ [ US[ U5*5U-5s $ [ U5$![a# [R"[S5U-5ef=f)z~Convert a space specifier to a byte count. >>> sizetoint(b'30') 30 >>> sizetoint(b'2.2kb') 2252 >>> sizetoint(b'6M') 6291456 Nscouldn't parse size: %s) striprn _sizeunitsrir r^rrrrhrW)r[rrr\us r0 sizetointrz s  ABDAzz!}}59c!fW.2331v Bq!;*r2cURRSS9 /nURHup4URU"U65 M U$)Nc US$r4r5rs r0r hooks.__call__.. sqtr2)rg)rsortr)rYrresultsrrs r0__call__hooks.__call__ sA ^, KKLF NN4; '(r2rN)rrrrrr)rr ) rtrurvrwrxr]rrrzr5r2r0rr s,+r2rc #^# [R"5SU*S- VVVVs/sH7upEpgU[R"U5U4-[R"U54PM9 snnnnU*SnU(a1[ SU55n UHupUcXU4v MXX4-v M ggs snnnnf7f)aYields lines for a nicely formatted stacktrace. Skips the 'skip' last entries, then return the last 'depth' entries. Each file+linenumber is formatted according to fileline. Each line is formatted according to line. If line is None, it yields: length of longest filepath+line number, filepath+linenumber, function Not be used in production code but very convenient while developing. Nrc3># UHn[US5v M g7frNr8).0entrys r0 !getstackframes.. s7weCaMMws)r extract_stackrsysbytesr) skiprfileliner rAlnr*_textentriesfnmaxfnlns r0getstackframesr s$-#:#:#<[uqy#I#I BD X&&r*B/ /1B1B41HI#I fgG7w77!JD|D))T000 " s"B->B% "A B-s stacktracer2cU(aUR5 URSXPR54-5 [US-US9HnURXV-5 M UR5 g)aCWrites a message to f (stderr) with a nicely formatted stacktrace. Skips the 'skip' entries closest to the call, then show 'depth' entries. By default it will flush stdout first. It can be used everywhere and intentionally does not require an ui object. Not be used in production code but very convenient while developing. s %s%s at: r)r N)rHrrstripr)rIrr,otherfr rrs r0debugstacktracer sV GGMVZZ\2 23taxu5  6GGIr2cUc [5nSX4-nXB;aXC;aU$[R"S5HnSXU4-nXB;dMXC;dMUs $ g)a Generate a name that it is safe to rename f to in the given context. f: filename to rename tag: a string tag that will be included in the new name ctx: a context, in which the new name must not exist others: a set of other filenames that the new name must not be in Returns a file name of the form oldname~tag[~number] which does not exist in the provided context and is not in the set of other names. Ns%s~%srs%s~%s~%s)set itertoolsr_)r,tagctxothersrAr"s r0safenamer s[~ QH B }) __Q  AA; & =R-I r2cURU5n[U5U:a-[R"[ S5[U5U4-5eU$)z=read n bytes from stream.read and abort if less was availables5stream ended unexpectedly (got %d bytes, expected %d))rrrrVrW)streamr"r[s r0 readexactlyr sK AA 1vzkk F G1vqk    Hr2cHUS:a[R"SU-5eUS-nUS-n/nU(a;UR[R"SU-55 US-nUS-nU(aM;UR[R"U55 SR U5$)aEncode an unsigned integer value to a varint. A varint is a variable length integer of 1 or more bytes. Each byte except the last has the most significant bit set. The lower 7 bits of each byte store the 2's complement representation, least significant group first. >>> uvarintencode(0) '\x00' >>> uvarintencode(1) '\x01' >>> uvarintencode(127) '\x7f' >>> uvarintencode(1337) '\xb9\n' >>> uvarintencode(65536) '\x80\x80\x04' >>> uvarintencode(-1) Traceback (most recent call last): ... ProgrammingError: negative value for uvarint: -1 rsnegative value for uvarint: %dr2)rr!rrbytechrr)r8r7rs r0 uvarintencoder s. qy$$%F%NOO 4>> from io import BytesIO >>> uvarintdecodestream(BytesIO(b'\x00')) 0 >>> uvarintdecodestream(BytesIO(b'\x01')) 1 >>> uvarintdecodestream(BytesIO(b'\x7f')) 127 >>> uvarintdecodestream(BytesIO(b'\xb9\n')) 1337 >>> uvarintdecodestream(BytesIO(b'\x80\x80\x04')) 65536 >>> uvarintdecodestream(BytesIO(b'\x80')) Traceback (most recent call last): ... Abort: stream ended unexpectedly (got 0 bytes, expected 1) rrrrr)rmr)rrshiftbytes r0uvarintdecodestreamr sM*F E ;r1%&$;5((t M   r2c## [R"[RS5nUS:XaQ[R"[RS5 Sv [R"[RU5 gSv g![Ra NEf=f![R"[RU5 f=f7f)NCr;)locale setlocaleLC_CTYPEr2)oldlocs r0 with_lc_ctyper F s   foot 4F } 6   "5    V__f 5 <<     V__f 5s:,C%BB+CBBBB'CCc^^ [RRS5(adSSKJmJm SSKJnJnJ nJ n "UU 4SjSU5nU"5nU"U5Ul URRU"U55 UR$[R "[R"S5n[R "[R"S5nXg-$![$a g [&a g f=f) z}Provide an estimate for the available system memory in Bytes. If no estimate can be provided on the platform, returns None. swinr)c_long c_ulonglong) Structurebyrefsizeofwindllc b>\rSrSrSY4SY4SY4SY4SY4SY4SY4S Y4S Y4/ rS rg ) '_estimatememory..MEMORYSTATUSEXih dwLength dwMemoryLoad ullTotalPhys ullAvailPhysullTotalPageFileullAvailPageFileullTotalVirtualullAvailVirtualullExtendedVirtualr5N)rtrurvrw_fields_rz)DWORD DWORDLONGsr0MEMORYSTATUSEXrh sRU#'++#Y/#Y/"I."I.%y1 Hr2r SC_PAGE_SIZE SC_PHYS_PAGESN)r sysplatform startswithctypesr r ctypes.wintypesr rrrrkernel32GlobalMemoryStatusExrr,sysconf sysconf_namesr"r) r rrrrrpagesizepagesrrs @@r0_estimatememoryr,X s &&v.. E    Y   AY ,,U1X6~~  ::b..~>? 2++O<=      s AC C6* C65C6)r/r rr)rrrrr )Nrr`)ri)rr)rrrrrrrr)FFFNNTr )rrrzOptional[bytes])r{rr|rrr)r|rrr)rrrr)r$rrrrr)rrrr)rrrz List[bytes])FNF) r$rrrr Optional[int]rrrr)FT)r,rrrrrrr)r,rrrr)r$rrr-r!rrr)rrrr)rrr+rrr)rir rjr rzTuple[int, int])r[rrr)rtypelib.BinaryIO_Proxyrr.)rzIterable[bytes]rzIterator[bytes])r[rrr )rs %-*s in %s s%s:%dr)rr-(rx __future__rrdr contextlibr%rhashlibiorrrr,picklererr*rrFtimertypingrBrrrrrr r r r r rr thirdpartyr TYPE_CHECKINGhgdemandimportrr;rrrrrrr interfacesrint_miscrintmodutilsrrrrtyping_extensionsrr importmodr#rr$ b85decode b85encode cookielibhttplib safehasattr socketserverBytesIObytesiostringio xmlrpclib httpserverurlerrurlreqrrkr+r%r.r&rWrbindunixsocket cachestat checkexec checklinkr- expandglobsgetfsmountpointr  get_password groupmembers groupnameisexecisownerrHr lookupregrrrr normcasespecnormcasefallback openhardlinksr$parsepatchoutputrpollrr)rr samedevicesamefilesamestatsetflagsrrr' statisexec statislinkr-rusernamer(r1 compengines SERVERROLE CLIENTROLErrsr9renvironrrAfilterwarningsrErLmd5sha1sha512rUrpr\rQr|r NameErrorrrrrrrrrrrrrrrrJr'r4r! OrderedDictr?rrNrQABCrScontextmanagerrirlrnryrrrrrrrrrrLrr r#r+rIrorlrsrcheckosfilenameclockrrrrrrrrrrrrrrrrrr)rrrrrr&r,r1r3DEFAULT_FILE_CHUNKrrRrfrk bytecountBinaryIO_Proxyrprr}rrr oslineseprrridentityrrrrrr[rrrrrrIHooksrrrGstdoutrrKrrrrr r,r5r2r0rzsH  #          "      G5 )E((2 2   ( #            "" $$ **      $ $      ## %#FF   ((            "" **    $$ $$        ..                $$ ,,&& ,,   }}                   FK);); <        Z8J)%%  # #  # #  ( x##$56 7  Ir+={K Ir+=wG Ir+=zJ  , 2K +-? &   KK ]]~~  3 A << --`""J ! F kk\ +\o o d' 1'T  x x v""Ja*aJIM ) D &D V    %0TJn >,${&&$Nc46#xCGG2 $ 0ccL  > ( (B%&  ??? D?6 (  M=`*Z0:z nd+ &O  ..O  ,  0   D D D N U )XB& $! - - -- -  -`c!c!LDDN:>   ! 26    AF $9= >   ggT#-D,$$N  , '1Z=!!J- :'1Z=!!J- :'1Z=!!J- :1]   2//2( y ! "*  KM!O##K%%M''O  """ & 8:4 Qy\!Qy\AiL1Y<%:* q}(AjM"1Z=!!J- +q}%a m$ Qz]#  ",,,$ &8 B(HOO&14  oo ??  .0 "JT ", y_!!!r< Ds$7h$!h6$ h32h36ii