e96SrSSKrSSKJr SSKJr SSKJr SSKJr SSKJr \Rr \Rr \Rr "S S \R\R5r"S S 5rSSS\R 4S jrSSS\R S.Sjrg))create_subprocess_execcreate_subprocess_shellN)events) protocols)streams)tasks)loggercV^\rSrSrSrU4SjrSrSrSrSr Sr S r S r S r U=r$) SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c>[TU]US9 XlS=Ul=UlUlSUlSUl/UlURR5Ul g)N)loopF) super__init___limitstdinstdoutstderr _transport_process_exited _pipe_fds_loop create_future _stdin_closed)selflimitr __class__s 8/opt/imh/python3.13/lib/python3.13/asyncio/subprocess.pyr!SubprocessStreamProtocol.__init__sX d# 155 5T[4;$!ZZ557cxURR/nURbURSUR<35 URbURSUR<35 UR bURSUR <35 SR SRU55$)Nzstdin=zstdout=zstderr=z<{}> )r__name__rappendrrformatjoin)rinfos r__repr__!SubprocessStreamProtocol.__repr__s''( :: ! KK&/ 0 ;; " KK'$++1 2 ;; " KK'$++1 2}}SXXd^,,r!cfXlURS5nUbd[R"URUR S9UlUR RU5 URRS5 URS5nUbd[R"URUR S9Ul URRU5 URRS5 URS5nUb'[R"UUSUR S9Ul gg)Nrrrr)protocolreaderr) rget_pipe_transportr StreamReaderrrr set_transportrr%r StreamWriterr)r transportstdout_transportstderr_transportstdin_transports rconnection_made(SubprocessStreamProtocol.connection_made(s#$77:  '!..T[[48JJ@DK KK % %&6 7 NN ! !! $$77:  '!..T[[48JJ@DK KK % %&6 7 NN ! !! $#66q9  & --o7;5937::?DJ 'r!c~US:Xa URnOUS:Xa URnOSnUbURU5 ggNrr-)rr feed_data)rfddatar/s rpipe_data_received+SubprocessStreamProtocol.pipe_data_received@s@ 7[[F 1W[[FF     T " r!cUS:Xa|URnUbUR5 URU5 UcURR S5 gURR U5 SURlgUS:Xa URnOUS:Xa URnOSnUb%UcUR5 OUR U5 XR;aURRU5 UR5 g)NrFrr-) rcloseconnection_lostr set_result set_exception_log_tracebackrrfeed_eofrremove_maybe_close_transport)rr=excpiper/s rpipe_connection_lost-SubprocessStreamProtocol.pipe_connection_lostJs 7::D   %{""--d3  ""0055:""1  7[[F 1W[[FF  {!$$S)   NN ! !" % ##%r!c2SUlUR5 g)NT)rrIrs rprocess_exited'SubprocessStreamProtocol.process_exitedhs# ##%r!c[UR5S:Xa4UR(a"URR 5 SUlggg)Nr)lenrrrrBrOs rrI/SubprocessStreamProtocol._maybe_close_transportls: t~~ ! #(<(< OO ! ! #"DO)= #r!c8XRLa UR$gN)rr)rstreams r_get_close_waiter*SubprocessStreamProtocol._get_close_waiterqs ZZ %% % r!)rrrrrrrr)r$ __module__ __qualname____firstlineno____doc__rr)r8r?rLrPrIrX__static_attributes__ __classcell__)rs@rr r s3:8-?0#&<&# &&r!r cd\rSrSrSrSr\S5rSrSr Sr Sr S r S r S rSS jrSrg )ProcessvcXlX lX0lURUlURUlUR UlUR 5UlgrV)r _protocolrrrrget_pidpid)rr4r.rs rrProcess.__init__wsB#! ^^ oo oo $$&r!cPSURRSURS3$)N)rr$rfrOs rr)Process.__repr__s&4>>**+1TXXJa88r!c6URR5$rV)rget_returncoderOs r returncodeProcess.returncodes--//r!cR# URR5IShvN $N7f)z?Wait until the process exit and return the process return code.N)r_waitrOs rwait Process.waits__**,,,,s '%'c:URRU5 grV)r send_signal)rsignals rruProcess.send_signals ##F+r!c8URR5 grV)r terminaterOs rryProcess.terminates !!#r!c8URR5 grV)rkillrOs rr| Process.kills r!c# URR5nUbCURRU5 U(a![R "SU[ U55 URR5IShvN U(a[R "SU5 URR5 gN=![[4a(nU(a[R "SX5 SnANnSnAff=f7f)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin) r get_debugrwriter debugrSdrainBrokenPipeErrorConnectionResetErrorrB)rinputrrJs r _feed_stdinProcess._feed_stdins $$& H    'LL?s5zS**""$ $ $  LL6 =  %!56 H ;TG  HsAC<A#CB?C9C<?CC9C4/C<4C99C<c # g7frVrOs r_noop Process._noopssc# URRU5nUS:Xa URnOUS:XdeURnURR 5(a!US:XaSOSn[ R"SX5 UR5IShvN nURR 5(a!US:XaSOSn[ R"SX5 UR5 U$NV7f)Nr-rrrz%r communicate: read %sz%r communicate: close %s) rr0rrrrr rreadrB)rr=r4rWnameoutputs r _read_streamProcess._read_streamsOO66r: 7[[F7N7[[F ::   ! !!Qw8HD LL2D ?{{}$ ::   ! !!Qw8HD LL3T @ %sBC1C/AC1Nc# URbURU5nOUR5nURbUR S5nOUR5nUR bUR S5nOUR5n[ R"X#U5IShvN up#nUR5IShvN X44$N"N 7fr;) rrrrrrr gatherrr)rrrrrs r communicateProcess.communicates :: !$$U+EJJLE ;; "&&q)FZZ\F ;; "&&q)FZZ\F&+ll5&&I Iviik!Js$B(C*C +CCCC)rrdrrfrrrrV)r$rZr[r\rr)propertyrnrrruryr|rrrrr^rr!rraravsH'900-,$(" r!rac^^ # [R"5m UU 4SjnT R"UU4XUS.UD6IShvN upx[XxT 5$N7f)Nc>[TTS9$Nr,r r,sr)create_subprocess_shell..7e=A Cr!rrr)rget_running_loopsubprocess_shellra) cmdrrrrkwdsprotocol_factoryr4r.rs ` @rrrsd  " " $DC $ 5 5 !!!I 9 -- s7AAA)rrrrc^^ # [R"5m UU 4SjnT R"UU/UQ7XUS.UD6IShvN up[XT 5$N7f)Nc>[TTS9$rrr,srr(create_subprocess_exec..rr!r)rrsubprocess_execra) programrrrrargsrrr4r.rs ` @rrrsp  " " $DC $ 4 4!! ! !I 9 -- s:AAA)__all__ subprocessrrrr logr PIPESTDOUTDEVNULLFlowControlMixinSubprocessProtocolr ra_DEFAULT_LIMITrrrr!rrs =      b&w77(;;b&JU U p.2$t(/(>(> .8