cj9 2 d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ej Z ej Z
ej Z G d d
ej ej Z G d d Zdddej fd
Zdddej ddZy))create_subprocess_execcreate_subprocess_shell N )events) protocols)streams)tasks)loggerc J e Zd Z fdZd Zd Zd Zd Zd Zd Z d Z
xZ S ) SubprocessStreamProtocolc t | | || _ d x| _ x| _ | _ d | _ d| _ g | _ | j j | _ y )N)loopF) super__init___limitstdinstdoutstderr
_transport_process_exited _pipe_fds_loop
create_future
_stdin_closed)selflimitr __class__s +/usr/lib64/python3.12/asyncio/subprocess.pyr z!SubprocessStreamProtocol.__init__ sZ
d# 155
5T[4; $ !ZZ 5 5 7 c l | j j g}| j |j d| j | j |j d| j | j
|j d| j
dj
dj | S )Nzstdin=zstdout=zstderr=z<{}> )r __name__r appendr r formatjoin)r infos r __repr__z!SubprocessStreamProtocol.__repr__ s ''( :: ! KK&/ 0 ;; " KK'$++ 1 2 ;; " KK'$++ 1 2}}SXXd^,,r c n || _ |j d }|ft j | j | j
| _ | j j | | j j d |j d }|ft j | j | j
| _
| j j | | j j d |j d }|)t j || d | j
| _ y y )Nr r r r )protocolreaderr )
r get_pipe_transportr StreamReaderr r r
set_transportr r# r StreamWriterr )r transportstdout_transportstderr_transportstdin_transports r connection_madez(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 x |dk( r
| j }n|dk( r
| j }nd }||j | y y Nr r* )r r feed_data)r fddatar, s r pipe_data_receivedz+SubprocessStreamProtocol.pipe_data_received@ s@
7[[F
1W[[FF T " r c |dk( rz| j }||j | j | | | j j d y | j j | d| j _ y |dk( r
| j }n|dk( r
| j }nd }|$||j n|j | || j v r| j j | | j y )Nr Fr r* )
r closeconnection_lostr
set_result
set_exception_log_tracebackr r feed_eofr remove_maybe_close_transport)r r9 excpiper, s r pipe_connection_lostz-SubprocessStreamProtocol.pipe_connection_lostJ s
7::D
%{""--d3
""005 5:""1
7[[F
1W[[FF {!$$S)
NN ! !" % ##%r c 2 d| _ | j y )NT)r rD r s r process_exitedz'SubprocessStreamProtocol.process_exitedh s # ##%r c t | j dk( r/| j r"| j j d | _ y y y )Nr )lenr r r r= rI s r rD z/SubprocessStreamProtocol._maybe_close_transportl s: t~~ ! #(<(< OO ! ! # "DO )= #r c 8 || j u r | j S y N)r r )r streams r _get_close_waiterz*SubprocessStreamProtocol._get_close_waiterq s TZZ %% % r ) r"
__module__ __qualname__r r' r5 r; rG rJ rD rP
__classcell__)r s @r r r s. :8-?0# &<&#
&r r c Z e Zd Zd Zd Zed Zd Zd Zd Z d Z
d Z d Z d
Z
d
d Zy )Processc || _ || _ || _ |j | _ |j | _ |j
| _ |j
| _ y rN )r _protocolr r r r get_pidpid)r r1 r+ r s r r zProcess.__init__w sH #!
^^
oo oo $$&r c P d| j j d| j dS )N)r r" rY rI s r r' zProcess.__repr__ s& 4>>**+1TXXJa88r c 6 | j j S rN )r get_returncoderI s r
returncodezProcess.returncode s --//r c T K | j j d { S 7 wrN )r _waitrI s r waitz Process.wait s" M__**,,,,s (&(c : | j j | y rN )r send_signal)r signals r rd zProcess.send_signal s ##F+r c 8 | j j y rN )r terminaterI s r rg zProcess.terminate s !!#r c 8 | j j y rN )r killrI s r ri z Process.kill s r c K | j j } |=| j j | |r t j
d| t
| | j j d { |rt j
d| | j j y 7 7# t t f$ r#}|rt j
d| | Y d }~bd }~ww xY ww)Nz%%r communicate: feed stdin (%s bytes)z %r communicate: stdin got %rz%r communicate: close stdin) r get_debugr writer
debugrL drainBrokenPipeErrorConnectionResetErrorr= )r inputrm rE s r _feed_stdinzProcess._feed_stdin s
$$& H
'LL?s5zS **""$ $ $ LL6 =
% !56 H ;T3G HsA C)A B4 :B2;B4 ?3C)2B4 4C&C! C)!C&&C)c K y wrN rI s r _noopz
Process._noop s s c K | j j | }|dk( r
| j }n | j }| j j r |dk( rdnd}t
j d| | |j d { }| j j r |dk( rdnd}t
j d| | |j |S 7 Pw)Nr* r r r z%r communicate: read %sz%r communicate: close %s)
r r- r r r rk r
rm readr= )r r9 r1 rO nameoutputs r _read_streamzProcess._read_stream s OO66r:
7[[F [[F :: ! !Qw8HD LL2D$ ? {{}$ :: ! !Qw8HD LL3T4 @
%s BC C
AC Nc K | j | j | }n| j }| j | j d }n| j }| j
| j d }n| j }t
j ||| d { \ }}}| j d { ||fS 7 $7
wr7 ) r rr ru r rz r r gatherrb )r rq r r r s r communicatezProcess.communicate s :: !$$U+EJJLE ;; "&&q)FZZ\F ;; "&&q)FZZ\F&+ll5&&&I I vviik !Js$ B%C'C (CC CCrN )r" rQ rR r r' propertyr_ rb rd rg ri rr ru rz r} rt r r rU rU v sH '9 0 0-,$ (" r rU c K t j fd} j || f|||d| d { \ }}t || S 7 w)Nc t S Nr) r r) s r z)create_subprocess_shell.. 7e=A Cr r r r )r get_running_loopsubprocess_shellrU )
cmdr r r r kwdsprotocol_factoryr1 r+ r s
` @r r r sm " " $DC 5 5 5 ! ! ! Ix 9h -- s 6AAA)r r r r c
K t j
fd}
j || g||||d| d { \ }} t ||
S 7 w)Nc t S r r r) s r r z(create_subprocess_exec.. r r r )r r subprocess_execrU ) programr r r r argsr r r1 r+ r s ` @r r r sy " " $DC 4 4 4! ! F ! ! Ix
9h -- s 9AAA)__all__
subprocess r r r r logr
PIPESTDOUTDEVNULLFlowControlMixinSubprocessProtocolr rU _DEFAULT_LIMITr r rt r r r s
=
b&w 7 7 ( ; ;b&JU U p .2$t(/(>(> . 8