$48 GRAYBYTE WORDPRESS FILE MANAGER $64

B

� fV�@s�dZd
dl
Z
ddlmZ
ddlmZ
ddlmZ
ddlmZ
ddlmZ
e
j	Z	e
j
Z
e
jZGd	d
�d
ejej
�ZGdd�d�Zddddejfd
d�
Zddddejd�dd�ZdS))�create_subprocess_exec�create_subprocess_shell�N�
)
�events)
�	protocols)
�streams)
�tasks)
�loggercsPeZ
dZd
Z�f
dd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
�ZS)�SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.cs<t�j
|d
�

|
|_d|_|_|_d|_d|_g|_dS)N)
�loopF)	�super�__init__�_limit�stdin�stdout�stderr�
_transport�_process_exited�	_pipe_fds)�self�limitr)
�	__class__��7/opt/alt/python37/lib64/python3.7/asyncio/subprocess.pyr
s





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�StreamReaderr�_looprZ
set_transportrrr�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_received?s





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

dS|
dkr<|j}n|
dkrL|j}nd}|dk	rt|dkrj|��
n
|�|�

|
|jkr�|j�|
�

|�	�
dS)Nrrr!)
r�closeZconnection_lostrrZfeed_eofZ
set_exceptionr�remove�_maybe_close_transport)rr*�exc�piper#rrr�pipe_connection_lostIs$


















z-SubprocessStreamProtocol.pipe_connection_lostc

Csd
|_|�
�
dS)NT)rr/)
rrrr�process_exited`s

z'SubprocessStreamProtocol.process_exitedc

Cs(t|j
�
d
kr$|jr$|j��
d|_dS)Nr)�lenrrrr-)
rrrrr/ds



z/SubprocessStreamProtocol._maybe_close_transport)r�
__module__�__qualname__�__doc__r
r r)r,r2r3r/�
__classcell__rr)
rrr
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|_|
��|_dS)
N)rZ	_protocolr&rrrZget_pid�pid)rr(r"rrrrr
ks






zProcess.__init__c

Csd
|jj
�d|j�d�S)N�
<r�
>)rrr:)
rrrrr ts
zProcess.__repr__c

Cs
|j�
�S)
N)rZget_returncode)
rrrr�
returncodewszProcess.returncodec

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

dS)
N)r�send_signal)r�signalrrrr?s
zProcess.send_signalc

Cs|j�
�
dS)
N)r�	terminate)
rrrrrA�s
zProcess.terminatec

Cs|j�
�
dS)
N)r�kill)
rrrrrB�s
zProcess.killc
�s�|j�
�}|j�|
�

|r,t�d
|t|
�
�
y|j��IdH
Wn8tt	fk
rx
}
z|rht�d||�
Wdd}~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	�debugr4Zdrain�BrokenPipeError�ConnectionResetErrorr-)r�inputrEr0rrr�_feed_stdin�s









 

zProcess._feed_stdinc


�sdS)
Nr)
rrrr�_noop�s
z
Process._noopc�s�|j�
|
�
}|
d
kr|j}n|
dks(t�
|j}|j��rV|
dkrDdnd}t�d||�
|�	�IdH}|j��r�|
dkrzdnd}t�d||�
|�
�
|S)Nr!rrrz%r communicate: read %sz%r communicate: close %s)rr$r�AssertionErrorrr&rCr	rE�readr-)rr*r(�stream�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)	rIrJrrPrrZgatherr&r>)rrHrrrrrr�communicate�s












zProcess.communicate)
N)rr5r6r
r �propertyr=r>r?rArBrIrJrPrQrrrrr9js
	r9c
�sP�
dkrt�
��
��
fd
d�}�
j||f|
||d�|��
IdH\}}	t||	�
�S)Ncst��
d
�S)N)rr)
r
r)rrrr�<lambda>�s
z)create_subprocess_shell.<locals>.<lambda>)rrr)r�get_event_loopZsubprocess_shellr9)
�cmdrrrrr�kwds�protocol_factoryr(r"r)rrrr�s





r)rrrrrc
�sT�
dkrt�
��
��
fd
d�}�
j||f|�|
||d�|��
IdH\}	}
t|	|
�
�S)Ncst��
d
�S)N)rr)
r
r)rrrrrS�s
z(create_subprocess_exec.<locals>.<lambda>)rrr)rrTZsubprocess_execr9)Zprogramrrrrr�argsrVrWr(r"r)rrrr
�s






r
)�__all__�
subprocess�rrrr�logr	�PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolr
r9Z_DEFAULT_LIMITrr
rrrr�<module>
s"






XV