File manager

3


 \��@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�Zeddddejfdd
�
�
Zeddddejd�dd��
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
�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__��*/usr/lib64/python3.6/asyncio/subprocess.pyrs





z!SubprocessStreamProtocol.__init__c
Csf|jj
g
}
|jdk	r$|
jd
|j�

|jdk	r>|
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	rDtj|j|jd�|_|jj|�

|jj	d
�

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

|jj	d�

|
j
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|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|
dkr<|j}n|
dkrL|j}nd}|dkrt|dkrj|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

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



z/SubprocessStreamProtocol._maybe_close_transport)r�
__module__�__qualname__�__doc__rr r)r,r2r3r/�
__classcell__rr)
rrrs

rc@s~eZ
dZd
d�Zdd�Zedd��
Zedd��
Zd	d
�Z	dd�Z
d
d�Zedd��
Zedd��
Z
edd��
Zeddd�
�
ZdS)�ProcesscCs8|
|_||_
||_|j|_|j|_|j|_|
j�|_dS)
N)rZ	_protocolr&rrrZget_pid�pid)rr(r"rrrrrls






zProcess.__init__c

Csd
|jj
|jfS)Nz<%s %s>)rrr:)
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
Wn8tt	fk
rx
}
z|rhtjd||�
WYdd}~XnX|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�inputrCr0rrr�_feed_stdin�s








 

zProcess._feed_stdinc


CsdS)
Nr)
rrrr�_noop�sz
Process._noopccs�|jj
|
�
}|
d
kr|j}n|
dks(t�
|j}|jj�rV|
dkrDdnd}tjd||�
|j	�EdH}|jj�r�|
dkrzdnd}tjd||�
|j
�
|S)Nr!rrrz%r communicate: read %sz%r communicate: close %s)rr$r�AssertionErrorrr&rAr
rC�readr-)rr*r(�stream�name�outputrrr�_read_stream�s













zProcess._read_streamNccs�|
dk	r|j|
�
}n|j
�}|jdk	r2|jd
�
}n|j
�}|jdk	rP|jd�
}n|j
�}tj||||jd�EdH\}}}|j�EdH
||fS)Nrr!)
r)	rGrHrrNrrZgatherr&r<)rrFrrrrrr�communicate�s











zProcess.communicate)
N)rr5r6rr �propertyr;r	r<r=r?r@rGrHrNrOrrrrr9ks
	
r9c
+sP�
dkrtj
��
��
fd
d�}�
j||f|
||d�|��
EdH\}}	t||	�
�S)Ncst��
d
�S)N)rr)
rr)rrrr�<lambda>�s
z)create_subprocess_shell.<locals>.<lambda>)rrr)r�get_event_loopZsubprocess_shellr9)
�cmdrrrrr�kwds�protocol_factoryr(r"r)rrrr�s





)rrrrrc
/sT�
dkrtj
��
��
fd
d�}�
j||f|�|
||d�|��
EdH\}	}
t|	|
�
�S)Ncst��
d
�S)N)rr)
rr)rrrrrQ�s
z(create_subprocess_exec.<locals>.<lambda>)rrr)rrRZsubprocess_execr9)Zprogramrrrrr�argsrTrUr(r"r)rrrr
�s






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


X]