$94 GRAYBYTE WORDPRESS FILE MANAGER $35



��Yf��
@s 
dd
gZddl
Z
ddlmZ
ddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
l	m
Z

e
jZe
jZe
j
Z
Gdd�dejej�ZGd
d�d�Zeddddejdd
��
Zedddddddddejdd��
ZdS)�create_subprocess_exec�create_subprocess_shell�N�
)
�events)
�	protocols)
�streams)
�tasks)
�	coroutine)
�loggercspeZ
dZd
Z�f
dd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
�S)�SubprocessStreamProtocolz0Like StreamReaderProtocol, but for a subprocess.csRt�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/python35/lib64/python3.5/asyncio/subprocess.pyrs

	

	
	
z!SubprocessStreamProtocol.__init__c
Cs�|jj
g
}
|jdk	r2|
jd
|j�

|jdk	rU|
jd|j�

|jdk	rx|
jd|j�

ddj|
�
S)Nzstdin=%rz	stdout=%rz	stderr=%rz<%s>�
 )r�__name__r�appendrr�join)r�inforrr�__repr__s







z!SubprocessStreamProtocol.__repr__cCs
|
|_|
j
d
�
}|dk	retjd|jd|j�|_|jj|�

|jj	d
�

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

|jj	d�

|
j
d�
}|dk	r
tj|d|ddd|j�
|_dS)Nrrr�r�protocol�reader)
r�get_pipe_transportr�StreamReaderr�_looprZ
set_transportrrr�StreamWriterr)r�	transportZstdout_transportZstderr_transportZstdin_transportrrr�connection_made(s&
	














z(SubprocessStreamProtocol.connection_madecCsS|
d
kr|j}n|
dkr0|j
}nd}|dk	rO|j|�

dS)Nrr!)rrZ	feed_data)r�fd�datar#rrr�pipe_data_received@s





z+SubprocessStreamProtocol.pipe_data_receivedcCs�|
d
kr<|j}|dk	r+|j
�
|j|�

dS|
dkrT|j}n|
dkrl|j}nd}|dkr�|dkr�|j�
n
|j|�

|
|jkr�|jj|
�

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















z-SubprocessStreamProtocol.pipe_connection_lostc

Csd
|_|j
�
dS)NT)rr/)
rrrr�process_exitedas
	
z'SubprocessStreamProtocol.process_exitedc

Cs8t|j
�
d
kr4|jr4|jj�
d|_dS)Nr)�lenrrrr-)
rrrrr/es



z/SubprocessStreamProtocol._maybe_close_transport)r�
__module__�__qualname__�__doc__rr r)r,r2r3r/rr)
rrrs

rc@s�eZ
dZd
d�Zdd�Zedd��
Zedd��
Zd	d
�Z	dd�Z
d
d�Zedd��
Zedd��
Z
edd��
Zeddd�
�
ZdS)�ProcesscCsR|
|_||_
||_|j|_|j|_|j|_|
j�|_dS)
N)rZ	_protocolr&rrrZget_pid�pid)rr(r"rrrrrls
	
	
	



zProcess.__init__c

Csd
|jj
|jfS)Nz<%s %s>)rrr9)
rrrrr us
zProcess.__repr__c


Cs
|jj
�S)
N)rZget_returncode)
rrrr�
returncodexszProcess.returncodec

cs|jj
�Ed
HS)zdWait until the process exit and return the process return code.

        This method is a coroutine.N)rZ_wait)
rrrr�wait|szProcess.waitcCs|jj
|
�

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


Cs|jj
�
dS)
N)r�	terminate)
rrrrr>�s
zProcess.terminatec


Cs|jj
�
dS)
N)r�kill)
rrrrr?�s
zProcess.killccs�|jj
�}|jj|
�

|r>tjd
|t|
�
�
y|jj�EdH
WnDtt	fk
r�
}
z|r�tjd||�
WYdd}~Xn
X|r�tjd|�
|jj
�
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�inputrBr0rrr�_feed_stdin�s


	




&

zProcess._feed_stdinc


CsdS)
Nr)
rrrr�_noop�sz
Process._noopccs�|jj
|
�
}|
d
kr*|j}n	|j}|jj�rm|
dkrTdnd}tjd||�
|j�EdH}|jj�r�|
dkr�dnd}tjd||�
|j	�
|S)Nr!rrrz%r communicate: read %sz%r communicate: close %s)
rr$rrr&r@r
rB�readr-)rr*r(�stream�name�outputrrr�_read_stream�s

	









zProcess._read_streamNccs�|
dk	r|j|
�
}n|j
�}|jdk	rK|jd
�
}n|j
�}|jdk	rx|jd�
}n|j
�}tj|||d|j�
EdH\}}}|j�EdH
||fS)Nrr!r)	rFrGrrLrrZgatherr&r;)rrErrrrrr�communicate�s








zProcess.communicate)rr5r6rr �propertyr:r	r;r<r>r?rFrGrLrMrrrrr8ks
	
r8c

+so�
dkrtj
��
��
fd
d�}�
j||d|
d|d||�EdH\}}	t||	�
�S)Ncstd
�d�
�S)Nrr)
rr)rrrr�<lambda>�s
z)create_subprocess_shell.<locals>.<lambda>rrr)r�get_event_loopZsubprocess_shellr8)
�cmdrrrrr�kwds�protocol_factoryr(r"r)rrrr�s





rrrrrc
/sr�
dkrtj
��
��
fd
d�}�
j|||d|
d|d||�EdH\}	}
t|	|
�
�S)Ncstd
�d�
�S)Nrr)
rr)rrrrrO�s
z(create_subprocess_exec.<locals>.<lambda>rrr)rrPZsubprocess_execr8)Zprogramrrrrr�argsrRrSr(r"r)rrrr
�s



	


)�__all__�
subprocess�rrrrZ
coroutinesr	�logr
�PIPEZSTDOUTZDEVNULLZFlowControlMixinZSubprocessProtocolrr8Z_DEFAULT_LIMITrr
rrrr�<module>
s(




	
	
	
X]