/g 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 J e Zd Z fdZd Zd Zd Zd Zd Zd Z d Z
xZ S ) SubprocessStreamProtocolc 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 9/opt/alt/python311/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__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