GRAYBYTE WORDPRESS FILE MANAGER7927

a

�DOg��@s�dZd
dl
Z
d
dlZddlmZ
ddlmZ
ddlmZ
ddlmZ
ddlm	Z	
e
j
Z
e
jZe
jZGd	d
�d
ej
ej�ZGdd�d�Zddddejfd
d�
Zddddejd�dd�ZdS))�create_subprocess_exec�create_subprocess_shell�N�
)
�events)
�	protocols)
�streams)
�tasks)
�loggercsTeZ
dZ�f
d
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
�ZS)�SubprocessStreamProtocolcsHt�j
|d
�

|
|_d|_|_|_d|_d|_g|_|j	�
�|_dS)N�
�loopF)�super�__init__�_limit�stdin�stdout�stderr�
_transport�_process_exited�	_pipe_fds�_loopZ
create_future�
_stdin_closed)�self�limitr�
�	__class__��*/usr/lib64/python3.9/asyncio/subprocess.pyrs






z!SubprocessStreamProtocol.__init__c
Csn|jj
g
}
|jdu
r&|
�d
|j���

|jdu
rB|
�d|j���

|jdu
r^|
�d|j���

d�d�|
�
�
S)Nzstdin=zstdout=zstderr=z<{}>�
 )r�__name__r�appendrr�format�join)r�inforrr�__repr__s











z!SubprocessStreamProtocol.__repr__cCs�|
|_|
�
d
�
}|du
rDtj|j|jd�|_|j�|�

|j�	d
�

|
�
d�
}|du
r�tj|j|jd�|_
|j
�|�

|j�	d�

|
�
d�
}|du
r�tj||d|jd�|_dS)Nr�rr�r)�protocol�readerr)
r�get_pipe_transportr�StreamReaderrrrZ
set_transportrr r�StreamWriterr)r�	transportZstdout_transportZstderr_transportZstdin_transportrrr�connection_made)s,




�




�






�z(SubprocessStreamProtocol.connection_madecCs:|
d
kr|j}n|
dkr |j
}nd}|du
r6|�|�

dS)Nrr&)rrZ	feed_data)r�fd�datar(rrr�pipe_data_receivedAs





z+SubprocessStreamProtocol.pipe_data_receivedcCs�|
d
krN|j}|du
r|�
�
|�|�

|dur>|j�d�

n|j�|�

dS|
dkr^|j}n|
dkrn|j}nd}|du
r�|dur�|��
n
|�|�

|
|j	vr�|j	�
|
�

|��
dS)Nrrr&)r�closeZconnection_lostr�
set_result�
set_exceptionrrZfeed_eofr�remove�_maybe_close_transport)rr.�exc�piper(rrr�pipe_connection_lostKs*




















z-SubprocessStreamProtocol.pipe_connection_lostc

Csd
|_|�
�
dS)NT)rr5�
rrrr�process_exitedfs

z'SubprocessStreamProtocol.process_exitedc

Cs(t|j
�
d
kr$|jr$|j��
d|_dS)Nr)�lenrrrr1r9rrrr5js



z/SubprocessStreamProtocol._maybe_close_transportcCs|
|jur|j
SdS�
N)rr)r�streamrrr�_get_close_waiteros


z*SubprocessStreamProtocol._get_close_waiter)r�
__module__�__qualname__rr$r-r0r8r:r5r>�
__classcell__rrrrr
s	

r
c@sjeZ
dZd
d�Zdd�Zedd��
Zdd�Zd	d
�Zdd�Z	d
d�Z
dd�Zdd�Zdd�Z
ddd�
ZdS)�ProcesscCs8|
|_||_
||_|j|_|j|_|j|_|
��|_dSr<)rZ	_protocolrrrrZget_pid�pid)rr,r'rrrrrus






zProcess.__init__c

Csd
|jj
�d|j�d�S)N�
<r�
>)rrrCr9rrrr$~s
zProcess.__repr__c

Cs
|j�
�Sr<)rZget_returncoder9rrr�
returncode�szProcess.returncodec

�s|j�
�IdHSr<)r�_waitr9rrr�wait�szProcess.waitcCs|j�
|
�

dSr<)r�send_signal)r�signalrrrrI�s
zProcess.send_signalc

Cs|j�
�
dSr<)r�	terminater9rrrrK�s
zProcess.terminatec

Cs|j�
�
dSr<)r�killr9rrrrL�s
zProcess.killc
�s�|j�
�}|j�|
�

|r,t�d
|t|
�
�
z|j��IdH
Wn:tt	fyz
}
z|rft�d||�
WYd}~n
d}~00|r�t�d|�
|j�
�
dS)Nz%%r communicate: feed stdin (%s bytes)z%r communicate: stdin got %rz%r communicate: close stdin)r�	get_debugr�writer	�debugr;Zdrain�BrokenPipeError�ConnectionResetErrorr1)r�inputrOr6rrr�_feed_stdin�s






�


$

zProcess._feed_stdinc


�sdSr<rr9rrr�_noop�s
z
Process._noopc�s�|j�
|
�
}|
d
kr|j}n|j}|j��rJ|
dkr8dnd}t�d||�
|��IdH}|j��r�|
dkrndnd}t�d||�
|�	�
|S)Nr&rrrz%r communicate: read %sz%r communicate: close %s)
rr)rrrrMr	rO�readr1)rr.r,r=�name�outputrrr�_read_stream�s













zProcess._read_streamNc�s�|
du
r|�|
�
}n|�
�}|jdu
r2|�d
�
}n|�
�}|jdu
rP|�d�
}n|�
�}tj||||jd�IdH\}}}|��IdH
||fS)Nrr&r)	rSrTrrXrrZ_gatherrrH)rrRrrrrrr�communicate�s










�
zProcess.communicate)
N)rr?r@rr$�propertyrFrHrIrKrLrSrTrXrYrrrrrBts
	

rBc
�sb�
durt�
��
ntjd
tdd�
��
fdd�}�
j||f|
||d�|�
�
IdH\}}	t||	�
�S)N�ZThe loop argument is deprecated since Python 3.8 and scheduled for removal in Python 3.10.r&�
�
stacklevelcst��
d
�S�Nr%�
r
rr%rr�<lambda>�s
�z)create_subprocess_shell.<locals>.<lambda>�rrr)r�get_event_loop�warnings�warn�DeprecationWarningZsubprocess_shellrB)
�cmdrrrrr�kwds�protocol_factoryr,r'rr%rr�s"


�

�
��r)rrrrrc
�sh�
durt�
��
ntjd
tdd�
��
fdd�}�
j||g|�
R|
||d�|�
�
IdH\}	}
t|	|
�
�S)Nr[r&r\cst��
d
�Sr^r_rr%rrr`�s
�z(create_subprocess_exec.<locals>.<lambda>ra)rrbrcrdreZsubprocess_execrB)Zprogramrrrrr�argsrgrhr,r'rr%rr
�s&


�

��
��r
)�__all__�
subprocessrc�rrrr�logr	�PIPE�STDOUT�DEVNULLZFlowControlMixinZSubprocessProtocolr
rBZ_DEFAULT_LIMITrr
rrrr�<module>
s*







�bV
�


�