!A?h 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 ddZdS ))create_subprocess_execcreate_subprocess_shell N )events) protocols)streams)tasks)loggerc L e Zd ZdZ fdZd Zd Zd Zd Zd Z d Z
d Z xZ S )
SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.c t | || _ d x| _ x| _ | _ d | _ d| _ g | _ | j
| _ d S )N)loopF) super__init___limitstdinstdoutstderr
_transport_process_exited _pipe_fds_loop
create_future
_stdin_closed)selflimitr __class__s ?/opt/alt/python-internal/lib64/python3.11/asyncio/subprocess.pyr z!SubprocessStreamProtocol.__init__ sl
d### 155
5T[4; $ !Z 5 5 7 7 c D | j j g}| j | d| j | j | d| j | j | d| j d d | S )Nzstdin=zstdout=zstderr=z<{}> )r __name__r appendr r formatjoin)r infos r __repr__z!SubprocessStreamProtocol.__repr__ s '( : ! KK/// 0 0 0 ; " KK1$+11 2 2 2 ; " KK1$+11 2 2 2}}SXXd^^,,,r c J || _ | d }|Yt j | j | j | _ | j | | j d | d }|Yt j | j | j | _
| j
| | j d | d }|$t j || d | j | _ d S d S )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[48J@ @ @DK K % %&6 7 7 7 N ! !! $ $ $$77:: '!.T[48J@ @ @DK K % %&6 7 7 7 N ! !! $ $ $#66q99 & -o7;5937:? ? ?DJJJ ' &r c t |dk r| j }n|dk r| j }nd }|| | d S d S Nr r* )r r feed_data)r fddatar, s r pipe_data_receivedz+SubprocessStreamProtocol.pipe_data_received@ sS
77[FF
1WW[FFF T " " " " " r c |dk rw| j }|| | | || j d n&| j | d| j _ d S |dk r| j }n|dk r| j }nd }|,|| n| | || j
v r| j
| | d S )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
77:D
% % %{"--d3333"00555 5:"1 F
77[FF
1WW[FFF {!!!!$$S)))
N ! !" % % % ##%%%%%r c < d| _ | d S )NT)r rD r s r process_exitedz'SubprocessStreamProtocol.process_exitedh s" # ##%%%%%r c t | j dk r)| j r$| j d | _ d S d S d S )Nr )lenr r r r= rI s r rD z/SubprocessStreamProtocol._maybe_close_transportl sL t~ ! # #(< # O ! ! # # # "DOOO $ # # #r c & || j u r| j S d S N)r r )r streams r _get_close_waiterz*SubprocessStreamProtocol._get_close_waiterq s TZ % % r )
r"
__module__ __qualname____doc__r r' r5 r; rG rJ rD rP
__classcell__)r s @r r r s ::8 8 8 8 8- - -? ? ?0# # # & & &<& & &# # #
& & & & & & &r r c b e Zd Zd Zd Zed Zd Zd Zd Z d Z
d Z d Z d
Z
d
d Zd S )Processc || _ || _ || _ |j | _ |j | _ |j | _ | | _ d S rN )r _protocolr r r r get_pidpid)r r1 r+ r s r r zProcess.__init__w sI #!
^
o o $$&&r c 2 d| j j d| j dS )N<r! >)r r" rZ rI s r r' zProcess.__repr__ s" 84>*88TX8888r c 4 | j S rN )r get_returncoderI s r
returncodezProcess.returncode s --///r c D K | j d{V S )z?Wait until the process exit and return the process return code.N)r _waitrI s r waitz Process.wait s, _**,,,,,,,,,r c : | j | d S rN )r send_signal)r signals r re zProcess.send_signal s ##F+++++r c 8 | j d S rN )r terminaterI s r rh zProcess.terminate s !!#####r c 8 | j d S rN )r killrI s r rj z Process.kill s r c K | j } | j | |r#t j d| t
| | j d {V n6# t t f$ r"}|rt j d| | Y d }~nd }~ww xY w|rt j d| | j
d S )Nz%%r communicate: feed stdin (%s bytes)z %r communicate: stdin got %rz%r communicate: close stdin) r get_debugr writer
debugrL drainBrokenPipeErrorConnectionResetErrorr= )r inputrn rE s r _feed_stdinzProcess._feed_stdin s
$$&& H J U # # #
O ;T3u::O O O *""$$ $ $ $ $ $ $ $ $ !56 H H H
H ;T3GGG H > L6 = = =
s A A< <B/
B**B/c
K d S rN rI s r _noopz
Process._noop s tr c K | j | }|dk r| j }n| j }| j r |dk rdnd}t
j d| | | d {V }| j r |dk rdnd}t
j d| | | |S )Nr* r r r z%r communicate: read %sz%r communicate: close %s)
r r- r r r rl r
rn readr= )r r9 r1 rO nameoutputs r _read_streamzProcess._read_stream s O66r::
77[FF [F : ! ! @ !Qww88HD L2D$ ? ? ? {{}}$$$$$$ : ! ! A !Qww88HD L3T4 @ @ @
r Nc K || | }n| }| j | d }n| }| j | d }n| }t j ||| d {V \ }}}| d {V ||fS r7 )rs rv r r{ r r gatherrc )r rr r r r s r communicatezProcess.communicate s $$U++EEJJLLE ; "&&q))FFZZ\\F ; "&&q))FFZZ\\F&+l5&&&I&I I I I I I I vviikk r rN )r" rQ rR r r' propertyr` rc re rh rj rs rv r{ r~ ru r r rV rV v s ' ' '9 9 9 0 0 X0- - -, , ,$ $ $ & " r rV c K t j fd} j || f|||d| d {V \ }}t || S )Nc & t S Nr) r r) s r <lambda>z)create_subprocess_shell.<locals>.<lambda> 7e=A C C C r r r r )r get_running_loopsubprocess_shellrV )
cmdr r r r kwdsprotocol_factoryr1 r+ r s
` @r r r s " $ $DC C C C C 5 5 ! ! ! ! ! Ix 9h - --r )r r r r c
K t j
fd}
j || g|R |||d| d {V \ }} t ||
S )Nc & t S r r r) s r r z(create_subprocess_exec.<locals>.<lambda> r r r )r r subprocess_execrV ) programr r r r argsr r r1 r+ r s ` @r r r s " $ $DC C C C C 4 4! ! ! F ! ! ! ! Ix
9h - --r )__all__
subprocess r r r r logr
PIPESTDOUTDEVNULLFlowControlMixinSubprocessProtocolr rV _DEFAULT_LIMITr r ru r r <module>r sK
=
b& b& b& b& b&w 7 ( ;b& b& b&JT T T T T T T T n .2$t(/(> . . . . 8<D(,G4J . . . . . . .r