6hY^SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK J r SSK Jr SSKJrJrJrJrJr SSKJr \R."S5r\R2(aSS KJr OSS KJr S r"S S \R<5r"SS5r \RBRE\ 5 Sr#Sr$"SS\RJ5r&\RNRE\&5 Sr(\RRc\"5r)O\RRRTr)\RVc\"5r+O\("\RVRT5r+\RXc\"5r,O\("\RXRT5r,\R2(a$\RZ"\+5r+\RZ"\,5r,\"\+5(a\R\S:wa\#"\+5r+\R^r/\R`r1\Rdr2\Rfr3\Rhr4\Rjr5\Rlr6\Rnr7\Rpr8\Rrr9\Rtr:\Rvr;\Rxr<\Rzr=\R~r?\R=(a \R\S:grASrB"SS5rCS7SjrDSrESrFS8SjrGS8SjrHS9SjrISrJS rK\K\JS!.rLS"rMSqNS#rOS$rPS%rQS&rRS'rSS(rTS)rUS8S*jrV\R2(aS+rW\RrYOS,rW\RrYS-r[S:S.jr\Sq]S/r^S0r_S1r`S;S2jra\RS35rc\R2(aS4rd\d\R-rfSa GNf=f!\>a GNf=f)=) annotationsN)BinaryIO_)encodingerrorpolicypycompattypelib) resourceutilosutil)windows)posixcDUR5$![a gf=f)NF)isattyAttributeError)fps :/usr/lib/python3/dist-packages/mercurial/utils/procutil.pyrr/s%yy{ s  c$\rSrSrSrSrSrSrg)BadFile6z3Dummy file object to simulate closed stdio behaviorc6[[RS5eNzBad file descriptorOSErrorerrnoEBADFselfbs rreadintoBadFile.readinto9ekk#899c6[[RS5errrs rwrite BadFile.write<r$r%N)__name__ __module__ __qualname____firstlineno____doc__r"r'__static_attributes__r)r%rrr6s=::r%rc&\rSrSrSrSrSrSrg)LineBufferedWrapper@cXlgNorigr r6s r__init__LineBufferedWrapper.__init__A r%c.[URU5$r4getattrr6r attrs r __getattr__LineBufferedWrapper.__getattr__Dtyy$''r%cURnURU5nURS5(aUR5 U$)N )r6r'endswithflush)r sr6ress rr'LineBufferedWrapper.writeGs5yyjjm ::e   JJL r%r5Nr*r+r,r-r8r@r'r/r)r%rr1r1@s(r%r1cUn[U[5(a URnOB[R(a,[U[ R 5(a URnOOMf[U[R5(aU$[U[R5(aO [S5e[U[5(aU$[U5$)Nz1can't determine whether stream is buffered or not) isinstanceWriteAllWrapperr6r iswindowsplatform winstdoutrio RawIOBaseBufferedIOBaseNotImplementedErrorr1)stream check_streams rmake_line_bufferedrWTsL  lO 4 4',,L   J    % % (??L  , -- L""3"3 4 4 ! ?  &-.. v &&r%c[U[5(a-[UR[5(aeUR$U$r4)rLr1r6rUs runwrap_line_bufferedrZts7&-..fkk+>????{{ Mr%c*\rSrSrSSjrSrSrSrg)rM{cXlgr4r5r7s rr8WriteAllWrapper.__init__|r:r%c.[URU5$r4r<r>s rr@WriteAllWrapper.__getattr__rBr%cURRn[U5n[U5nSnXT:aU"X5S5nU(aXV- nXT:aMU$)Nr)r6r' memoryviewlen)r rGwrite1mtotal_to_write total_writtencs rr'WriteAllWrapper.writesV qMQ ,q()A" ,r%r5N)r6rrJr)r%rrMrM{s( r%rMc[U[5(aU$[U[R5(aU$[U5$r4)rLrMrQrSrYs r_make_write_allrks;&/** &"++,,  6 ""r%OpenVMScHUS:a[S5U-$[S5U*-$)zlreturn a message describing a subprocess status (codes from kill are negative - not os.system/wait encoding)rsexited with status %dskilled by signal %dr)codes r explainexitros/ qy)*T11 # $u ,,r%c<\rSrSrSrSrSrSrSrSr Sr S r g ) _pfilez;File-like wrapper for a stream opened by subprocess.Popen()cXlX lgr4)_proc_fp)r procrs rr8_pfile.__init__s  r%cjURR5 URR5$r4)ruclosertwaitr s rry _pfile.closes! zz  r%c,[UR5$r4)iterrur{s r__iter___pfile.__iter__sDHH~r%c.[URU5$r4)r=rur>s rr@_pfile.__getattr__stxx&&r%cU$r4r)r{s r __enter___pfile.__enter__s r%c$UR5 gr4)ry)r exc_type exc_valueexc_tbs r__exit___pfile.__exit__s  r%)rurtN) r*r+r,r-r.r8ryrr@rrr/r)r%rrqrqs#E! 'r%rqcxUS:Xa [X5$US:Xa [X5$[R"SU-5e)Nrbswbsunsupported mode: %r) _popenreader _popenwriterr ProgrammingError)cmdmodebufsizes rpopenrs= u}C)) C))  !84!? @@r%c[R"[U5SU[[RS9n[ X"R 5$)NT)shellr close_fdsstdout) subprocessPopen tonativestrclosefdsPIPErqrrrps rrrs;C  A !XX r%c[R"[U5SU[[RS9n[ X"R 5$)NT)rrrstdin)rrrrrrqrrs rrrs;Coo  A !WW r%c [R"[U5SS[[R[R[ U5S9nUR UR4$)NT)rrrrrenv)rrrrr tonativeenvrr)rrrs rpopen2rsP Coo   A 77AHH r%c&[X5up#pEX#U4$r4)popen4)rrrrstderrrs rpopen3r#s%c/E6 &  r%c [R"[U5SU[[R[R[R[ U5S9nUR URURU4$)NT)rrrrrrr) rrrrrrrrr)rrrrs rrr(s]Coo   A 77AHHahh ))r%c[R"[U5S[[R[RS9nUR U5up4U$)z9filter string S through command CMD, returning its outputT)rrrr)rrrrr communicate)rGrrpoutperrs r pipefilterr6sECoo  Aq!JD Kr%cSup#[R"SS9upB[R"US5nUR U5 SSS5 [R"SS9upc[R "U5 UR SU5nUR SU5n[U5nU(a-[R"[S 5U[U54-5e[US 5nUR5sSSS5 U(a[R"U5 U(a[R"U5 $$!,(df  GN=f![a N>f=f![a $f=f!,(df  O=fU(a[R"U5 O![a Of=fU(a[R"U5 gg![a gf=f!U(a[R"U5 O![a Of=fU(a[R"U5 ff![a ff=f=f) zfilter string S through a pair of temporary files with CMD. CMD is used as a template to create the real command to be run, with the strings INFILE and OUTFILE replaced by the real names of the temporary files generated.)NNs hg-filter-in-)prefixwbNshg-filter-out-sINFILEsOUTFILEscommand '%s' failed: %srb)r mkstemposfdopenr'ryreplacesystemr Abortrroopenreadunlinkr)rGrinnameoutnameinfdroutfdrns r tempfilterrCs !OF''/?@  YYtT "b HHQK#"))1BC kk)V,kk*g.c{ ++,-k$6G0HH '4 B779!   &!  '"+# "$       !   &!     '"     &!     '"   s-G"D?B#G"(E18 G"E E!? E G" EE! E.-E.1 E?;G"F"" F/.F/3G GG"I$HI H IHIH20I2 H?<I>H??I)s tempfile:spipe:c[R5H?up#URU5(dMU"X[U5SR 55s $ [ X5$)zIfilter a string through a command that transforms its input to its outputN) _filtertableitems startswithrclstripr)rGrnamefns rfilterrmsT!&&( >>$  aSY[)0023 3) a r%cZ[Gc[RRSS5n[R Sn[ RS:XaUSSS:XaS USS-nU(a[U5 [$[R"5(aW[[S S5S :Xa"[[RS 5 [$[[ R5 [$[ R(d][RR![US S55S:Xa/[[ R""UR$55 [$[['S5=(d0 [RR![ R(S55 [$)zUreturn location of the 'hg' executable. Defaults to $HG or 'hg' in the search path. NHG__main__rlr$zmcr frozen macosx_appEXECUTABLEPATH__file__hgshg) _hgexecutablerenvirongetsysmodulesr sysplatform_sethgexecutabler mainfrozenr= sysexecutablerNrpathbasenamefsencoderfindexesysargv)rmainmods r hgexecutablerysF     ! !% ,++j)   : -"Qq'S."QR&B R  $ $ & &sHd+|; !1!12C!DE !!7!78 ""  *b!ABdJ X..w/?/?@ A  G"''"2"283C3CA3F"G  r%cUqg)z#set location of the 'hg' executableN)r)rs rrrs Mr%c[USS5nU=(a U"5UR5:H$![Ra gf=f)NfilenoF)r=rrQUnsupportedOperation)fstdfrs r _testfilenorsE Q$ 'F3&(dkkm33 " "s 0AAc6[U[R5$r4)rr __stdin__rs risstdinrs q#-- ((r%c6[U[R5$r4)rr __stdout__rs risstdoutrs q#.. ))r%cUR5 Xp2[U[5(a[R"UR 55n[R "[R[R5n[R"XPR 55 [R"U5 [R"US5n[U[5(ar[R"UR 55n[R"[R 5UR 55 [R"US5nX#4$)aDuplicate streams and redirect original if (uin, uout) are stdio If uin is stdin, it's redirected to /dev/null. If uout is stdout, it's redirected to stderr so the output is still readable. Returns (fin, fout) which point to the original (uin, uout) fds, but may be copy of (uin, uout). The returned streams can be considered "owned" in that print(), exec(), etc. never reach to them. rr)rFrrrduprrdevnullO_RDONLYdup2ryrrr)uinuoutfinfoutnewfdnullfds r protectstdiors JJL3szz|$R[[1  % iit$4  t{{}%  /yy% 9r%cUR5 X 4X144HNupEXELdM [R"UR5UR55 UR 5 MP g)z@Restore (uin, uout) streams from possibly duplicated (fin, fout)N)rFrrrry)rrrrruifs r restorestdiorsHJJL:|, < GGAHHJ - GGI-r%c^Sm[[R5nU(a)URU4SjUR 555 [ 5US'U$)z>return environ with optional override, useful for shelling outcLUbUSLagUSLag[R"U5$)z9convert python object into string that is useful to shellF0T1)r bytestr)vals rpy2shellshellenviron..py2shells+ ;#, $;$$r%c3<># UHupUT"U54v M g7fr4r)).0kvr s r shellenviron..s@Ax{#sr)dictrrupdaterr)rrr s @r shellenvironrsE% x C @ @@CJ Jr%cB[R"U[U55$r4)rO shelltocmdexerrrs r shelltonativers%% c"  r%cU$r4r)rs rrrs r%c8[R"[U5$)zHconvert the environment from bytes to strings suitable for Popen(), etc.)r rapplyr)rs rrrs ??; ,,r%c [R5 [U5nUb[ U5(aI[ R "[U5S[[U5[R"[U5S9nU$[ R"[U5S[[U5[R"[U5[ R[ RS9n[URR S5HnUR#U5 M UR%5 UR&nU$![a GN/f=f)zenhanced shell command execution. run with environment maybe modified, maybe in different dir. if out is specified, it is assumed to be a file-like object that has a write() method. stdout and stderr will be redirected to out.T)rrrcwd)rrrrrrr%)rrF Exceptionrrrcallrrrr rrrSTDOUTr~readliner'rz returncode)rrroutrrcrvlines rrrs    w C {hsmm __  C  S1  * I  C  S1??$$ --s3D IIdO4 __ I3    sD88 EEcd[R(a@S[R;ag[ [ SS5(a[ R 5$g[R=(dE [RRS5=(d [RRS5$)zAre we running in a GUI?sSSH_CONNECTIONFisguiNTsDISPLAYsWAYLAND_DISPLAY) r isdarwinrrr=rr&rNrr)r%r_guir(s  0 0 0 VWd + +<<> !    8##J/ 8##$67 r%c0[c [5q[$r4)_is_guir(r)r%rguir+1s& Nr%c[R"5(a:[[SS5S:Xa[R S/$[ R/$[5$)zReturn the command used to execute current hg This is different from hgexecutable() because on Windows we want to avoid things opening new shell windows like batch files, so we get either the python call or current executable. rNrr) r rr=rrrr r _gethgcmdr)r%rhgcmdr.8sP  3$ '< 7$$%678 8**+ + ;r%c:^[5mU4SjnSn[[SS5nUb[R"XB5n[U5nU"5(dpUT;d[ U5(d6U"5(d*Ub%[R"[R U5 g[ R"S5 U"5(dMpUUb%[R"[R U5 $!Ub%[R"[R U5 f=f)aGExecute the argument list in a detached process. condfn is a callable which is called repeatedly and should return True once the child process is known to have started successfully. At this point, the child process PID is returned. If the child process fails to start or finishes before condfn() evaluates to True, return -1. cN>TR[R"55 gr4)addrrz)signumframe terminateds rhandlerrundetached..handlerZsrwwy!r%NSIGCHLDrg?)setr=signal spawndetachedtestpidr7timesleep)argscondfnr5 prevhandlerr7pidr4s @r rundetachedrBHs J"Kfi.GmmG5  D!((z!vxx  " MM&..+ 6  JJsO((  " MM&..+ 6   " MM&..+ 6 s9C0""C0C00*Dc#^^^# [R"[R5/m/mUUU4Sjn[R"[RU5 Sv T(a([R"[RTS5 T(a[eg![a TS NPf=f!T(a([R"[RTS5 T(a[ef=f7f)zInhibit SIGINT handling on a region of code. Note that if this is called in a non-main thread, it turns into a no-op. Args: warn: A callable which takes no arguments, and returns True if the previous signal handling should be restored. c>T"5(a+[R"[RTS5 TS TRS5 g)NrT)r9SIGINTappend)r>oldsiginthandler shouldbailwarns rdisabledsiginthandler.uninterruptible..disabledsiginthandlers8 66 MM&--)9!)< = #$r%rN)r9 getsignalrE ValueErrorKeyboardInterrupt)rIrJrGrHs` @@runinterruptiblerOss((78J $ $ MM&--)> ?   MM&--)9!)< = # #  $ # $  MM&--)9!)< = # # s:0C1%BB0 =C1 B-*B0,B--B00>C..C1c SnUbG[R"5nURU5 UR5 UR S5 [ R "[R"[U5U[U5S[UUUS9n UbU"U R5 UbUR5 gg!UbUR5 ff=f)z1Spawn a command without waiting for it to finish.NrT)rrr creationflagsrrr) r unnamedtempfiler'rFseekrrrrr_creationflagsrzry) scriptrrrr ensurestart record_wait stdin_bytesrrs r runbgcommandrZs & 002 K(  1    V4$, A&AFF#  !u  !s B B99Cc ^ [R(a [5 U(aUnO0[U[5(aU/nSR SU55nUcSU-nSn OSn SnSn Uc[ Rn OG[R"5n U RU5 U R5 U RS5 Uc[ RnUc[ Rn[ R"USUSU UUU S9m Ub*U b'[U [5(aeU R5 U(d0[ R""U 4S jS 9n SU lU R'5 gT R(n Ub U"U 5 gg![a UbU"S 5 ef=f!Ub,U b([U [5(aeU R5 fff=f) atSpawn a command without waiting for it to finish. When `record_wait` is not None, the spawned process will not be fully detached and the `record_wait` argument will be called with a the `Subprocess.wait` function for the spawned process. This is mostly useful for developers that need to make sure the spawned process finished before a certain point. (eg: writing test) c38# UHn[U5v M g7fr4) shellquote)r xs rrrunbgcommand..s:cz!}}csNs( ( %s ) <&3 3<&- &) 3<&0TFr)rrrrrrstart_new_sessionc>TR$r4)rz)rsrrunbgcommand..s r%)target)r r'r+rLbytesjoinrDEVNULLrSr'rFrTrrintry threadingThreaddaemonstartrz)rrrrrrWrXrYrVrartr!rs @rrZrZs$    E F#u%%eYY:c::F  1F:F $  % K ""** 002 K(  1 ~#++~#++  "3 A&5+<%eS1111    7AAH GGIJ&J''' &C   &5+<%eS1111 ,=&s-BFFF!!1G)rrr4)Nr)NNN)returnrj)FNNTNN)h __future__r contextlibrrQrr9rrrkr<typingri18nrrrr r r r utilsr importmodrrNrrOrrrRrr1rSregisterrWrZBinaryIO_ProxyrMIOBaserkrbufferrrrPrrgethgcmdr-getusergetpid hidewindowreadpipe setbinarysetsignalhandlerr^ shellsplitr:sshargsr; setprocnamer unblocksignalisposixrrorqrrrrrrrrrrrrrrrrrrrr strfromlocalridentityrrr*r(r+r.rBcontextmanagerrODETACHED_PROCESSCREATE_NEW_PROCESS_GROUPrUrZr)r%rrs#   !   ( # &$:bll:   ./'@g,,( ?# #$99 IE II  E:: YF SZZ.. /F:: YF SZZ.. /F     'F    'F &>>h**j8  'F                  ,,   &&       $$K ((M    B 4 4 B-2A  ! * !J  < )*2$  ''K##K- !H  (  ( V $$B "   - - .%XR(C    s$5 N N"NN"N,+N,