*j9 6 S r SSKrSSKJr SSKJr SSKJr SSKJr SSKJr \R r \R r
\R r " S S
\R \R 5 r " S S 5 rSSS\R 4S
jrSSS\R S.S jrg))create_subprocess_execcreate_subprocess_shell N )events) protocols)streams)tasks)loggerc V ^ \ rS rSrSrU 4S jrS rS rS rS r S r
S r S
r S r
U =r$ ) SubprocessStreamProtocol z0Like StreamReaderProtocol, but for a subprocess.c > [ TU ] US9 Xl S =U l =U l U l S U l SU l / U l U R R 5 U l g )N)loopF) super__init___limitstdinstdoutstderr
_transport_process_exited _pipe_fds_loop
create_future
_stdin_closed)selflimitr __class__s 9/opt/alt/python313/lib64/python3.13/asyncio/subprocess.pyr !SubprocessStreamProtocol.__init__ sX
d# 155
5T[4; $ !ZZ 5 5 7 c x U R R /nU R b UR SU R < 35 U R b UR SU R < 35 U R
b UR SU R
< 35 SR
SR U5 5 $ )Nzstdin=zstdout=zstderr=z<{}> )r __name__r appendr r formatjoin)r infos r __repr__!SubprocessStreamProtocol.__repr__ s ''( :: ! KK&/ 0 ;; " KK'$++ 1 2 ;; " KK'$++ 1 2}}SXXd^,,r! c f Xl UR S5 nUbd [ R " U R U R
S9U l U R R U5 U R R S5 UR S5 nUbd [ R " U R U R
S9U l
U R R U5 U R R S5 UR S5 nUb' [ R " UU S U R
S9U l g g )Nr r r r )protocolreaderr )
r get_pipe_transportr StreamReaderr r r
set_transportr r% r StreamWriterr )r transportstdout_transportstderr_transportstdin_transports r connection_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:X a
U R nOUS:X a
U R nOS nUb UR U5 g g Nr r- )r r feed_data)r fddatar/ s r pipe_data_received+SubprocessStreamProtocol.pipe_data_received@ s@
7[[F
1W[[FF T " r! c US:X a| U R nUb UR 5 U R U5 Uc U R R S 5 g U R R U5 SU R l g US:X a
U R nOUS:X a
U R nOS nUb% Uc UR 5 OUR U5 XR ; a U R R U5 U R 5 g )Nr Fr r- )
r closeconnection_lostr
set_result
set_exception_log_tracebackr r feed_eofr remove_maybe_close_transport)r r= excpiper/ s r pipe_connection_lost-SubprocessStreamProtocol.pipe_connection_lostJ s
7::D
%{""--d3
""005 5:""1
7[[F
1W[[FF {!$$S)
NN ! !" % ##%r! c 2 SU l U R 5 g )NT)r rI r s r process_exited'SubprocessStreamProtocol.process_exitedh s # ##%r! c [ U R 5 S:X a4 U R ( a" U R R 5 S U l g g g )Nr )lenr r r rB rO s r rI /SubprocessStreamProtocol._maybe_close_transportl s: t~~ ! #(<(< OO ! ! # "DO )= #r! c 8 XR L a U R $ g N)r r )r streams r _get_close_waiter*SubprocessStreamProtocol._get_close_waiterq s ZZ %% % r! )r r r r r r r r )r$
__module__ __qualname____firstlineno____doc__r r) r8 r? rL rP rI rX __static_attributes__
__classcell__)r s @r r r s3 :8-?0# &<&#
& &r! r c d \ rS rSrS rS r\S 5 rS rS r S r
S r S r S
r
S rSS
jrSrg )Processv c Xl X l X0l UR U l UR U l UR
U l UR
5 U l g rV )r _protocolr r r r get_pidpid)r r4 r. r s r r Process.__init__w sB #!
^^
oo oo $$&r! c P SU R R SU R S3$ )N)r r$ rf rO s r r) Process.__repr__ s& 4>>**+1TXXJa88r! c 6 U R R 5 $ rV )r get_returncoderO s r
returncodeProcess.returncode s --//r! c R # U R R 5 I Sh vN $ N7f)z?Wait until the process exit and return the process return code.N)r _waitrO s r wait Process.wait s __**,,,,s '%'c : U R R U5 g rV )r send_signal)r signals r ru Process.send_signal s ##F+r! c 8 U R R 5 g rV )r terminaterO s r ry Process.terminate s !!#r! c 8 U R R 5 g rV )r killrO s r r| Process.kill s r! c # U R R 5 n UbC U R R U5 U( a! [ R
" SU [
U5 5 U R R 5 I S h vN U( a [ R
" SU 5 U R R 5 g N=! [ [ 4 a( nU( a [ R
" SX5 S nANnS nAff = f7f)Nz%%r communicate: feed stdin (%s bytes)z %r communicate: stdin got %rz%r communicate: close stdin) r get_debugr writer
debugrS drainBrokenPipeErrorConnectionResetErrorrB )r inputr rJ s r _feed_stdinProcess._feed_stdin s
$$& H
'LL?s5zS **""$ $ $ LL6 =
% !56 H ;TG HsA C<A#C B?C 9C<?C C9 C4/C<4C99C<c # g 7frV rO s r _noop
Process._noop s s c # U R R U5 nUS:X a
U R nOUS:X d eU R nU R R 5 ( a! US:X a SOSn[ R " SX5 UR 5 I S h vN nU R R 5 ( a! US:X a SOSn[ R " SX5 UR 5 U$ NV7f)Nr- r r r z%r communicate: read %sz%r communicate: close %s)
r r0 r r r r r
r readrB )r r= r4 rW nameoutputs r _read_streamProcess._read_stream s OO66r:
7[[F7N7[[F :: ! ! !Qw8HD LL2D ? {{}$ :: ! ! !Qw8HD LL3T @
%s BC1C/AC1Nc # U R b U R U5 nOU R 5 nU R b U R S5 nOU R 5 nU R
b U R S5 nOU R 5 n[ R " X#U5 I S h vN u p#nU R 5 I S h vN X44$ N" N 7fr; ) r r r r r r r gatherrr )r r r r r s r communicateProcess.communicate s :: !$$U+EJJLE ;; "&&q)FZZ\F ;; "&&q)FZZ\F&+ll5&&I I viik !Js$ B(C*C
+CCCC)r rd r rf r r r rV )r$ rZ r[ r\ r r) propertyrn rr ru ry r| r r r r r^ r r! r ra ra v sH '9 0 0-,$ (" r! ra c ^^ # [ R " 5 m UU 4S jnT R " UU 4XUS.UD6I S h vN u px[ XxT 5 $ N7f)Nc > [ T TS9$ Nr, r r, s r )create_subprocess_shell.. 7e=A Cr! r r r )r get_running_loopsubprocess_shellra )
cmdr r r r kwdsprotocol_factoryr4 r. r s
` @r r r sd " " $DC $ 5 5 ! ! ! I 9 -- s 7AAA)r r r r c ^^
# [ R " 5 m
UU
4S jnT
R " UU /UQ7XUS.UD6I S h vN u p[ XT
5 $ N7f)Nc > [ T TS9$ r r r, s r r (create_subprocess_exec.. r r! r )r r subprocess_execra ) programr r r r argsr r r4 r. r s ` @r r r sp " " $DC $ 4 4! ! ! ! I
9 -- s :AAA)__all__
subprocess r r r r logr
PIPESTDOUTDEVNULLFlowControlMixinSubprocessProtocolr ra _DEFAULT_LIMITr r r r! r r s
=
b&w 7 7 ( ; ;b&JU U p .2$t(/(>(> . 8