$24 GRAYBYTE WORDPRESS FILE MANAGER $68

U

i�f��@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)
�loggercsXeZ
dZd
Z�f
dd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Z�ZS)�SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.csHt�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__��7/opt/alt/python38/lib64/python3.8/asyncio/subprocess.pyrs






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

|jdk	rB|
�d|j���

|jdk	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
�
}|dk	rDtj|j|jd�|_|j�|�

|j�	d
�

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

|j�	d�

|
�
d�
}|dk	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}|dk	r6|�|�

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





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

|dkr>|j�d�

n|j�|�

dS|
dkr^|j}n|
dkrn|j}nd}|dk	r�|dkr�|��
n
|�|�

|
|j	kr�|j	�
|
�

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




















z-SubprocessStreamProtocol.pipe_connection_lostc

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

z'SubprocessStreamProtocol.process_exitedc

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



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


z*SubprocessStreamProtocol._get_close_waiter)
r�
__module__�__qualname__�__doc__rr$r-r0r6r8r3r<�
__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�
>)rrrBr7rrrr$~s
zProcess.__repr__c

Cs
|j�
�Sr:)rZget_returncoder7rrr�
returncode�szProcess.returncodec

�s|j�
�Id
HS)z?Wait until the process exit and return the process return code.N)rZ_waitr7rrr�wait�szProcess.waitcCs|j�
|
�

dSr:)r�send_signal)r�signalrrrrG�s
zProcess.send_signalc

Cs|j�
�
dSr:)r�	terminater7rrrrI�s
zProcess.terminatec

Cs|j�
�
dSr:)r�killr7rrrrJ�s
zProcess.killc
�s�|j�
�}|j�|
�

|r,t�d
|t|
�
�
z|j��IdH
Wn8tt	fk
rx
}
z|rht�d||�
W5d}~XYnX|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	�debugr9Zdrain�BrokenPipeError�ConnectionResetErrorr1)r�inputrMr4rrr�_feed_stdin�s 





�


 

zProcess._feed_stdinc


�sdSr:rr7rrr�_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)rrrrKr	rM�readr1)rr.r,r;�name�outputrrr�_read_stream�s













zProcess._read_streamNc�s�|
dk	r|�|
�
}n|�
�}|jdk	r2|�d
�
}n|�
�}|jdk	rP|�d�
}n|�
�}tj||||jd�IdH\}}}|��IdH
||fS)Nrr&r)	rQrRrrVrrZgatherrrF)rrPrrrrrr�communicate�s










�
zProcess.communicate)
N)rr=r>rr$�propertyrErFrGrIrJrQrRrVrWrrrrrAts
	

rAc
�sb�
dkrt�
��
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_shellrA)
�cmdrrrrr�kwds�protocol_factoryr,r'rr%rr�s$


�

�
��r)rrrrrc
�sf�
dkrt�
��
ntjd
tdd�
��
fdd�}�
j||f|�|
||d�|��
IdH\}	}
t|	|
�
�S)NrYr&rZcst��
d
�Sr\r]rr%rrr^�s
�z(create_subprocess_exec.<locals>.<lambda>r_)rr`rarbrcZsubprocess_execrA)Zprogramrrrrr�argsrerfr,r'rr%rr
�s(


�

��
��r
)�__all__�
subprocessra�rrrr�logr	�PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr
rAZ_DEFAULT_LIMITrr
rrrr�<module>
s.







�bV
�


�